Redis分布式锁从入门到精通：从SETNX到Redisson看门狗机制

引言

在分布式系统中，多个服务节点同时操作共享资源时，传统的单机锁（如synchronized、ReentrantLock）就失效了。如何保证同一时刻只有一个节点能执行关键代码？分布式锁就是解决方案。

Redis凭借其高性能和原子操作，成为实现分布式锁的首选工具。本文将深入剖析Redis分布式锁的实现原理、常见坑点以及工业级解决方案Redisson的源码级解析。

1. 分布式锁的核心要求

在设计分布式锁时，必须满足以下四个条件：

2. 基于Redis的简易分布式锁实现

2.1 第一阶段：SETNX + EXPIRE（有问题！）

最原始的想法：用SETNX加锁，再用EXPIRE设过期时间。

# 1. 加锁SETNX lock_key1# 2. 设置过期时间（防止死锁）EXPIRE lock_key30

问题所在：SETNX和EXPIRE是两个命令，非原子性。如果SETNX成功后客户端崩溃，EXPIRE没执行，就导致死锁！

2.2 第二阶段：SET原子操作（正确基础版）

Redis 2.6.12+提供了SET命令的扩展参数，解决了原子性问题：

SET lock_key unique_value NX PX30000

参数说明：

• NX：只有key不存在时才设置（实现互斥）
• PX 30000：设置过期时间30秒（防止死锁）
• unique_value：客户端唯一ID（如UUID），用于安全释放锁

2.3 第三阶段：安全解锁（Lua脚本）

为什么释放锁要用Lua脚本？因为要确保当前客户端只能释放自己加的锁，不能误删别人的锁。

-- 解锁Lua脚本ifredis.call("get",KEYS[1])==ARGV[1]thenreturnredis.call("del",KEYS[1])elsereturn0end

2.4 完整基础代码示例（Java版）

publicclassRedisDistributedLock{privateJedisjedis;privateStringlockKey;privateStringuniqueValue;privateintexpireTime;// 毫秒publicbooleantryLock(){// SET key value NX PX expireTimeStringresult=jedis.set(lockKey,uniqueValue,"NX","PX",expireTime);return"OK".equals(result);}publicbooleanunlock(){StringluaScript="if redis.call('get', KEYS[1]) == ARGV[1] then "+" return redis.call('del', KEYS[1]) "+"else "+" return 0 "+"end";Objectresult=jedis.eval(luaScript,Collections.singletonList(lockKey),Collections.singletonList(uniqueValue));returnLong.valueOf(1).equals(result);}}

2.5 基础版流程图

3. 基础版存在的问题

上述实现虽然正确，但在生产环境中仍有几个痛点：

1. 锁超时释放：业务执行时间超过过期时间，锁自动释放，导致并发问题
2. 不可重入：同一线程无法多次获取同一把锁
3. 不支持等待：获取不到锁直接返回失败，没有阻塞等待机制
4. 无续期机制：无法在业务执行过程中延长锁的有效期

4. 工业级方案：Redisson分布式锁

Redisson是Redis官方推荐的Java分布式锁实现，完美解决了上述所有问题。

4.1 Redisson快速入门

<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.20.0</version></dependency>

@ConfigurationpublicclassRedissonConfig{@BeanpublicRedissonClientredissonClient(){Configconfig=newConfig();config.useSingleServer().setAddress("redis://127.0.0.1:6379").setPassword("123456").setConnectionPoolSize(10);returnRedisson.create(config);}}@ServicepublicclassOrderService{@AutowiredprivateRedissonClientredissonClient;publicvoidcreateOrder(LongorderId){// 1. 获取分布式锁RLocklock=redissonClient.getLock("order:"+orderId);try{// 2. 加锁（支持自动续期）lock.lock(30,TimeUnit.SECONDS);// 3. 执行业务逻辑doBusiness();}finally{// 4. 释放锁lock.unlock();}}}

4.2 核心特性

5. Redisson源码深度剖析

5.1 加锁核心Lua脚本

Redisson的加锁逻辑通过Lua脚本实现原子性，源码如下：

<T>RFuture<T>tryLockInnerAsync(longleaseTime,TimeUnitunit,longthreadId,RedisStrictCommand<T>command){returncommandExecutor.evalWriteAsync(getName(),LongCodec.INSTANCE,command,// 1. 判断锁是否存在"if (redis.call('exists', KEYS[1]) == 0) then "+"redis.call('hincrby', KEYS[1], ARGV[2], 1); "+"redis.call('pexpire', KEYS[1], ARGV[1]); "+"return nil; "+"end; "+// 2. 判断是否是当前线程持有"if (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 nil; "+"end; "+// 3. 其他线程持有，返回剩余过期时间"return redis.call('pttl', KEYS[1]);",Collections.singletonList(getName()),unit.toMillis(leaseTime),getLockName(threadId));}

数据结构说明：Redisson使用Hash结构存储锁信息

• key: 锁名称（如"order:123"）
• field: 线程标识（如"UUID:threadId"）
• value: 重入计数

5.2 加锁流程图

5.3 看门狗机制（自动续期）

看门狗是Redisson最核心的特性，解决了业务执行超时导致锁自动释放的问题。

privatevoidscheduleExpirationRenewal(longthreadId){ExpirationEntryentry=newExpirationEntry();EXPIRATION_RENEWAL_MAP.put(getEntryName(),entry);// 定时任务，每10秒执行一次Timeouttask=commandExecutor.getConnectionManager().newTimeout(newTimerTask(){@Overridepublicvoidrun(Timeouttimeout)throwsException{// 续期Lua脚本：重置锁过期时间为30秒RFuture<Boolean>future=renewExpirationAsync(threadId);future.onComplete((res,e)->{if(res){// 续期成功，递归调用继续续期scheduleExpirationRenewal(threadId);}});}},internalLockLeaseTime/3,TimeUnit.MILLISECONDS);// 默认30秒/3=10秒执行一次entry.setTimeout(task);}

看门狗工作流程：

1. 客户端加锁成功，默认过期时间30秒
2. 启动后台线程，每10秒检查一次
3. 如果锁仍被当前线程持有，执行续期Lua脚本，重置过期时间为30秒
4. 业务执行完毕，主动释放锁，取消看门狗
5. 如果客户端崩溃，看门狗停止续期，锁30秒后自动释放

5.4 可重入实现原理

通过Hash结构的计数器实现可重入：

# 第一次加锁HSET"order:123""clientA:thread1"1PEXPIRE"order:123"30000# 同一线程再次加锁HINCRBY"order:123""clientA:thread1"1# 计数变为2PEXPIRE"order:123"30000# 重置过期时间# 释放锁HINCRBY"order:123""clientA:thread1"-1# 计数减1# 计数>0，保留锁# 计数=0，删除key

6. 分布式锁的扩展形态

Redisson还提供了多种高级锁类型：

6.1 读写锁（ReadWriteLock）

适用于读多写少的场景，提升并发性能。

RReadWriteLockrwLock=redissonClient.getReadWriteLock("data-lock");RLockreadLock=rwLock.readLock();// 读锁RLockwriteLock=rwLock.writeLock();// 写锁// 读锁可被多个线程同时持有readLock.lock();// 写锁独占writeLock.lock();

6.2 公平锁（FairLock）

保证先等待的线程先获得锁。

RLockfairLock=redissonClient.getFairLock("fair-lock");fairLock.lock();// 按请求顺序分配

6.3 红锁（RedLock）

多Redis节点部署时的高可用方案，需要大多数节点同意才能加锁。

7. 最佳实践与避坑指南

7.1 合理设置过期时间

// 错误：过期时间太短，业务可能未完成lock.lock(5,TimeUnit.SECONDS);// 正确：使用默认30秒，配合看门狗自动续期lock.lock();// 或者根据业务评估设置足够长时间lock.lock(60,TimeUnit.SECONDS);

7.2 务必在finally中释放锁

RLocklock=redissonClient.getLock(key);lock.lock();try{// 业务逻辑}finally{// 确保一定释放if(lock.isLocked()&&lock.isHeldByCurrentThread()){lock.unlock();}}

7.3 监控与告警

@ComponentpublicclassLockMonitor{privatestaticfinalMeterRegistryregistry=newSimpleMeterRegistry();// 监控锁等待时间privateTimerlockWaitTimer=Timer.builder("lock.wait.time").register(registry);// 监控锁持有时间privateTimerlockHoldTimer=Timer.builder("lock.hold.time").register(registry);public<T>TexecuteWithMonitor(StringlockKey,Supplier<T>supplier){RLocklock=redissonClient.getLock(lockKey);longstartWait=System.currentTimeMillis();lock.lock();longwaitTime=System.currentTimeMillis()-startWait;lockWaitTimer.record(waitTime,TimeUnit.MILLISECONDS);longstartHold=System.currentTimeMillis();try{returnsupplier.get();}finally{lock.unlock();longholdTime=System.currentTimeMillis()-startHold;lockHoldTimer.record(holdTime,TimeUnit.MILLISECONDS);// 告警检查if(holdTime>10000){// 持有超过10秒alertService.sendAlert("锁持有时间过长: "+lockKey);}}}}

8. 总结对比

核心观点

1. 原子性是基础：加解锁必须用Lua或原子命令
2. 唯一标识是关键：用UUID标识锁持有者，防止误删
3. 看门狗是保障：自动续期解决业务超时问题
4. 选型要慎重：生产环境直接用Redisson，不要重复造轮子