redis订阅发布机制实现分布式锁 - 好文

推荐： jeesuite开发框架 <http://www.jeesuite.com/>，免费开源、一站式解决方案。

通常情况在解决分布式场景锁机制都会首先想到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
* 完整代码：
获取完整代码
<https://gitee.com/vakinge/jeesuite-libs/tree/master/jeesuite-common2/src/main/java/com/jeesuite/common2/lock/redis>

热门工具换一换