Redisson 锁续期举个实际例子，我看看代码样子

好的，我来给你展示一个 Redisson 分布式锁续期的实际代码例子：

1. import org.redisson.Redisson;
2. import org.redisson.api.RLock;
3. import org.redisson.api.RedissonClient;
4. import org.redisson.config.Config;
6. import java.util.concurrent.TimeUnit;
8. public class RedissonLockExample {
10. private static RedissonClient redissonClient;
12. static {
13. // 初始化 Redisson 客户端
14. Config config = new Config();
15. config.useSingleServer()
16. .setAddress("redis://127.0.0.1:6379");
17. redissonClient = Redisson.create(config);
18. }
20. public static void main(String[] args) {
21. // 获取锁实例
22. RLock lock = redissonClient.getLock("my_distributed_lock");
24. try {
25. // 方式1: 普通加锁，自动续期（默认锁超时30秒，每10秒续期一次）
26. lock.lock();
28. // 方式2: 指定锁超时时间（不会自动续期，超时后自动释放）
29. // lock.lock(10, TimeUnit.SECONDS);
31. // 方式3: 尝试获取锁，最多等待5秒，获取后持有10秒（不会自动续期）
32. // boolean locked = lock.tryLock(5, 10, TimeUnit.SECONDS);
33. // if (!locked) {
34. // System.out.println("获取锁失败");
35. // return;
36. // }
38. System.out.println("成功获取锁，开始执行业务逻辑...");
40. // 模拟长时间业务操作（超过锁超时时间，验证续期效果）
41. // 这里休眠25秒，超过默认的30秒锁超时的三分之二
42. Thread.sleep(25000);
44. System.out.println("业务逻辑执行完成，准备释放锁");
46. } catch (InterruptedException e) {
47. Thread.currentThread().interrupt();
48. } finally {
49. // 释放锁
50. if (lock.isLocked() && lock.isHeldByCurrentThread()) {
51. lock.unlock();
52. System.out.println("锁已释放");
53. }
54. }
56. // 关闭客户端
57. redissonClient.shutdown();
58. }
59. }

关键点说明：

1. 自动续期机制：
   • 使用 lock() 不加参数时，默认锁超时时间为 30秒
   • Redisson 会启动一个后台定时任务，每 10秒 检查一次锁是否仍被持有
   • 如果持有，则自动将锁的过期时间延长至 30秒
2. 续期原理：
   1. // Redisson 内部续期逻辑（简化版）
   2. // 每隔 lockWatchdogTimeout / 3 = 10秒 执行一次续期
   3. public void renewExpiration() {
   4. ExpirationEntry entry = EXPIRATION_RENEWAL_MAP.get(getEntryName());
   5. if (entry == null) {
   6. return;
   7. }
   9. // 通过 Lua 脚本原子性地续期
   10. schedule(executorService, () -> {
   11. if (entry.isCancelled()) {
   12. return;
   13. }
   14. // 延长锁过期时间
   15. Long ttl = commandExecutor.evalWriteAsync(getName(),
   16. LongCodec.INSTANCE, RedisCommands.EVAL_LONG,
   17. "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +
   18. "redis.call('pexpire', KEYS[1], ARGV[1]); return 1; " +
   19. "end; return 0;",
   20. Collections.singletonList(getName()),
   21. internalLockLeaseTime, getLockName());
   22. // 继续调度下次续期
   23. renewExpiration();
   24. }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS);
   25. }
3. 手动指定超时时间：
   • lock(10, TimeUnit.SECONDS) – 锁超时10秒，不会自动续期
   • tryLock(waitTime, leaseTime, TimeUnit) – 最多等待waitTime秒，获取后持有leaseTime秒
4. 锁的释放：
   • 业务完成后调用 unlock() 释放
   • 使用 isLocked() 和 isHeldByCurrentThread() 确保安全释放

Maven 依赖：

1. <dependency>
2. <groupId>org.redisson</groupId>
3. <artifactId>redisson</artifactId>
4. <version>3.23.5</version>
5. </dependency>

场景适用：

• 需要执行较长时间的业务操作（如批量数据处理）
• 防止因业务执行时间超过锁超时导致的并发问题
• 需要高可靠的分布式锁保证