当前位置: 首页 > news >正文

Redis系列之客户端Redisson

概述

官方推荐的客户端,支持Redis单实例、Redis哨兵、Redis Cluster、Redis master-slave等各种部署架构。
GitHub,

功能:

  • 分布式锁

分布式锁

使用Redisson提供的分布式锁的一个最常见场景,应用部署为多个节点,然后使用Spring提供的原生@Scheduled任务调度功能;而没有使用xxl-job等轻量级分布式任务调度系统(底层基于数据库悲观锁)

@Scheduled(cron = "0 0 8 * * ?")
public void execute() {RLock lock = redissonClient.getLock("myLock");try {boolean isLock = lock.tryLock(1, 5, TimeUnit.MINUTES);if (!isLock) {log.warn("job正在执行!");return;}log.info("任务开始执行!");} catch (Exception e) {log.error("执行失败:", e);lock.unlock();}
}

通过lock.tryLock()查看源码,一步步往里看:

<T> RFuture<T> tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) {this.internalLockLeaseTime = unit.toMillis(leaseTime);return this.commandExecutor.evalWriteAsync(this.getName(), LongCodec.INSTANCE, command, "if (redis.call('exists', KEYS[1]) == 0) then redis.call('hset', KEYS[1], ARGV[2], 1); redis.call('pexpire', KEYS[1], ARGV[1]); return nil; end; if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then redis.call('hincrby', KEYS[1], ARGV[2], 1); redis.call('pexpire', KEYS[1], ARGV[1]); return nil; end; return redis.call('pttl', KEYS[1]);", Collections.singletonList(this.getName()), new Object[]{this.internalLockLeaseTime, this.getLockName(threadId)});
}

稍微格式化一下,方便阅读:

if (redis.call('exists', KEYS[1]) == 0) then redis.call('hset', KEYS[1], ARGV[2], 1);redis.call('pexpire', KEYS[1], ARGV[1]);return nil;
end;
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1)then redis.call('hincrby', KEYS[1], ARGV[2], 1);redis.call('pexpire', KEYS[1], ARGV[1]);return nil;
end;
return redis.call('pttl', KEYS[1]);

也就是说,需要执行一段Lua脚本:

  • KEYS[1]代表加锁的Key,即myLock
  • ARGV[1]代表加锁Key的生存时间,默认30秒
  • ARGV[2]代表加锁客户端ID,格式UUID:n,如:e197fb92-deeb-4f9d-9d34-51b9b09f0bd7:1,其中n表示Redis Cluster集群节点

第一段if判断语句,用exists myLock判断一下,如果要加锁的Key不存在,则通过命令hset myLock e197fb92-deeb-4f9d-9d34-51b9b09f0bd7:1 1加锁,即设置一个Hash数据结构。命令执行后会生成类似如下数据结构:

myLock:
{
"e197fb92-deeb-4f9d-9d34-51b9b09f0bd7:1": 1
}

接着执行pexpiremyLock 30000命令,设置myLock这个锁Key的生存时间是30秒,加锁完成。

watch dog自动延期机制
客户端1加锁的Key默认过期时间30秒,客户端1只要加锁成功,就会启动一个watchdog后台线程,每隔10秒检查一下,如果客户端1还持有锁Key,就会不断的延长锁Key的生存时间。

释放锁
执行lock.unlock(),即释放分布式锁,执行一次lock.unlock(),对myLock数据结构中的加锁次数减1。
加锁次数未0,说明此客户端已经不再持有锁,触发删除所del myLock命令。其他客户端即可尝试加锁。

缺点

上面那种方案最大的问题,就是如果你对某个Redis Master实例,写入myLock这种锁Key的Value,此时会异步复制给对应的Master Slave实例。

但是这个过程中一旦发生Redis Master宕机,主备切换,Redis Slave变为Redis Master。

会导致客户端2尝试加锁时,在新的Redis Master上完成加锁,客户端1也以为自己成功加锁。

此时就会导致多个客户端对一个分布式锁完成加锁。这时系统在业务语义上一定会出现问题,导致各种脏数据的产生。

所以这个就是Redis Cluster,或是redis master-slave架构的主从异步复制导致的Redis分布式锁的最大缺陷:在Redis Master实例宕机的时候,可能导致多个客户端同时完成加锁。

在基于NIO的Netty框架上,充分利用Redis提供的一系列优势,

问题

ClassNotFoundException: org.nustaq.serialization.FSTConfiguration

Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.redisson.api.RedissonClient]: Factory method 'redisson' threw exception; nested exception is java.lang.NoClassDefFoundError: Lorg/nustaq/serialization/FSTConfiguration;
Caused by: java.lang.ClassNotFoundException: org.nustaq.serialization.FSTConfiguration

解决方案,pom.xml文件里新增:

<dependency><groupId>de.ruedigermoeller</groupId><artifactId>fst</artifactId><version>2.57</version>
</dependency>

attempt to unlock lock, not locked by current thread by node id

java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: 633dfc8a-b388-4ba1-ad64-75b491d0c5f2 thread-id: 118at org.redisson.misc.RedissonPromise.trySuccess(RedissonPromise.java:88)at org.redisson.command.CommandAsyncService.handleReference(CommandAsyncService.java:1067)at org.redisson.command.CommandAsyncService.handleSuccess(CommandAsyncService.java:1059)at org.redisson.command.CommandAsyncService.checkAttemptFuture(CommandAsyncService.java:1041)at org.redisson.command.CommandAsyncService$12.operationComplete(CommandAsyncService.java:805)at org.redisson.misc.RedissonPromise.trySuccess(RedissonPromise.java:88)at org.redisson.client.handler.CommandDecoder.completeResponse(CommandDecoder.java:448)at org.redisson.client.handler.CommandDecoder.handleResult(CommandDecoder.java:443)at org.redisson.client.handler.CommandDecoder.decode(CommandDecoder.java:354)at org.redisson.client.handler.CommandDecoder.decodeCommand(CommandDecoder.java:128)at org.redisson.client.handler.CommandDecoder.decode(CommandDecoder.java:108)

解决方案:

finally {if (lock.isLocked() && lock.isHeldByCurrentThread()) {lock.unlock();}
}

Command (SET), params [] succesfully sent, but channel [] has been closed

详细的报错信息:

org.springframework.data.redis.RedisConnectionFailureException: Command (SET), params [] succesfully sent, but channel [] has been closed!
at org.redisson.spring.data.connection.RedissonExceptionConverter.convert(RedissonExceptionConverter.java:40)at org.redisson.spring.data.connection.RedissonExceptionConverter.convert(RedissonExceptionConverter.java:35)at org.springframework.data.redis.PassThroughExceptionTranslationStrategy.translate(PassThroughExceptionTranslationStrategy.java:44)at org.redisson.spring.data.connection.RedissonConnection.transform(RedissonConnection.java:237)at org.redisson.spring.data.connection.RedissonConnection.syncFuture(RedissonConnection.java:232)at org.redisson.spring.data.connection.RedissonConnection.sync(RedissonConnection.java:462)at org.redisson.spring.data.connection.RedissonConnection.write(RedissonConnection.java:828)at org.redisson.spring.data.connection.RedissonConnection.set(RedissonConnection.java:596)at org.springframework.data.redis.connection.DefaultStringRedisConnection.set(DefaultStringRedisConnection.java:946)at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:224)at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)	

参考GitHub-issue:

Redis connection is closed for some reason. Try to set pingConnectionInterval: 60000.

解决方法:在redisson.yml文件里新增配置:pingConnectionInterval: 60000

RedisResponseTimeoutException: Redis server response timeout occured after 3 retry attempts. Command: params:

解决方法同上,新增配置。

参考

http://www.lryc.cn/news/161975.html

相关文章:

  • centos 端口被占用的快速排查方式
  • Java“牵手”淘宝商品列表数据,关键词搜索淘宝商品数据接口,淘宝API申请指南
  • OpenEuler/CentOS如何修改密码策略
  • # Spring MVC与RESTful API:如何设计高效的Web接口
  • Scrum敏捷模式的优势点、实践经验及适用企业
  • 【C++杂货铺】探索stack和queue的底层实现
  • “系统的UI”——SystemUI
  • 类和对象:构造函数,析构函数与拷贝构造函数
  • 谈谈Java的特点和优点以及选择Java的原因
  • 消息队列(MQ)面试
  • 无涯教程-JavaScript - COUPNUM函数
  • 上海控安携汽车网络安全新研产品出席AUTOSEMO“恒以致远,共创共赢”主题研讨会
  • 小程序引入高德/百度地图坐标系详解
  • 英诺森 “供应链智能数据平台”荣获“科技进步奖”
  • kafka 3.5 主题分区的Follower创建Fetcher线程从Leader拉取数据源码
  • Golang web 项目中实现自定义 recovery 中间件
  • Direct3D绘制旋转立方体例程
  • ElementUI浅尝辄止31:Tabs 标签页
  • 将 ChatGPT 用于数据科学项目的指南
  • 06-JVM对象内存回收机制深度剖析
  • [VSCode] 替换掉/去掉空行
  • 时序分解 | MATLAB实现ICEEMDAN+SE改进的自适应经验模态分解+样本熵重构分量
  • python内网环境安装第三方包【内网搭建开发环境】
  • 7.13 在SpringBoot中 正确使用Validation实现参数效验
  • Matlab图像处理之Lee滤波器
  • C++系列-const修饰的常函数
  • fail-safe 机制与 fail-fast 机制
  • LLM 位置编码及外推
  • 第3章_瑞萨MCU零基础入门系列教程之开发环境搭建与体验
  • AI在医疗保健领域:突破界限,救治生命