Redisson源码解读-分布式锁( 四 ) _生活百科

scheduleExpirationRenewal 方法处理了ExpirationEntry和如果出现异常则取消看门狗，具体看门狗逻辑在 renewExpiration 方法中
private void renewExpiration() {ExpirationEntry ee = EXPIRATION_RENEWAL_MAP.get(getEntryName());if (ee == null) {return;}// 创建延时任务，延时时间是internalLockLeaseTime / 3Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {@Overridepublic void run(Timeout timeout) throws Exception {ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName());if (ent == null) {return;}Long threadId = ent.getFirstThreadId();if (threadId == null) {return;}// lua脚本判断，如果锁存在，则续期并返回true，不存在则返回falseCompletionStage<Boolean> future = renewExpirationAsync(threadId);future.whenComplete((res, e) -> {if (e != null) {log.error("Can't update lock " + getRawName() + " expiration", e);EXPIRATION_RENEWAL_MAP.remove(getEntryName());return;}if (res) {// 锁续期成功，则再启动一个延时任务，继续监测renewExpiration();} else {// 取消看门狗cancelExpirationRenewal(null);}});}}, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS);ee.setTimeout(task);}Timeout 是一个延时任务，延时 internalLockLeaseTime / 3 时间执行。任务的内容主要是通过 renewExpirationAsync 方法对锁进行续期，如果续期失败（解锁了、锁到期等），则取消看门狗，如果续期成功，则递归 renewExpiration 方法，继续创建延时任务。
internalLockLeaseTime 也就是 lockWatchdogTimeout 参数，默认是 30 秒。
总结本文介绍了Redisson的加锁、解锁、看门狗机制，以及对Redis发布订阅机制的应用。因为篇幅有限，很多细节聊得不够深入。此外Redisson的异步机制、对Netty的使用等都是很值得水文章的。
参考资料
万字长文带你解读Redisson分布式锁的源码 - 知乎 (zhihu.com)
Redis分布式锁-这一篇全了解(Redission实现分布式锁完美方案)

Redisson源码解读-分布式锁( 四 )

经验总结扩展阅读

室温25度熟肉放一夜会坏吗

大蒜长出芽还能吃吗,蒜头发芽了还能吃吗？

怎么让孩子表达大胆

开空调盖被子是什么心理

汽车暖风怎么关

抖音怎么使用自己的音乐?

相思难相拥终不得情的网名

金华聚佳是什么意思?

空调质保期一般是几年

汉兰达紫金版是什么？

给初一新生的一句话需要怎么表达期许

热情穷逼是什么意思?

《情书》：爱情中最遥远的距离，是你不知道我爱你

四两四钱男命婚姻详解一生，四两四钱男命能成大事吗

外婆菜是什么菜腌制的

作者无笔一个男人的懊悔：娶大龄剩女半年，才知哥们的话不是空穴来风

干墨鱼一般泡水泡多久?

发型以家人之名演员染发，唐灿变成熟女人，看到月亮：乖乖女黑化了！

爱慕|女人看你顺眼，不是说喜欢你，而是开始出现这些迹象

炸鸡店名字创意