Redisson 分布式锁源码 05:公平锁加锁

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 默认的加锁逻辑是非公平的。在加锁失败时,线程会进入 while 循环,一直尝试获得锁,这时候是多线程进行竞争。就是说谁抢到就是谁的。

前言


默认的加锁逻辑是非公平的。

在加锁失败时,线程会进入 while 循环,一直尝试获得锁,这时候是多线程进行竞争。就是说谁抢到就是谁的。

Redisson 提供了 公平锁 机制,使用方式如下:

RLock fairLock = redisson.getFairLock("anyLock");
// 最常见的使用方法
fairLock.lock();
复制代码

下面一起看下公平锁是如何实现的?


公平锁

相信小伙伴们看过前面的文章,已经轻车熟路了,直接定位到源码方法:RedissonFairLock#tryLockInnerAsync

好家伙,这一大块代码,我截图也截不完,咱们直接分析 lua 脚本。

PS:虽然咱不懂 lua,但是这一堆堆的 if else 咱们大概还是能看懂的。

因为 debug 发现 command == RedisCommands.EVAL_LONG,所以直接看下面一部分。

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

这么长,连呼好几声好家伙!

先来看看参数都有啥?

  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 当前时间戳。

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

加锁队列和集合是含有大括号的字符串。{XXXX} 是指这个 key 仅使用 XXXX 用来计算 slot 的位置。


Lua 脚本分析

上面的 lua 脚本是分为几块的,咱们分别从不同的角度看下上面代码的执行。


首次加锁(Thread1)

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


第一部分,因为是首次加锁,所以等待队列为空,直接 跳出循环。这一部分执行结束。

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


第二部分:

  1. 当锁不存在,等待队列为空或队首是当前线程,两个条件都满足时,进入内部逻辑;
  2. 从等待队列和超时集合中删除当前线程,这时候等待队列和超时集合都是空的,不需要任何操作;
  3. 减少队列中所有等待线程的超时时间,也不需要任何操作;
  4. 加锁并设置超时时间。

执行完这里就 return 了。所以后面几部分就暂时不看了。

相当于下面两个命令(整个 lua 脚本都是原子的!):

> hset anyLock a3da2c83-b084-425c-a70f-5d9a08b37f31:1 1
> pexpire anyLock 30000
复制代码

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


Thread2 加锁

当 Thread1 加锁完成之后,此时 Thread2 来加锁。

Thread2 可以是本实例其他线程,也可以是其他实例的线程。

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


第一部分,虽然锁被 Thread1 占用了,但是等待队列是空的,直接跳出循环。

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


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

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


第三部分,线程是否持锁,没有持锁,直接跳过。


第四部分,线程是否在等待队列中,Thread2 才来加锁,不在里面,直接跳过。

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


Thread2 最后会来到这里:

  1. 从线程等待队列 redisson_lock_queue:{anyLock} 中获取最后一个线程;
  2. 因为等待队列是空的,所以直接获取当前锁的剩余时间 ttl anyLock
  3. 组装超时时间 timeout = ttl + 300000 + 当前时间戳,这个 300000 是默认 60000*5
  4. 使用 zadd 将 Thread2 放到等待线程有序集合,然后使用 rpush 将 Thread2 再放到等待队列中。

zadd KEYS[3] timeout ARGV[2]


这里使用 zadd 命令分别放置的是,redisson_lock_timeout:{anyLock},超时时间戳(1624612689520),线程(UUID2:Thread2)。

其中超时时间戳当分数,用来在有序集合中排序,表示加锁的顺序。

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


Thread3 加锁

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


Thread1 占有了锁,Thread2 在等待,此时线程 3 来了。

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

获取 firstThreadId2 此时队列是有线程的是 UUID2:Thread2。


判断 firstThreadId2 的分数(超时时间戳)是不是小于当前时间戳:

  1. 小于等于则说明超时了,移除 firstThreadId2;
  2. 大于,则会进入后续判断。

第二、三、四部分都不满足条件。

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


Thread3 最后也会来到这里:

  1. 从线程等待队列 redisson_lock_queue:{anyLock} 中获取最后一个线程;
  2. 最后一个线程存在,且不是自己,则 ttl = lastThreadId 超时时间戳 - 当前时间戳,就是看最后一个线程还有多久超时;
  3. 组装超时时间 timeout = ttl + 300000 + 当前时间戳,这个 300000 是默认 60000*5,在最后一个线程的超时时间上加上 300000 以及当前时间戳,就是 Thread3 的超时时间戳。
  4. 使用 zadd 将 Thread3 放到等待线程有序集合,然后使用 rpush 将 Thread3 再放到等待队列中。

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


总结


本文主要总结了公平锁的加锁逻辑,这涉及到比较多的 Redis 操作,做一下简要总结:

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

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

需要理解的就是这里会额外添加一个等待队列,以及有序集合。

对照着 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
目录
相关文章
|
4月前
|
存储 缓存 NoSQL
Redis常见面试题(二):redis分布式锁、redisson、主从一致性、Redlock红锁;Redis集群、主从复制,哨兵模式,分片集群;Redis为什么这么快,I/O多路复用模型
redis分布式锁、redisson、可重入、主从一致性、WatchDog、Redlock红锁、zookeeper;Redis集群、主从复制,全量同步、增量同步;哨兵,分片集群,Redis为什么这么快,I/O多路复用模型——用户空间和内核空间、阻塞IO、非阻塞IO、IO多路复用,Redis网络模型
Redis常见面试题(二):redis分布式锁、redisson、主从一致性、Redlock红锁;Redis集群、主从复制,哨兵模式,分片集群;Redis为什么这么快,I/O多路复用模型
|
1月前
|
缓存 NoSQL Java
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
55 3
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
|
24天前
|
NoSQL Java Redis
开发实战:使用Redisson实现分布式延时消息,订单30分钟关闭的另外一种实现!
本文详细介绍了 Redisson 延迟队列(DelayedQueue)的实现原理,包括基本使用、内部数据结构、基本流程、发送和获取延时消息以及初始化延时队列等内容。文章通过代码示例和流程图,逐步解析了延迟消息的发送、接收及处理机制,帮助读者深入了解 Redisson 延迟队列的工作原理。
|
2月前
|
缓存 NoSQL Java
谷粒商城笔记+踩坑(12)——缓存与分布式锁,Redisson+缓存数据一致性
缓存与分布式锁、Redisson分布式锁、缓存数据一致性【必须满足最终一致性】
112 14
谷粒商城笔记+踩坑(12)——缓存与分布式锁,Redisson+缓存数据一致性
|
1月前
|
缓存 NoSQL Ubuntu
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
52 3
|
5月前
|
消息中间件 NoSQL Java
Redis系列学习文章分享---第六篇(Redis实战篇--Redis分布式锁+实现思路+误删问题+原子性+lua脚本+Redisson功能介绍+可重入锁+WatchDog机制+multiLock)
Redis系列学习文章分享---第六篇(Redis实战篇--Redis分布式锁+实现思路+误删问题+原子性+lua脚本+Redisson功能介绍+可重入锁+WatchDog机制+multiLock)
227 0
|
3月前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
这篇文章介绍了如何在SpringBoot项目中整合Redis,并探讨了缓存穿透、缓存雪崩和缓存击穿的问题以及解决方法。文章还提供了解决缓存击穿问题的加锁示例代码,包括存在问题和问题解决后的版本,并指出了本地锁在分布式情况下的局限性,引出了分布式锁的概念。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
|
4月前
|
负载均衡 NoSQL Java
|
3月前
|
算法
分布式锁设计问题之重建节点锁信息时要分为多个阶段如何解决
分布式锁设计问题之重建节点锁信息时要分为多个阶段如何解决
|
3月前
分布式锁设计问题之节点A向节点C发起对R1的加锁请求如何解决
分布式锁设计问题之节点A向节点C发起对R1的加锁请求如何解决

热门文章

最新文章