Redisson 分布式锁源码 06:公平锁排队加锁

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: 在上一篇文章中已经分析过公平锁的加锁源码,并得出结论:1. Redis Hash 数据结构:存放当前锁,Redis Key 就是锁,Hash 的 field 是加锁线程,Hash 的 value 是 重入次数;2. Redis List 数据结构:充当线程等待队列,新的等待线程会使用 rpush 命令放在队列右边;3. Redis sorted set 有序集合数据结构:存放等待线程的顺序,分数 score 用来是等待线程的超时时间戳。现在看一下加锁失败被放到等待队列之后,线程是如何处理的?

前言


在上一篇文章中已经分析过公平锁的加锁源码,并得出结论:

  1. Redis Hash 数据结构:存放当前锁,Redis Key 就是锁,Hash 的 field 是加锁线程,Hash 的 value 是 重入次数;
  2. Redis List 数据结构:充当线程等待队列,新的等待线程会使用 rpush 命令放在队列右边;
  3. Redis sorted set 有序集合数据结构:存放等待线程的顺序,分数 score 用来是等待线程的超时时间戳。

现在看一下加锁失败被放到等待队列之后,线程是如何处理的?


排队等锁

源码入口:org.redisson.RedissonLock#lock(long, java.util.concurrent.TimeUnit, boolean)

线程进入排队之后,在 Java 代码中会 while (true) 一直循环调用 tryAcquire,尝试获取锁。

最终还是来到 RedissonFairLock#tryLockInnerAsync 方法中。

方便起见,重新贴一下 Lua 脚本,以及脚本的参数含义。

  1. KEYS[1]:加锁的名字,anyLock
  2. KEYS[2]:加锁等待队列,redisson_lock_queue:{anyLock}
  3. KEYS[3]:等待队列中线程锁时间的 set 集合,redisson_lock_timeout:{anyLock},是按照锁的时间戳存放到集合中的;
  4. ARGV[1]:锁超时时间 30000
  5. ARGV[2]:UUID:ThreadId 组合 a3da2c83-b084-425c-a70f-5d9a08b37f31:1
  6. ARGV[3]:threadWaitTime 默认 300000
  7. ARGV[4]:currentTime 当前时间戳

网络异常,图片无法展示
|


源码分析

网络异常,图片无法展示
|

第一部分,while 循环:

  1. 从等待队列 redisson_lock_queue:{anyLock} 中获取第一个等待线程;
  2. 从等待线程超时集合 redisson_lock_timeout:{anyLock} 中获取第一个等待线程的分数;
  3. 没有超时,直接结束,超时了,则直接移除。

第二部分,当前锁存在,直接跳过。

第三部分,当前锁不是持锁线程,直接跳过。

网络异常,图片无法展示
|

第四部分,

网络异常,图片无法展示
|

直接返回当前锁还有多久到期。

当前 Redisson 版本为 3.15.6,不同版本的略有不同。


队列重排

这里不存在重新排序,因为官方认为这是一个 bug,重新进行了修复。

具体可以阅读:Justin Corpron 2019/5/10, 04:13 Fix timeout drift in RedissonFairLock

最大的变化就是增加了第四部分。

网络异常,图片无法展示
|

图仅仅代表两个版本的差别,并不是代表这个版本才修改。


总结


网络异常,图片无法展示
|

当线程获取锁失败,进入到等待队列时,ttl != null,在 Java 代码中会不断尝试获取锁。

当锁不存在且当前线程是在等待队列头时,直接获得锁。这个排队的过程就是公平锁的提现。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
1月前
|
NoSQL 算法 安全
Redlock 算法-主从redis分布式锁主节点宕机锁丢失的问题
Redlock 算法-主从redis分布式锁主节点宕机锁丢失的问题
184 0
|
1月前
|
Java 编译器 数据库
Spring Boot 整合 redisson 实现分布式锁
Spring Boot 整合 redisson 实现分布式锁
47 1
|
1月前
|
缓存 NoSQL Java
分布式项目中锁的应用(本地锁-_redis【setnx】-_redisson-_springcache)-fen-bu-shi-xiang-mu-zhong-suo-de-ying-yong--ben-de-suo--redissetnx-springcache-redisson(一)
分布式项目中锁的应用(本地锁-_redis【setnx】-_redisson-_springcache)-fen-bu-shi-xiang-mu-zhong-suo-de-ying-yong--ben-de-suo--redissetnx-springcache-redisson
70 0
|
8天前
|
缓存 NoSQL 安全
玩转Redis!非常强大的Redisson分布式集合,少写60%代码
Redisson是Java的Redis客户端,提供实时数据平台服务,简化了分布式环境下的数据管理。它包含RList、RSet、RMap等分布式集合,支持ConcurrentMap和Set接口,确保线程安全和数据一致性。例如,RMap实现了本地缓存和监听器功能,允许数据监听和本地加速读取。此外,还提供了RSet的排序和去重功能,以及RQueue和RBlockingQueue等队列实现,支持阻塞操作。通过Redisson,开发者能轻松处理分布式系统的数据同步和操作。
|
1月前
|
存储 关系型数据库 MySQL
分布式事物【悲观锁、乐观锁、读锁、写锁、间隙锁、临键锁 、 表锁、行锁、页面锁、 如何避免死锁】(二)-全面详解(学习总结---从入门到深化)
分布式事物【悲观锁、乐观锁、读锁、写锁、间隙锁、临键锁 、 表锁、行锁、页面锁、 如何避免死锁】(二)-全面详解(学习总结---从入门到深化)
61 0
|
1月前
|
编解码 NoSQL Java
Springboot框架使用redisson实现分布式锁
Redisson是官方推荐的Java Redis客户端,提供丰富的功能,包括默认的分布式锁支持。它可以无缝替代Spring Boot 2.x的Letture客户端,不影响原有RedisTemplate和Redis Repository的使用。集成包括spring-boot-starter-data-redis和redisson-spring-boot-starter,后者需排除默认的redisson-spring-data-23以匹配Spring Data Redis v.2.2.x。
|
1月前
|
NoSQL Java Redis
分布式延时消息的另外一种选择 Redisson (推荐使用)
分布式延时消息的另外一种选择 Redisson (推荐使用)
188 1
|
1月前
|
缓存 NoSQL 数据库
关于高并发下缓存失效的问题(本地锁 && 分布式锁 && Redission 详解)
关于高并发下缓存失效的问题(本地锁 && 分布式锁 && Redission 详解)
166 0
|
1月前
|
XML NoSQL Java
Java单体项目和分布式项目中的锁
Java单体项目和分布式项目中的锁 Java单体项目和分布式项目中的锁
44 2
|
1月前
|
缓存 NoSQL Redis
分布式项目中锁的应用(本地锁-_redis【setnx】-_redisson-_springcache)-fen-bu-shi-xiang-mu-zhong-suo-de-ying-yong--ben-de-suo--redissetnx-springcache-redisson(二)
分布式项目中锁的应用(本地锁-_redis【setnx】-_redisson-_springcache)-fen-bu-shi-xiang-mu-zhong-suo-de-ying-yong--ben-de-suo--redissetnx-springcache-redisson
45 0