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

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

c#如何实现分布式锁 redis分布式锁c#实现方法

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

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

推荐使用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机制)

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

加锁时启动一个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#里很稳。

以上就是C#如何实现分布式锁 Redis分布式锁C#实现方法的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1443010.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月17日 19:37:32
下一篇 2025年12月17日 19:37:51

相关推荐

发表回复

登录后才能评论
关注微信