Redisson 看门狗原理详解-平芜编程栈

1. 什么是看门狗机制

在分布式锁的实现中，一个核心挑战是：当持有锁的客户端因为 GC 停顿、网络延迟或进程假死等原因，未能及时释放锁时，如何避免锁被永久占用，导致其他客户端无限等待？

Redisson 的看门狗（Watchdog）机制正是为了解决这个问题而设计的。它是一种锁自动续期机制。当客户端成功获取一个 Redisson 锁（默认指RLock）时，如果未指定锁的过期时间（leaseTime），看门狗便会启动一个后台守护线程，定期检查客户端是否还持有锁，并自动为锁续期，从而防止锁因业务执行时间过长而意外过期释放。

2. 看门狗的核心工作流程

看门狗机制的工作流程可以概括为以下几个关键步骤：

加锁：客户端调用lock()方法尝试加锁。
锁设置与看门狗启动：
- 如果加锁时未指定leaseTime（锁租约时间），Redisson 会在 Redis 中创建一个 key，其默认过期时间为30 秒。同时，客户端会启动一个看门狗后台线程。
- 如果指定了leaseTime，则 Redis key 的过期时间就是该值，并且不会启动看门狗线程。
定期续期：看门狗线程会以锁过期时间的 1/3为周期（默认 30 秒 / 3 = 10 秒）进行调度。在每次调度时，它检查当前客户端是否仍持有该锁（即检查本地的一个并发标记）。
执行续期：如果检查通过，看门狗线程会向 Redis 发送一个PEXPIRE命令，将锁 key 的过期时间重新设置为 30 秒（即“续命”）。
业务执行与释放：客户端业务逻辑执行完毕后，调用unlock()方法。该方法会删除 Redis 中的锁 key，并中断看门狗线程的续期循环。
异常处理：如果客户端在持有锁期间崩溃，看门狗线程也会随之停止，锁 key 将在最后一次续期后的 30 秒自动过期，从而避免死锁。

3. 源码逻辑浅析

看门狗的核心逻辑位于RedissonLock类的scheduleExpirationRenewal方法中。以下是一个简化的逻辑说明：

// 伪代码，展示核心逻辑 private void scheduleExpirationRenewal(long threadId) { // 1. 创建一个定时任务 Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() { @Override public void run(Timeout timeout) throws Exception { // 2. 检查当前线程是否还持有锁（通过一个本地 ConcurrentMap） if (internalLockLeaseTime != null && internalLockLeaseTime == -1) { // 3. 如果仍持有，则执行续期命令 (PEXPIRE) RFuture<Boolean> future = commandExecutor.evalWriteAsync( getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " + "redis.call('pexpire', KEYS[1], ARGV[1]); " + "return 1; " + "end; " + "return 0;", Collections.singletonList(getName()), internalLockLeaseTime, getLockName(threadId)); // 4. 续期成功后，递归调用自己，安排下一次续期 future.onComplete((res, e) -> { if (e == null && res) { scheduleExpirationRenewal(threadId); } }); } } }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS); // 延迟时间为租约时间的1/3 // 将定时任务保存起来，以便在解锁时取消 expirationRenewalMap.put(getEntryName(), task); }

关键点：

递归调用：每次成功续期后，会再次调用scheduleExpirationRenewal，从而形成一个周期性的续期循环。
取消机制：在unlock()方法中，会从expirationRenewalMap中取出并取消这个定时任务。

4. 关键特性与注意事项

4.1 默认时间参数

锁默认租约时间：lockWatchdogTimeout，默认30 秒。可通过Config.setLockWatchdogTimeout()全局配置。
续期周期：默认是租约时间的 1/3，即10 秒。

4.2 看门狗的启用条件

启用：使用lock()、tryLock()等方法且未指定leaseTime参数时。也就是leaseTime == -1时。
不启用：
- 加锁时指定了leaseTime。
- 使用lockInterruptibly()等方法且未指定租期（但看门狗仍会工作，原理相同）。