redis订阅发布机制实现分布式锁
2018-03-26 12:57
911 查看
推荐: jeesuite开发框架,免费开源、一站式解决方案。
通常情况在解决分布式场景锁机制都会首先想到redis。因为redis单线程天然就解决了这个问题。使用redis实现分布式锁可以通过getset和setnx。getset:将给定 key 的值设为 value ,并返回 key 的旧值(old value)
redis> GETSET db mongodb # 没有旧值,返回 nil (nil) redis> GET db "mongodb" redis> GETSET db redis # 返回旧值 mongodb "mongodb" redis> GET db "redis"
SETNX :将 key 的值设为 value ,当且仅当 key 不存在。若给定的 key 已经存在,则 SETNX 不做任何动作。
redis> EXISTS job # job 不存在 (integer) 0 redis> SETNX job "programmer" # job 设置成功 (integer) 1 redis> SETNX job "code-farmer" # 尝试覆盖 job ,失败 (integer) 0 redis> GET job # 没有被覆盖 "programmer"
然而这个方式在锁等待的情况下,都无法主动获取锁释放通知,必须轮询的方式去不断的查redis。这个就会产生大量查询请求并且会增加等待时间(譬如你10ms轮询一次,但是可能下一毫秒已经可以获得锁了,你却需要继续等10ms)。接下来我分享一段我基于redis SUBPUB机制实现的分布式锁的思路:
使用了redis List队列和subpub机制。
每个等待锁都会生成全局唯一的eventId,redis队列放置的就是等待获取锁的eventId集合。
获取锁的过程一:放入队列后长度刚好为:1,则已获得锁。
获取锁的过程二:放入队列后长度 > 1,则等待上一个锁释放。
释放锁:首先从eventId队列RPOP一个作为下一个获得锁的通知对象。
锁等待:线程阻塞等待redis发布消息,如果nextEventId与当前一致则获得锁。
其他需要考虑:锁超时,死锁等问题。
附:
1. eventId结构:固定位数节点ID+13位时间戳+唯一序列
public String buildEvenId(){ return new StringBuilder().append(EVENT_ID_PREFIX).append(System.currentTimeMillis()).append(eventIdSeq.incrementAndGet()).toString(); }
释放锁,发布消息内容:lockName+分隔符+nextEventId
完整代码:
获取完整代码
相关文章推荐
- redis利用pipline实现发布订阅机制
- nodejs redis 发布订阅机制封装实现方法及实例代码
- .NET消息发布和订阅机制的实现案例
- php 实现redis发布订阅消息及时通讯
- java连接redis,实现订阅发布遇到的问题
- 浅谈java实现redis的发布订阅(简单易懂)
- redis 发布订阅机制
- 基于订阅/发布模式的简易聊天室实现(java+redis)
- Java实现Redis发布/订阅
- springboot结合redis实现redis订阅发布模式
- Redis实现分布式环境下的分布式锁机制
- 【Redis】Java实现redis消息订阅/发布(PubSub)
- Java实现Redis发布订阅
- Java实现Redis发布/订阅
- 基于spring-redis发布订阅模式的实现
- Redis发布订阅实现原理
- 【由浅至深】redis 实现发布订阅的几种方式
- 发布订阅 - 基于A2DFramework的事件机制实现
- Redis实现分布式环境下的分布式锁机制
- 使用Redis实现一个订阅/发布系统