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

推荐： jeesuite开发框架，免费开源、一站式解决方案。

通常情况在解决分布式场景锁机制都会首先想到redis。因为redis单线程天然就解决了这个问题。使用redis实现分布式锁可以通过getset和setnx。

• getset:将给定 key 的值设为 value ，并返回 key 的旧值(old value)

代码语言：javascript复制

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 不做任何动作。

代码语言：javascript复制

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机制实现的分布式锁的思路：

1. 使用了redis List队列和subpub机制。
2. 每个等待锁都会生成全局唯一的eventId，redis队列放置的就是等待获取锁的eventId集合。
3. 获取锁的过程一：放入队列后长度刚好为：1，则已获得锁。
4. 获取锁的过程二：放入队列后长度 > 1,则等待上一个锁释放。
5. 释放锁：首先从eventId队列RPOP一个作为下一个获得锁的通知对象。
6. 锁等待：线程阻塞等待redis发布消息，如果nextEventId与当前一致则获得锁。
7. 其他需要考虑：锁超时，死锁等问题。

附： 1. eventId结构：固定位数节点ID 13位时间戳 唯一序列

代码语言：javascript复制

public String buildEvenId(){
        return new StringBuilder().append(EVENT_ID_PREFIX).append(System.currentTimeMillis()).append(eventIdSeq.incrementAndGet()).toString();
    }

1. 释放锁，发布消息内容：lockName 分隔符 nextEventId
2. 完整代码： 获取完整代码

云数据库Redis 分布式

0 人点赞