Redis分布式锁核心是SET key value EX seconds NX原子命令,加锁需唯一value和合理超时,解锁须Lua脚本校验value后删除,续期需匹配且安全,推荐使用redis-py-lock等成熟库。

用 Redis 实现分布式锁,核心是利用 SET key value EX seconds NX 命令的原子性:只有当 key 不存在时才设置成功,并同时指定过期时间,避免死锁。关键在于保证加锁、续期、解锁的正确性和安全性。
加锁:原子写入 + 过期时间
直接使用 redis.set(key, value, ex=seconds, nx=True)(Redis-py 接口),其中:
- value 必须唯一(如 UUID 或进程 ID + 线程 ID),用于后续解锁校验,防止误删其他客户端的锁;
- ex 参数设为合理超时时间(比如 30 秒),不是越长越好——要略大于业务最大执行时间,兼顾安全与及时释放;
- 不要分两步做
exists+set,会破坏原子性,导致并发加锁失败或重复加锁。
解锁:Lua 脚本保障原子删除
解锁必须验证 value 是否匹配,再删除,否则可能删掉别人持有的锁。推荐用 Lua 脚本一次性完成判断和删除:
if redis.call("GET", KEYS[1]) == ARGV[1] then
return redis.call("DEL", KEYS[1])
else
return 0
end
Python 中调用方式:
立即学习“Python免费学习笔记(深入)”;
- 预先加载脚本:
unlock_script = redis.register_script(lua_script); - 执行:
unlock_script(keys=[lock_key], args=[lock_value]); - 返回 1 表示解锁成功,0 表示锁已失效或不属于当前客户端。
锁自动续期(可选):解决长任务超时问题
如果业务执行时间不确定且可能超过锁过期时间,需在持有锁期间定期刷新 TTL(renew)。常见做法是启动一个守护线程或协程,在锁剩余时间约 1/3 时调用 redis.expire(key, new_ex),但前提是 value 仍匹配(需先 GET 校验,或用带校验的 Lua 续期脚本)。注意:
- 仅限“自己还持有该锁”时才续期,避免续了别人的锁;
- 续期操作本身应有重试和超时控制,防止续期失败导致提前释放;
- 简单场景不建议引入续期,优先优化业务逻辑或合理预估超时时间。
进阶建议:用成熟库降低出错风险
手动实现易遗漏边界(如网络分区、时钟漂移、Redlock 争议等)。生产环境推荐:
-
redis-py-lock:轻量、支持自动续期和上下文管理(
with lock:); - redlock-py:实现 Redis 官方 Redlock 算法(需多个独立 Redis 实例),提升容错性(但实际收益有限,多数场景单节点加合理超时已足够);
- 若用 Celery,可直接启用其内置的
celery_once或django-redis提供的锁机制。
不复杂但容易忽略:value 唯一性、解锁原子性、超时时间合理性,这三点踩准,Redis 分布式锁就能稳住大多数业务场景。










