C#如何实现分布式锁 Redis分布式锁C#实现方法

2次阅读

C#中实现redis分布式锁需用SET命令原子加锁并设唯一value,通过lua脚本安全解锁防误删,配合Watchdog机制自动续期,再辅以重连、重试、日志等生产级保障。

C#如何实现分布式锁 Redis分布式锁C#实现方法

在C#中实现redis分布式锁,核心是利用Redis的SET命令原子性设置带过期时间的key,并配合唯一value(如GUID)做锁标识,再通过Lua脚本保证解锁操作的原子性。关键不在“加锁”,而在“防误删”和“自动续期”——否则容易出现锁失效或锁被别人释放的问题。

用StackExchange.Redis实现基础分布式锁

推荐使用red”>StackExchange.Redis客户端,它性能高、线程安全、支持连接池。加锁本质是执行:

  • SET lock:key "unique-Token" NX PX 30000:NX表示key不存在才设,PX设30秒过期
  • 返回”OK”表示加锁成功;nil表示已存在,加锁失败
  • value必须全局唯一(建议用Guid.NewGuid().ToString()),避免A加锁后B误删

安全解锁必须用Lua脚本

不能先GET再DEL!否则可能刚查到key属于你,下一刻就过期,接着DEL删掉别人刚抢到的锁。正确做法是用Lua保证“判断+删除”原子执行:

  • Lua脚本示例:
    if redis.call("get", KEYS[1]) == ARGV[1] then return redis.call("del", KEYS[1]) else return 0 end
  • C#中调用:db.ScriptEvaluate(luaScript, new RedisKey[] { key }, new RedisValue[] { token })
  • 返回1表示解锁成功,0表示token不匹配(锁已被他人持有或已过期)

进阶:支持自动续期(Watchdog机制)

业务执行时间不确定?别把锁过期时间设太长(影响故障恢复),也别设太短(怕没执行完就释放)。推荐用后台定时任务自动续期:

C#如何实现分布式锁 Redis分布式锁C#实现方法

美图云修

商业级AI影像处理工具

C#如何实现分布式锁 Redis分布式锁C#实现方法 50

查看详情 C#如何实现分布式锁 Redis分布式锁C#实现方法

  • 加锁时启动一个Timer,每隔expireTime / 3(如10秒)尝试执行GETSET key new-token并比对旧value
  • 仅当当前value仍为自己的token时,才更新过期时间(可用EXPIRE命令)
  • 任务在业务完成或异常时及时取消,避免“幽灵续期”

生产环境建议补充项

真正上线前,别只盯着加解锁逻辑:

  • 使用连接串中的abortConnect=false和重连策略,避免Redis短暂不可用导致锁异常
  • 加锁失败时,建议用指数退避重试(如100ms→200ms→400ms),而非死循环
  • 记录加锁/解锁日志(含key、token、耗时),便于排查“锁未释放”或“重复释放”问题
  • 考虑封装IDistributedLock接口,方便后续替换为zookeeper数据库方案

基本上就这些。不复杂但容易忽略细节——尤其是value唯一性和Lua解锁。用对了,Redis分布式锁在C#里很稳。

text=ZqhQzanResources