Redlock 在 Go 中不推荐直接手写,因官方未提供被广泛认可的实现且无法保证强一致性;生产环境优先用单实例 SET + token 或 etcd 等 Raft 方案;若必须使用,应基于 redsync 库并严格满足多实例、唯一 token、超时控制等前提。

Redlock 在 Go 中不推荐直接手写
Go 生态里没有被广泛认可的 Redlock 官方实现,且 Redis 官方已明确说明 Redlock 并不能解决所有分布式锁场景——尤其在时钟漂移、网络分区、主从切换等真实故障下,它无法保证强一致性。多数生产系统用 SET key value PX 30000 NX 加单实例锁 + 唯一随机 token(防止误删)就足够;需要高可用时,优先考虑基于 Raft 的协调服务(如 etcd),而非 Redlock。
如果你仍需 Redlock 的 Go 实现,必须满足三个前提
Redlock 要求同时向 ≥3 个独立 Redis 实例(无主从关系)发起加锁请求,且只在大多数(≥(N/2)+1)成功、总耗时小于锁过期时间时才算成功。实际落地要注意:
-
redis.Client必须分别连接不同实例(不能复用同一 client 或共享连接池) - 每个实例的锁 key 必须相同,但 value 必须是全局唯一 token(如
uuid.NewString()),用于后续解锁校验 - 加锁超时时间(如 50ms)和锁 TTL(如 10s)要分开控制:前者限制单次请求等待,后者是业务允许的最大持有时间
用 github.com/go-redsync/redsync/v4 而非自己拼逻辑
社区最接近 Redlock 规范的库是 redsync,但它本质上仍是“多实例 SET + 多数派确认”,不解决 Redlock 的根本缺陷。使用时关键点:
- 初始化时传入至少 3 个独立
*redis.Pool(或 v8+ 的redis.UniversalClient),不能是同一个集群的多个节点 - 调用
mutex.Lock()返回前会检查成功数是否 ≥ (len(instances)/2)+1,失败则自动清理已设的锁 - 务必设置
Expiry(TTL)和Clock(建议用redsync.DefaultClock,避免本地时钟误差放大) - 解锁必须调用
mutex.Unlock(),它通过 Lua 脚本比对 value 再删 key,防止误删
pool := redis.NewPool(func() (*redis.Client, error) {
return redis.NewClient(&redis.Options{Addr: "redis1:6379"}), nil
})
rs := redsync.New(pool)
mutex := rs.NewMutex("my-resource", redsync.Expiry(10*time.Second))
if err := mutex.Lock(); err != nil {
// 失败,不持有锁
}
// ... 业务逻辑
mutex.Unlock() // 必须调用,不能省略
真正该警惕的不是算法,而是解锁时机和续期逻辑
Redlock 最容易出问题的地方不在加锁,而在锁快过期时业务还没做完。Go 里常见错误包括:
- 忘记用
context.WithTimeout控制Lock()调用本身耗时,导致 goroutine 卡死 - 用
time.AfterFunc异步续期,但没处理 panic 或续期失败后的 panic 传播 - 在 defer 中调用
Unlock(),却忽略了锁可能早已因超时被 Redis 自动释放,此时 Unlock 会静默失败(Lua 脚本返回 0) - 把锁 value 当作业务上下文透传,结果因序列化/反序列化差异导致 Unlock 时 value 不匹配而删错 key
如果业务确实需要长时间持有锁,与其折腾 Redlock 续期,不如拆解任务、用消息队列分片,或者改用支持租约自动续期的 etcd lease.Grant + lease.KeepAlive。
golang免费学习笔记(深入):立即使用
在学习笔记中,你将探索golang的核心概念和高级技巧!











