java后端开发怎么用Redis实现分布式锁?

使用Redis实现分布式锁需通过SET命令的NX和PX选项保证原子性加锁,用Lua脚本安全释放锁,防止死锁与误删;为支持可重入和避免超时问题,可结合ThreadLocal与看门狗机制;生产环境推荐使用Redisson框架,其提供自动续期、可重入、异常处理等完整特性,比手动实现更可靠。

java后端开发怎么用redis实现分布式锁?

在Java后端开发中,使用Redis实现分布式锁主要是为了在多节点环境下保证共享资源的线程安全。最常见的方式是利用Redis的SET命令配合NX(不存在时设置)和PX(毫秒级过期时间)选项来实现原子性的加锁操作。

1. 基于SET命令的简单分布式锁

Redis 2.6.12以后,SET命令支持多个参数组合,可以原子性地完成“判断key是否存在 + 设置值 + 设置过期时间”的操作。

示例代码:

public class RedisDistributedLock {    private static final String LOCK_SUCCESS = "OK";    private static final String SET_IF_NOT_EXIST = "NX";    private static final String SET_WITH_EXPIRE_TIME = "PX";    private Jedis jedis;    private String lockKey;    private String requestId;    private int expireTime;    public RedisDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {        this.jedis = jedis;        this.lockKey = lockKey;        this.requestId = requestId;        this.expireTime = expireTime;    }    public boolean tryLock() {        String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);        return LOCK_SUCCESS.equals(result);    }}

说明:

立即学习“Java免费学习笔记(深入)”;

lockKey 是锁的唯一标识,比如 “lock:order:1001” requestId 通常用UUID,用来标识哪个客户端持有的锁 设置过期时间防止死锁(如程序崩溃未释放)

2. 正确释放锁:Lua脚本保证原子性

释放锁时必须确保只有自己持有的锁才能被释放,避免误删。使用Lua脚本可以保证“读取value-判断-删除”操作的原子性。

public boolean releaseLock() {    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then " +                    "return redis.call('del', KEYS[1]) " +                    "else " +                    "return 0 " +                    "end";    Object result = jedis.eval(script, List.of(lockKey), List.of(requestId));    return "1".equals(result.toString());}

关键点:

大师兄智慧家政 大师兄智慧家政

58到家打造的AI智能营销工具

大师兄智慧家政 99 查看详情 大师兄智慧家政 通过比较requestId判断是否为锁持有者 Lua脚本在Redis中是原子执行的,不会出现并发问题

3. 可重入性和超时处理

如果需要支持可重入(同一个线程多次获取同一把锁),可以在value中记录线程信息和重入次数,并结合ThreadLocal管理。

关于锁超时:

业务执行时间应远小于锁过期时间 可引入“看门狗”机制(如Redisson中的Watchdog)自动续期 避免锁在业务未完成时过期导致并发问题

4. 推荐使用Redisson框架

手写分布式锁容易出错,生产环境建议使用成熟的开源库,如Redisson。

使用示例:

Config config = new Config();config.useSingleServer().setAddress("redis://127.0.0.1:6379");RedissonClient redisson = Redisson.create(config);RLock lock = redisson.getLock("myLock");try {    // 尝试加锁,最多等待10秒,上锁后30秒自动解锁    if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {        // 执行业务逻辑    }} finally {    lock.unlock();}

Redisson优势:

自动续期(watchdog机制) 支持可重入、公平锁、读写锁等 封装了网络重连、异常处理等细节

基本上就这些。自己实现要特别注意原子性和异常场景,直接用Redisson更稳妥。

以上就是java后端开发怎么用Redis实现分布式锁?的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1102465.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月2日 17:45:40
下一篇 2025年12月2日 17:46:02

相关推荐

发表回复

登录后才能评论
关注微信