如何在Go语言中实现一个通用的数据行锁与分布式排他锁模块-Golang-PHP中文网

sync.rwmutex仅适用于单进程本地行锁，跨进程或多实例部署时完全失效；必须用redis（set nx+px原子加锁、lua校验token安全释放）或etcd（cas+lease）实现分布式行锁。

如何在go语言中实现一个通用的数据行锁与分布式排他锁模块

Go 中用 sync.RWMutex 实现本地行锁不适用于分布式场景

本地内存锁（如 sync.RWMutex 或 sync.Mutex）只能保护单进程内的并发访问，跨进程、跨机器时完全失效。如果你的应用已部署多实例（比如 Kubernetes 多 Pod、或多个服务器），直接套用 sync 包的锁会立刻出现数据竞争——看似加了锁，实际各实例各自为政，根本没互斥。

常见错误现象：UPDATE account SET balance = balance - 100 WHERE id = 123 在两个服务实例上同时执行，余额被扣两次；或者订单状态从 “pending” 误设为 “paid” 两次。

行锁粒度必须绑定具体业务主键（如 user_id、order_id），不能全局一把锁
锁生命周期需可控：不能死锁、不能无限期持有、失败时要自动释放
本地锁无法感知其他节点是否持有同 key 的锁，这是本质限制

Redis + Lua 是最实用的分布式行锁实现方案

Redis 单线程原子性 + Lua 脚本保证操作不可中断，是 Go 分布式行锁的事实标准。核心不是“用 Redis.Set”，而是用 SET key value NX PX timeout_ms 命令配合唯一 client token（如 UUID），再辅以 Lua 脚本做安全释放。

关键点在于：加锁必须原子（NX 防重入，PX 防死锁），删锁必须校验 token（防止 A 加锁、B 误删），且整个释放逻辑必须在 Lua 中完成。

加锁用 redis.Client.Set(ctx, lockKey, token, time.Second*10)，但注意：Go redis 客户端（如 github.com/redis/go-redis/v9）默认不带 NX/PX 组合，需显式传 redis.SetOptions{NX: true, PX: 10000}

释放锁必须用 Lua：

if redis.call("get", KEYS[1]) == ARGV[1] then return redis.call("del", KEYS[1]) else return 0 end

，否则存在「检查+删除」竞态

token 必须全局唯一且不可预测（推荐 uuid.NewString()），不能用固定字符串或 PID，否则多个 goroutine 可能共用同一 token 导致误删

封装成可复用的 LockProvider 接口比写死 Redis 更可靠

硬编码 Redis 连接或写一堆重复的 Lua 调用，会让模块难以测试和替换。应定义接口隔离实现细节，例如：

Go语言（Golang）1.26.0

Go语言（Golang）1.26.0版本官方下载，版本号 1.26.0，适合旧项目维护、兼容性测试和指定版本开发环境搭建。

下载

type LockProvider interface {
    TryLock(ctx context.Context, key, token string, ttl time.Duration) (bool, error)
    Unlock(ctx context.Context, key, token string) error
    WithLock(ctx context.Context, key string, ttl time.Duration, fn func() error) error
}

这样既能 mock 测试（比如用内存 map 模拟锁），也能轻松切换底层（如未来换用 Etcd 的 txn），还能统一处理超时、重试、日志等横切逻辑。