java后端开发怎么用Redis实现分布式锁？_技术教程

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

在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);
    }
}

说明：

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());
}

关键点：

通过比较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优势：