当前位置: 首页 > news >正文

Redis红锁中的看门狗机制

在 Java 构建微服务或高并发系统时,Redis 分布式锁几乎是标配。为了提高分布式锁的可靠性,Redis 官方提出了 RedLock(红锁)算法,并推荐在加锁过程中引入看门狗机制,以解决锁过早释放的问题。

本文将详细讲解:

  • 为什么在红锁中需要看门狗机制

  • Java 中如何实现看门狗机制(包含 Redisson 和手动实现)

  • 实战建议与注意事项


一、红锁中的锁过期问题

🧨 场景

你使用 Redis 设置一个 10 秒的分布式锁:

SET my-lock <UUID> NX PX 10000

但你的业务逻辑执行了 15 秒 —— 锁在中途自动过期,其他客户端误以为锁已释放,并发执行了本不该同时执行的逻辑!

✅ 解决方案:看门狗机制

引入看门狗机制(Watchdog),定期刷新锁的过期时间,只要业务还在运行,就自动延长锁的 TTL,防止锁失效。


二、Redisson 的自动续期机制(内置看门狗)

Redisson 是 Java 中使用 Redis 分布式锁的首选框架,封装了红锁和看门狗机制。

✅ 使用示例:

RLock lock = redissonClient.getLock("my-lock");lock.lock(); // 默认开启看门狗机制,自动续期try {// 执行业务逻辑(不管你多久,锁都不会提前释放)doSomeLongRunningJob();
} finally {lock.unlock(); // 手动释放锁
}

🔍 内部原理:

  • 默认锁 TTL 为 30 秒

  • Redisson 启动一个定时任务,每 10 秒向 Redis 发送 PEXPIRE 续期

  • 如果客户端宕机或线程终止,Redisson 停止续期,Redis 自动删除锁


三、手动实现看门狗机制(不使用 Redisson)

如果你不使用 Redisson,而是用原生 Redis 客户端(如 Jedis、Lettuce),也可以手动实现看门狗。

🧵 手动看门狗 + 锁代码示例(Jedis)

public class RedisLockWithWatchdog {private static final String LOCK_KEY = "my-lock";private static final String LOCK_VALUE = UUID.randomUUID().toString();private static final int TTL_SECONDS = 10;private static final int WATCHDOG_INTERVAL = 5;private static volatile boolean running = true;private static Jedis jedis = new Jedis("localhost", 6379);public static void main(String[] args) {if (tryLock()) {// 启动看门狗线程Thread watchdog = new Thread(() -> {while (running) {try {TimeUnit.SECONDS.sleep(WATCHDOG_INTERVAL);String val = jedis.get(LOCK_KEY);if (LOCK_VALUE.equals(val)) {jedis.expire(LOCK_KEY, TTL_SECONDS);System.out.println("🔄 看门狗续期锁");} else {break; // 锁已失效或被别人抢了}} catch (InterruptedException e) {break;}}});watchdog.start();try {System.out.println("🚀 执行业务逻辑");TimeUnit.SECONDS.sleep(20); // 模拟长时间任务} catch (Exception e) {e.printStackTrace();} finally {unlock();running = false;}}}private static boolean tryLock() {String result = jedis.set(LOCK_KEY, LOCK_VALUE, "NX", "EX", TTL_SECONDS);return "OK".equals(result);}private static void unlock() {if (LOCK_VALUE.equals(jedis.get(LOCK_KEY))) {jedis.del(LOCK_KEY);System.out.println("✅ 锁释放成功");}}
}

☑️ 说明:

  • WATCHDOG_INTERVAL 是看门狗执行间隔,建议设为 TTL 的一半或 1/3

  • 解锁时使用 UUID 验证防止误删他人锁

  • 如果进程崩溃,看门狗线程终止,Redis 锁会自动过期


四、注意事项与最佳实践

问题解决建议
锁被提前释放使用看门狗定期续期
Redisson 看门狗间隔可通过 setLockWatchdogTimeout() 自定义
客户端宕机看门狗线程停止,Redis 锁自动过期,无需人工清理
UUID 锁标识加锁/续期/解锁都要验证 UUID,确保锁归属
业务异常try-finally 必须保证锁一定释放

五、总结

项目Redisson 自动看门狗手动实现
简洁性✅ 非常方便❌ 代码复杂
安全性✅ 多线程安全⚠ 需小心并发
灵活性✅ 支持配置 TTL✅ 可自定义逻辑
建议使用✅ 推荐生产使用🧪 适合学习实验

📌 参考资料

  • Redis 官方文档:Redlock 分布式锁算法

  • Redisson GitHub:https://github.com/redisson/redisson

  • Lua 脚本实现可重入锁:https://redis.io/docs/latest/develop/patterns/distributed-locks/

http://www.dtcms.com/a/283980.html

相关文章:

  • 如何解决pip安装报错ModuleNotFoundError: No module named ‘flask’问题
  • 【SpringBoot】实战-开发接口-用户-登录
  • APIs案例及知识点串讲(中)
  • docker--安装--原理
  • 寻找数组中的多数元素:HashMap方法解析
  • 【无标题】构建黑洞虚维度空间的完整理论
  • COZE官方文档基础知识解读第五期 —— 插件
  • Android默认背光亮度配置说明
  • 如何清除 npm 缓存
  • web前端渡一大师课 CSS属性计算过程
  • 【Android】ViewBinding(视图绑定)
  • 华为P30/pro (ELE-AL00) 鸿蒙4.2降级 EMUI 9
  • 单片机+微信小程序做示波器
  • 深入解析:前端 localStorage 的读取是异步的吗?为什么硬盘 I/O 是异步的,而它却是同步的?
  • Linux 软件安装的四种方式详解
  • HTTP 状态码笔记
  • 网络原理 —— HTTP
  • uniapp用webview导入本地网页,ios端打开页面空白问题
  • 自定义 django 中间件
  • 《小白学习产品经理》第六章:方法论之SWOT分析
  • 3D工业相机是什么?如何选择和使用它?
  • docker安装与简单项目上手
  • 5. 实战项目类:《用TypeScript + Vite从零搭建企业级React应用》
  • Django由于数据库版本原因导致数据库迁移失败解决办法
  • 我的开发日志:随机数小程序
  • redis中间件
  • 手撕Spring底层系列之:后置处理器“PostProcessor”
  • Vmware虚拟机使用仅主机模式共享物理网卡访问互联网
  • 研报复现|格雷厄姆成长股内在价值策略
  • Error: llama runner process has terminated: exit status 2