分布式锁在分布式系统中用于协调共享资源访问，确保数据一致性。本文深入剖析 Redis 实现分布式锁的核心原理，包括 SETNX 命令、原子性保障及 CAP 理论权衡。针对锁过期误删、主从切换脑裂、时钟漂移等常见失效场景，提供了基于 Lua 脚本、看门狗机制及 Redlock 算法的解决方案。同时对比了 Jedis、Lettuce 和 Redisson 等 Java 连接方案，总结了高可用分布式锁的最佳实践与监控指标。
在分布式系统中，多个节点可能同时访问共享资源，如数据库记录、缓存或文件系统。为了确保数据的一致性和操作的原子性，必须引入一种协调机制——分布式锁。它允许多个进程在跨网络的环境下协商对临界资源的独占访问权限。
一个可靠的分布式锁应满足以下核心属性：
目前主流的分布式锁实现依赖于外部存储系统，如 Redis、ZooKeeper 或 Etcd。以 Redis 为例，可通过 SET 命令的 NX 和 EX 选项实现简单锁机制：
// 使用 Redis 实现加锁操作（Go 伪代码）
result, err := redisClient.Set(ctx, "lock:resource", clientId, &redis.Options{
NX: true, // 仅当键不存在时设置
EX: 30, // 30 秒过期时间
})
if err != nil || result == "" {
log.Println("获取锁失败")
return false
}
log.Println("成功获得锁")
return true
该代码通过原子命令尝试设置带过期时间的键，若返回成功则表示获得锁。但需注意网络分区、时钟漂移和客户端延迟执行等问题可能导致锁失效。
| 挑战 | 说明 |
|---|---|
| 脑裂问题 | 网络分区导致多个节点同时认为自己持有锁 |
| 锁过期误删 | 任务执行时间超过锁有效期，被其他客户端误释放 |
| 时钟跳跃 | 系统时间被手动调整或 NTP 同步引发异常行为 |
graph TD
A[客户端请求加锁] --> B{Redis 是否已有锁？}
B -- 是 --> C[加锁失败]
B -- 否 --> D[设置带 TTL 的锁键]
D --> E[返回加锁成功]
E --> F[执行业务逻辑]
F --> G[删除锁键]
在分布式系统中，实现可靠的分布式锁需满足三个核心要求：互斥性、容错性和可重入性。锁机制必须确保同一时刻仅有一个客户端能获取锁，即使在节点故障或网络分区情况下仍能正常运作。
根据 CAP 理论，系统只能在一致性（C）、可用性（A）和分区容忍性（P）中三选二。分布式锁通常优先保障 CP，牺牲可用性以维护强一致性。例如基于 ZooKeeper 的实现强调一致性，而 Redis 方案常偏向 AP，通过超时机制提升可用性。
| 系统类型 | 一致性模型 | 典型代表 |
|---|---|---|
| CP 优先 | 强一致 | ZooKeeper |
| AP 优先 | 最终一致 | Redis |
if (redis.setNX(lockKey, clientId, TTL)) {
return true; // 获取锁成功
}
return false; // 锁已被占用
该代码尝试原子性地设置键，仅当键不存在时生效（SetNX），TTL 防止死锁。其逻辑依赖 Redis 的最终一致性模型，在网络分区中可能产生多客户端同时持锁的风险。
Redis 的单线程事件循环（Event Loop）是其保障原子性操作的核心机制。所有客户端命令按顺序进入队列，由主线程逐一执行，避免了多线程环境下的竞争条件。
由于同一时间仅有一个命令被执行，无需加锁即可保证数据一致性。例如，INCR 操作在执行期间不会被其他命令中断：
INCR user:1001:login_count
该命令读取值、加 1、写回三个步骤在单线程下不可分割，天然具备原子性。
| 特性 | Redis 单线程 | 传统多线程数据库 |
|---|---|---|
| 并发控制 | 无锁 | 需锁机制 |
| 上下文切换 | 极少 | 频繁 |
在分布式锁的实现中，SETNX 与 EXPIRE 的组合曾被广泛使用。先通过 SETNX 设置锁，再用 EXPIRE 添加过期时间，看似合理，实则存在原子性缺失的风险。
SETNX lock_key 1
EXPIRE lock_key 10
若在执行 SETNX 后、调用 EXPIRE 前发生宕机，锁将永不释放，导致死锁。
现代实践推荐使用 SET 命令的 NX 与 EX 选项，保证设置值和过期时间的原子性：
SET lock_key unique_value NX EX 10
该方式彻底规避了原生命令拆分带来的隐患。
在分布式系统中，Redis 的 Lua 脚本是实现原子化加锁与解锁的核心手段。通过将加锁和解锁逻辑封装在 Lua 脚本中，可确保操作的原子性，避免因网络延迟或客户端崩溃导致的锁状态不一致。
if redis.call("GET", KEYS[1]) == false then
return redis.call("SET", KEYS[1], ARGV[1], "PX", ARGV[2])
else
return nil
end
该脚本首先检查键是否已存在，若不存在则设置带过期时间的锁（PX 单位为毫秒），ARGV[1] 为客户端唯一标识，ARGV[2] 为超时时间，防止死锁。
在分布式系统中，锁的可重入性是保障线程安全的重要机制。当同一个客户端在持有锁的情况下再次请求同一资源时，应允许其重复获取，避免死锁。
利用 Redis 的 Hash 结构，可将客户端标识（如线程 ID）作为 field，重入次数作为 value，实现精细化控制：
-- 示例：使用 Lua 脚本实现可重入锁
local key = KEYS[1]
local clientID = ARGV[1]
local ttl = ARGV[2]
if redis.call("HEXISTS", key, clientID) == 1 then
return redis.call("HINCRBY", key, clientID, 1)
else
if redis.call("GET", key) == false then
redis.call("HSET", key, clientID, 1)
redis.call("PEXPIRE", key, ttl)
return 1
else
return -1 -- 锁被其他客户端持有
end
end
上述逻辑首先检查当前客户端是否已持有锁（通过 HEXISTS），若存在则调用 HINCRBY 递增重入计数；否则尝试设置 Hash 字段并设定过期时间。该设计确保了锁的可重入性与原子性操作。
在 Jedis 直连模式中，客户端直接连接 Redis 服务器，适用于单节点部署场景。由于无连接池介入，每次操作均需建立和关闭连接，因此需谨慎管理资源。
Jedis jedis = new Jedis("localhost", 6379);
String result = jedis.set("lock.key", "1", "NX", "EX", 10);
if ("OK".equals(result)) {
try {
// 执行临界区逻辑
} finally {
jedis.del("lock.key");
}
}
jedis.close();
上述代码使用 SET key value NX EX seconds 原子操作实现锁：NX 确保键不存在时才设置，EX 提供 10 秒过期时间，防止死锁。连接通过 jedis.close() 显式释放，避免资源泄漏。
close() 关闭连接Lettuce 利用 Netty 的 EventLoop 实现非阻塞 I/O，将 Redis 锁操作（如 SET key value NX PX 10000）封装为 Mono<Boolean>，全程无线程阻塞。
Mono<Boolean> lock = redisClient.reactive()
.set(key, "token", SetArgs.Builder.nx().px(10_000));
该调用返回立即完成的 Mono，实际网络交互由 Netty Channel 异步执行；nx() 确保仅当 key 不存在时设置，px(10_000) 设置 10 秒自动过期，避免死锁。
| 特性 | 传统 Jedis | Lettuce 响应式 |
|---|---|---|
| 线程模型 | 每请求独占连接 | 共享 Netty EventLoop |
| 锁获取延迟 | 同步阻塞等待 | 零线程挂起，背压支持 |
在高并发场景下，传统 JVM 锁已无法满足跨服务实例的协调需求。Redisson 基于 Redis 实现了分布式的可重入锁，极大简化了开发复杂度。
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient client = Redisson.create(config);
RLock lock = client.getLock("order:lock");
try {
if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {
// 执行业务逻辑
}
} finally {
lock.unlock();
}
上述代码获取名为 "order:lock" 的分布式锁，设置等待 10 秒、持有 30 秒自动过期。Redisson 自动处理锁重入、看门狗续期及异常释放。
| 特性 | 原生 Redis 实现 | Redisson 封装 |
|---|---|---|
| 锁重入 | 需手动维护计数 | 自动支持 |
| 自动续期 | 无 | 看门狗机制保障 |
在分布式系统中，使用 Redis 等实现的分布式锁常依赖于键的过期时间来防止死锁。若锁的过期时间设置过短，可能导致持有锁的线程尚未完成任务，锁便已自动释放，其他线程趁机获取锁，引发数据竞争。
client.Set("lock_key", "thread_1", time.Second*5) // 问题：硬编码 5 秒，若任务需 8 秒，则第 6 秒时其他线程可抢占
上述代码中，过期时间未根据实际业务耗时动态调整，极易引发竞争。应结合看门狗机制，定期检测任务状态并自动续期，确保锁生命周期与任务执行周期匹配。
在 Redis 主从架构中，主节点宕机触发故障转移时，可能因数据同步延迟导致分布式锁被错误删除。当客户端 A 在原主节点获取锁后，主从尚未完成同步即发生切换，新主节点未继承锁状态，造成锁丢失。
# 客户端 A 在主节点设置锁
SET resource_name my_random_value NX PX 30000
# 主节点崩溃，从节点升为主，但未同步该锁
# 新客户端 B 可立即获取同一资源的锁，导致并发冲突
上述代码中，若主从复制为异步模式，NX PX 设置的锁无法及时同步，新主节点视图为空，引发锁误删。
解决此类问题需引入如 Redlock 算法或依赖强一致共识机制。
在分布式系统中，租约机制依赖时间戳判断资源持有状态，客户端时钟漂移可能导致租约误判。若客户端时间快于服务端，租约可能被提前视为过期；反之则延长无效持有期，增加脑裂风险。
if time.Now().After(lease.Expiry) {
return errors.New("lease expired")
}
该逻辑依赖本地时钟。若客户端时钟偏差超过租约容忍窗口（如 ±30s），需引入 NTP 同步或逻辑时钟校正机制以保障一致性。
在分布式系统中，客户端与 Redis 服务端之间的网络连接可能因瞬时故障中断，触发客户端自动重连机制。若在此期间未妥善处理锁状态，极易引发重复加锁问题。
当客户端 A 持有锁后发生网络闪断，Redis 因超时释放锁；重连后客户端 A 误认为仍持有锁，再次发起加锁请求，导致逻辑混乱。
通过为每个加锁请求生成唯一 ID，并结合 Lua 脚本原子校验，可避免重复加锁：
if redis.call('GET', KEYS[1]) == ARGV[1] then
return redis.call('EXPIRE', KEYS[1], ARGV[2])
else
return 0
end
上述脚本确保仅当锁的值等于本次请求的唯一 ID 时才更新过期时间，防止非持有者误操作。该机制依赖客户端维护 ID 状态，建议配合单调递增序列或 UUID 实现。
分布式锁的可靠性高度依赖于存储系统的特性。Redis 因其高性能和原子操作支持成为主流选择，而 ZooKeeper 则凭借强一致性与会话机制适用于对安全性要求更高的场景。在实际部署中，建议使用 Redis Sentinel 或 Redis Cluster 模式，避免单点故障。
以下是一个基于 Redis 的 Go 实现示例，使用 Lua 脚本保证删除操作的原子性：
// 加锁：SET key uuid EX seconds NX
if redis.Call("SET", key, uuid, "EX", 30, "NX") == "OK" {
return true
}
// 解锁：通过 Lua 脚本确保只有持有者可释放
UnlockScript = `
if redis.call("get", KEYS[1]) == ARGV[1] then
return redis.call("del", KEYS[1])
else
return 0
end`
redis.Call("EVAL", UnlockScript, 1, key, uuid)
| 指标名称 | 说明 | 告警阈值 |
|---|---|---|
| 锁等待时长 | 请求获取锁的平均延迟 | > 500ms |
| 锁冲突率 | 单位时间内失败请求数占比 | > 15% |
| 锁超时次数 | 因超时被自动释放的频次 | > 5 次/分钟 |
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
使用加密算法（如AES、TripleDES、Rabbit或RC4）加密和解密文本明文。 在线工具，加密/解密文本在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online