Redisson工具类库给大家推荐一个基于Redis开发的工具类库这个类库提供了很多实用的功能比如限流布隆过滤器分布式锁等dependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion3.16.8/version/dependency我们今天就只分析一下分布式锁的实现Redisson提供了很多加锁的方式非阻塞式加锁阻塞式加锁加公平锁等。另外还提供自动延时的功能当一个任务没有完成任务式Redisson会通过Watch Dog不断延长锁的期限阻塞式获取锁// 阻塞式获取锁并且是重入锁RLocklockclient.getLock(testLock);try{lock.lock();lock.lock();// 执行业务逻辑}finally{lock.unlock();lock.unlock();}非阻塞式获取锁RLocklockclient.getLock(lock);if(lock.tryLock()){System.out.println(获锁成功);}else{System.out.println(获锁失败);}Redisson如何实现一个可重入锁加锁执行脚本脚本入参参数含义KEYS[1]锁的名字ARGV[1]锁的超时时间毫秒ARGV[2]客户端唯一ID:线程ID// 锁不存在if(redis.call(exists,KEYS[1])0)then// 新建锁加锁次数设为1并设置超时时间redis.call(hincrby,KEYS[1],ARGV[2],1);redis.call(pexpire,KEYS[1],ARGV[1]);returnnil;end;if(redis.call(hexists,KEYS[1],ARGV[2])1)then// 当前线程已经获取到锁了将加锁次数加1redis.call(hincrby,KEYS[1],ARGV[2],1);redis.call(pexpire,KEYS[1],ARGV[1]);returnnil;end;// 加锁失败returnredis.call(pttl,KEYS[1]);加锁成功返回nil否则返回锁的剩余时间解锁执行脚本脚本入参参数含义KEYS[1]锁的名字KEYS[2解锁消息的频道频道名为redisson_lock__channel:{锁的名字}ARGV[1]固定为0Redisson定义解锁消息固定为0ARGV[2]锁的超时时间ARGV[3]客户端唯一ID:线程ID// 为0表示锁不存在if(redis.call(hexists,KEYS[1],ARGV[3])0)thenreturnnil;end;// 将加锁次数减1local counterredis.call(hincrby,KEYS[1],ARGV[3],-1);if(counter0)then// 当前线程持有锁设置超时时间redis.call(pexpire,KEYS[1],ARGV[2]);return0;else// 加锁次数为0了直接删除锁并广播释放锁的消息redis.call(del,KEYS[1]);redis.call(publish,KEYS[2],ARGV[1]);return1;end;returnnil;解锁成功为什么要发布消息呢因为阻塞式获取锁的线程并不是一直不断的尝试获取锁而是会阻塞当收到解锁的消息后才会唤醒重新开始抢锁。Redisson如何实现锁的自动延时在 Redis 分布式锁的实现中如果某个线程获取了锁但在执行业务逻辑时耗时过长或者锁的过期时间TTL设置得太短锁就会在业务还没跑完时被自动释放。这时其他线程就能趁虚而入拿到锁从而导致超卖、数据错乱等并发安全问题。为了解决这个问题Redisson 引入了看门狗Watchdog机制。简单来说它就像一个忠诚的保安只要你的业务还在跑它就会不断帮你给锁续期看门狗的核心机制可以总结为如下几个步骤1. 触发条件不显式指定过期时间。只有当你加锁时没有显式指定锁的释放时间时看门狗机制才会启动。lock.lock(10, TimeUnit.SECONDS); ➔ 不会启动看门狗10秒后锁必释放lock.lock(); ➔ 会启动看门狗2.赋予默认过期时间。加锁成功后Redisson 会给这个锁设置一个默认的过期时间默认是 30 秒由配置项 lockWatchdogTimeout 决定3.开启定时续期任务。Redisson 内部会启动一个定时任务基于 Netty 的 HashedWheelTimer 时间轮。它的触发周期是lockWatchdogTimeout / 3也就是默认每 10 秒执行一次4.检查并续期。当 10 秒时间到看门狗会检查当前线程是否还持有这把锁如果业务还在执行看门狗会向 Redis 发送一段 Lua 脚本把锁的过期时间重新重置为 30 秒。如果业务执行完毕或服务宕机看门狗停止续命锁会在剩余的 TTL 到期后自动释放防止死锁
Redis源码解析：详解Redis超实用工具类库Redisson
Redisson工具类库给大家推荐一个基于Redis开发的工具类库这个类库提供了很多实用的功能比如限流布隆过滤器分布式锁等dependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion3.16.8/version/dependency我们今天就只分析一下分布式锁的实现Redisson提供了很多加锁的方式非阻塞式加锁阻塞式加锁加公平锁等。另外还提供自动延时的功能当一个任务没有完成任务式Redisson会通过Watch Dog不断延长锁的期限阻塞式获取锁// 阻塞式获取锁并且是重入锁RLocklockclient.getLock(testLock);try{lock.lock();lock.lock();// 执行业务逻辑}finally{lock.unlock();lock.unlock();}非阻塞式获取锁RLocklockclient.getLock(lock);if(lock.tryLock()){System.out.println(获锁成功);}else{System.out.println(获锁失败);}Redisson如何实现一个可重入锁加锁执行脚本脚本入参参数含义KEYS[1]锁的名字ARGV[1]锁的超时时间毫秒ARGV[2]客户端唯一ID:线程ID// 锁不存在if(redis.call(exists,KEYS[1])0)then// 新建锁加锁次数设为1并设置超时时间redis.call(hincrby,KEYS[1],ARGV[2],1);redis.call(pexpire,KEYS[1],ARGV[1]);returnnil;end;if(redis.call(hexists,KEYS[1],ARGV[2])1)then// 当前线程已经获取到锁了将加锁次数加1redis.call(hincrby,KEYS[1],ARGV[2],1);redis.call(pexpire,KEYS[1],ARGV[1]);returnnil;end;// 加锁失败returnredis.call(pttl,KEYS[1]);加锁成功返回nil否则返回锁的剩余时间解锁执行脚本脚本入参参数含义KEYS[1]锁的名字KEYS[2解锁消息的频道频道名为redisson_lock__channel:{锁的名字}ARGV[1]固定为0Redisson定义解锁消息固定为0ARGV[2]锁的超时时间ARGV[3]客户端唯一ID:线程ID// 为0表示锁不存在if(redis.call(hexists,KEYS[1],ARGV[3])0)thenreturnnil;end;// 将加锁次数减1local counterredis.call(hincrby,KEYS[1],ARGV[3],-1);if(counter0)then// 当前线程持有锁设置超时时间redis.call(pexpire,KEYS[1],ARGV[2]);return0;else// 加锁次数为0了直接删除锁并广播释放锁的消息redis.call(del,KEYS[1]);redis.call(publish,KEYS[2],ARGV[1]);return1;end;returnnil;解锁成功为什么要发布消息呢因为阻塞式获取锁的线程并不是一直不断的尝试获取锁而是会阻塞当收到解锁的消息后才会唤醒重新开始抢锁。Redisson如何实现锁的自动延时在 Redis 分布式锁的实现中如果某个线程获取了锁但在执行业务逻辑时耗时过长或者锁的过期时间TTL设置得太短锁就会在业务还没跑完时被自动释放。这时其他线程就能趁虚而入拿到锁从而导致超卖、数据错乱等并发安全问题。为了解决这个问题Redisson 引入了看门狗Watchdog机制。简单来说它就像一个忠诚的保安只要你的业务还在跑它就会不断帮你给锁续期看门狗的核心机制可以总结为如下几个步骤1. 触发条件不显式指定过期时间。只有当你加锁时没有显式指定锁的释放时间时看门狗机制才会启动。lock.lock(10, TimeUnit.SECONDS); ➔ 不会启动看门狗10秒后锁必释放lock.lock(); ➔ 会启动看门狗2.赋予默认过期时间。加锁成功后Redisson 会给这个锁设置一个默认的过期时间默认是 30 秒由配置项 lockWatchdogTimeout 决定3.开启定时续期任务。Redisson 内部会启动一个定时任务基于 Netty 的 HashedWheelTimer 时间轮。它的触发周期是lockWatchdogTimeout / 3也就是默认每 10 秒执行一次4.检查并续期。当 10 秒时间到看门狗会检查当前线程是否还持有这把锁如果业务还在执行看门狗会向 Redis 发送一段 Lua 脚本把锁的过期时间重新重置为 30 秒。如果业务执行完毕或服务宕机看门狗停止续命锁会在剩余的 TTL 到期后自动释放防止死锁
