redisson续期是怎么续的

### Redisson续期机制的源码解析 #### WatchDog超时续约机制 Redisson通过`WatchDog`机制来自动延长分布式锁的有效时间，防止因TTL设置较短而导致误释放的情况发生。每当一个线程成功获取到锁之后，Redisson会启动一个定时任务，在距离锁到期前的一段时间内（默认为TTL的三分之一），尝试对该锁进行续期操作[^1]。 以下是具体的实现逻辑： 1. **初始化WatchDog** 当调用`tryLock()`方法并成功获得锁时，Redisson会在内部创建一个`RenewExpirationTask`对象，并将其提交给调度器执行。此任务负责定期更新锁的过期时间[^3]。 2. **续期逻辑** `RenewExpirationTask`的任务核心在于不断向Redis发送命令以刷新锁的TTL值。具体来说，它使用了一个原子性的Lua脚本来完成这一过程，确保即使在网络延迟或其他异常情况下也能安全地延续锁的生命周期。 ```lua -- Lua 脚本用于续期锁 if redis.call("get", KEYS[1]) == ARGV[1] then return redis.call("pexpire", KEYS[1], ARGV[2]) else return 0 end ``` 上述代码片段展示了如何判断当前客户端是否仍持有锁，如果条件满足，则重新设定新的过期时间。 3. **取消WatchDog** 在释放锁的过程中，除了清理Redis中的键外，还会停止对应的`RenewExpirationTask`任务，从而终止后续不必要的续期动作。 #### 源码示例 以下是从官方文档中提取的部分关键代码段，展示加锁与续期的核心部分： ```java // 获取锁 public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException { Long threadId = Thread.currentThread().getId(); // 设置初始租约时间和最大等待时间 RFuture<Boolean> future = commandExecutor.evalWriteAsync( getName(), StringCodec.INSTANCE, "if (redis.call('exists', KEYS[1]) == 0 or 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 1; end; return 0;", Collections.singletonList(getName()), unit.toMillis(leaseTime), getEntryName(threadId)); Boolean result = future.sync(); if (!result && waitTime > 0) { // 如果未获取到锁则进入等待队列... } return result; } // 自动续期任务 private class RenewExpirationTask implements Runnable { @Override public void run() { while (!isCancelled()) { // 只要没有被显式取消就一直运行 try { renewCommand(); // 发送续命指令至Redis服务器端 Thread.sleep(expirationIntervalMs); } catch (InterruptedException e) { break; } } } private void renewCommand() { commandExecutor.writeAsync( name, StringCodec.INSTANCE, new ScriptOp(LUA_SCRIPT_RENEW_EXPIRATION), Arrays.asList(name, entryName, ttlInMilliseconds.toString())); } } ``` 以上Java代码清晰展现了Redisson是如何结合异步编程模型和Lua脚本来保障分布式环境下的数据一致性和高效性能。 --- ### 总结 Redisson的续期机制主要依靠`WatchDog`定时任务配合Lua脚本完成。这种设计不仅简化了开发者手动管理锁生命周期的工作量，同时也增强了系统的稳定性和可靠性。

<think>我们正在讨论Redisson中键的过期时间设置与自动续期机制。根据引用内容，我们可以总结如下： 1. **自动续期触发条件**：只有使用无参的`lock()`方法时才会启用看门狗自动续期机制（引用[1]和[2]）。如果指定了leaseTime（如`lock(30, TimeUnit.SECONDS)`），则不会自动续期。 2. **自动续期原理**：通过看门狗（Watch Dog）机制，一个后台线程定期（默认10秒）检查持有锁的客户端是否仍然活跃，如果是，则通过Lua脚本重置键的过期时间（引用[2]和[3]）。 3. **手动续期**：如果使用指定leaseTime的加锁方式，需要自己实现续期逻辑，例如在业务代码中判断锁是否仍被当前线程持有，然后调用`expire`方法重新设置过期时间（引用[1]）。 4. **键的过期时间设置**：在加锁时，如果不指定leaseTime，则默认使用`lockWatchdogTimeout`（默认30秒）作为键的过期时间，并启动看门狗自动续期；如果指定leaseTime，则直接使用该值作为过期时间，且不自动续期。 5. **等待锁的机制**：Redisson使用Redis的发布订阅机制来避免无效的轮询，当锁释放时，等待的客户端会收到通知（引用[4]和[5]）。 现在，针对用户的问题“Redisson 设置键的过期时间与自动续期方法”，我们可以从以下几个方面回答： ### 一、设置键的过期时间的方法 1. **自动设置（启用看门狗时）**：使用无参`lock()`方法，Redisson会自动设置过期时间为`lockWatchdogTimeout`（默认30秒）并自动续期。 2. **手动设置**：在加锁时指定leaseTime，例如： ```java lock.lock(30, TimeUnit.SECONDS); // 设置30秒过期，不自动续期 ``` 或者在加锁后手动调整过期时间： ```java if (lock.isHeldByCurrentThread()) { lock.expire(60, TimeUnit.SECONDS); // 重新设置为60秒过期 } ``` ### 二、自动续期机制的管理 1. **启用自动续期**：使用无参`lock()`方法。 2. **修改自动续期参数**： - 调整看门狗默认超时时间：通过配置`lockWatchdogTimeout`（单位毫秒），例如： ```java Config config = new Config(); config.setLockWatchdogTimeout(60000L); // 设置为60秒 RedissonClient redisson = Redisson.create(config); ``` - 续期间隔：固定为`lockWatchdogTimeout / 3`（例如默认30秒则每10秒续期一次），不可直接配置，但可通过调整`lockWatchdogTimeout`间接影响。 3. **停止自动续期**： - 调用`unlock()`释放锁时会自动停止续期。 - 在程序关闭时，确保调用`redisson.shutdown()`来停止所有后台线程（包括看门狗）。 ### 三、注意事项 1. **避免混淆两种模式**：指定leaseTime和不指定leaseTime是两种互斥的模式，前者需要自己管理过期和续期，后者由看门狗管理。 2. **锁释放与续期的关系**：只有持有锁的线程才能续期（通过验证客户端ID）。 3. **网络问题处理**：如果续期请求失败，看门狗会尝试重试，但多次失败后最终会因锁过期而自动释放，避免死锁。 ### 四、配置示例 在Spring Boot中配置`lockWatchdogTimeout`： ```yaml spring: redis: redisson: config: | lockWatchdogTimeout: 60000 # 其他配置... ``` ### 五、手动续期示例 当使用指定leaseTime的锁时，可以自定义续期逻辑（例如在业务代码中定时续期）： ```java RLock lock = redisson.getLock("myLock"); lock.lock(30, TimeUnit.SECONDS); // 初始30秒 try { // 业务处理 // 在业务执行过程中，如果预计会超时，可以手动续期 if (lock.isHeldByCurrentThread()) { lock.expire(30, TimeUnit.SECONDS); // 再续30秒 } } finally { lock.unlock(); } ``` ### 六、自动续期示例 ```java RLock lock = redisson.getLock("myLock"); lock.lock(); // 自动续期模式 try { // 长时间业务处理（看门狗会自动续期） } finally { lock.unlock(); } ``` ### 总结 - **自动续期**：使用无参`lock()`，由看门狗负责，默认30秒过期，每10秒续期一次。 - **手动设置过期时间**：通过`lock(leaseTime, unit)`或`expire(time, unit)`方法。 - **关键配置**：通过`lockWatchdogTimeout`调整自动续期的超时时间。 根据引用内容，特别是引用[1][2][3]的说明，我们确保了上述回答的准确性。 §§相关问题§§ 1. 在Redisson中，如果使用指定leaseTime的锁，如何实现可靠的续期机制？ 2. 如何调整Redisson看门狗的续期时间间隔？ 3. Redisson的自动续期机制在分布式系统故障时如何保证一致性？</think>### Redisson 键过期时间设置与自动续期机制详解 #### 一、键过期时间设置方法 ##### 1. **初始化设置** 在创建锁时指定过期时间（禁用自动续期）： ```java RLock lock = redisson.getLock("resource_lock"); // 设置30秒过期时间（无自动续期） lock.lock(30, TimeUnit.SECONDS); ``` *特点*： - 锁在30秒后自动释放 - **不会触发看门狗自动续期**[^1] - 适合短期任务 ##### 2. **运行时动态调整** ```java if (lock.isHeldByCurrentThread()) { // 手动重置为60秒过期 lock.expire(60, TimeUnit.SECONDS); } ``` *适用场景*： - 需要延长锁持有时间 - 业务处理时间不确定时[^1] ##### 3. **配置文件设置** 在`redisson.yaml`中全局配置： ```yaml lockWatchdogTimeout: 60000 # 默认自动续期超时(毫秒) ``` #### 二、自动续期机制 ##### 1. **启用条件** ```java // ✅ 无参lock()启用看门狗 RLock lock = redisson.getLock("order_lock"); lock.lock(); // 自动续期生效 ``` *核心特征*： - 仅无参`lock()`触发自动续期 - 默认30秒超时 + 10秒续期间隔[^2][^3] - 后台线程池维护续期任务 ##### 2. **续期工作流程 ```mermaid sequenceDiagram 业务线程->>+看门狗线程: lock()请求 看门狗线程->>Redis: 执行Lua加锁脚本 Redis-->>看门狗线程: 返回成功 看门狗线程->>续期映射表: 注册[线程ID, 锁名] loop 每10秒循环 看门狗线程->>Redis: 发送续期Lua脚本 Redis-->>看门狗线程: 返回续期结果 看门狗线程->>Redis: 更新TTL(30秒) end 业务线程->>看门狗线程: unlock()请求 看门狗线程->>续期映射表: 移除注册项 看门狗线程->>Redis: 删除锁 ``` ##### 3. **续期Lua脚本** ```lua if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then redis.call('pexpire', KEYS[1], ARGV[1]); return 1; end; return 0; ``` *安全机制*： 1. 验证客户端ID匹配(`hexists`)[^3] 2. 原子性重置TTL(`pexpire`) 3. 续期间隔 = lockWatchdogTimeout / 3[^2] #### 三、混合使用方案 ```java RLock lock = redisson.getLock("payment_lock"); // 初始获取锁（30秒手动过期） lock.lock(30, TimeUnit.SECONDS); try { // 复杂业务处理 if (needMoreTime) { // 启用自动续期接管 lock.lock(); // 后续由看门狗自动维护 } } finally { lock.unlock(); } ``` *优势*： - 初始阶段避免不必要的续期开销 - 关键阶段启用自动续期保活 #### 四、配置建议 | **场景** | **配置方案** | **注意事项** | |-----------------------|----------------------------------|-----------------------------| | 短期任务(<5秒) | `lock.lock(10, SECONDS)` | 禁用自动续期降低成本 | | 中长期任务(5-60秒) | 无参`lock()`+调整`lockWatchdogTimeout` | 设置超时≥最大预估时间×1.5 | | 超长任务(>1分钟) | 手动续期+心跳检测 | 监控续期成功率 | | 高可用要求 | 启用RedLock多节点模式 | 配合`lockWatchdogTimeout`使用 | #### 五、生产环境实践 1. **监控续期状态** ```java // 获取看门狗续期状态 RedissonClient client = Redisson.create(); RMap<String, Integer> renewalMap = client.getMap("redisson:expiration_renewal_map"); ``` 2. **优雅停机处理** ```java @PreDestroy void shutdown() { // 停止所有续期线程 redisson.getConfig().getExecutor().shutdownNow(); redisson.shutdown(); } ``` 3. **异常处理机制** ```java lock.lock(); try { // 业务代码 } catch (Exception e) { // 异常时主动续期保活 if(lock.isHeldByCurrentThread()) { lock.expire(30, SECONDS); } throw e; } finally { lock.unlock(); } ``` #### 六、常见问题解答 **Q: 为什么设置了leaseTime就不会自动续期？** A: 这是Redisson的**设计原则**：当显式指定过期时间时，系统认为用户能精确控制任务时长，因此禁用自动续期避免资源浪费[^1]。 **Q: 看门狗续期失败会重试吗？** A: 是的，续期失败时会采用**指数退避策略**重试（1s/2s/4s...），直到： 1. 续期成功 2. 达到最大重试次数（主动释放锁） 3. 锁自然过期 **Q: 如何确认自动续期已启用？** A: 检查日志关键词： ``` - Starting redisson watchdog service - Renewal task submitted for lock: 'order_lock' - Lock renewed for key: order_lock ``` > **最佳实践提示**：在关键业务系统中，建议通过`RedissonClient.getConfig().setLockWatchdogTimeout(60000)`将自动续期超时设为业务最大耗时的1.5倍，并配合监控系统跟踪续期成功率[^3]。