Redis分布式锁的实战应用
以商品超卖为例讲解Redis分布式锁
主要讲解Redis实现分布式锁的两种实现方式:Jedis
实现、Redisson
实现
一、Jedis实现
该方案只考虑Redis单机部署的场景
1.1 加锁
1.1.1 原理
jedis.set(String key, String value, String nxxx, String expx, int time)
参数解释:
-
key
: 使用key来当锁,因为key
是惟一的; -
value
: 这里传入的是唯一值(UUID),很多人不明白,有了 key 作为锁不就够了吗,为什么还要用到value
?原因是分布式锁要满足解铃还须系铃人
:通过给value
赋值为requestId
,我们就可知道这把锁是哪个请求加的,在解锁的时候要验证value
值,不能误解锁; -
nxxx
: 这个参数我传的是NX
,意思是SET IF NOT EXIST
,即当key
不存在时,执行set
操作;若key
已经存在,则不作任何操作;-
NX
: not exists, 只有key 不存在时才把key value
set 到redis -
XX
: is exists ,只有 key 存在是,才把key value
set 到redis
-
-
expx
:这个参数我传的是 PX,意思是我们要给这个 key 加一个过期的设置,具体时间有第五个参数决定;
expx参数有两个值可选 :
EX
: seconds 秒
PX
: milliseconds 毫秒 -
time
: 与第四个参数相呼应,代表key的过期时间。
有两种可选的值,int
和long
的 time,都是过期时间不管是
int
还是long
,都转成String
了,所以jedis 的最后两个重载方法,其实是一样的。(猜测:1、expx 参数是px的时候,使用long类型的参数,可以表示更多时间; 2、满足使用习惯long类型表示毫秒)
最后,返回值 String
,如果写入成功是“OK”
,写入失败返回空(在nxxx的时候,也是)
1.1.2 小结
-
set()
加入了NX
参数,可以保证如果已有key
存在,则函数不会调用成功,也就是只有一个客户端能只有锁,满足互斥性
; - 其次,由于我们对锁设置了过期时间,即使锁的持有者后续发生崩溃而没有解锁,锁也会因为到了过期时间而自动解锁(即
key
被删除),不会发生死锁
; - 最后,因为我们将
value
赋值为requestId
,代表加锁的客户端请求标识,那么客户端在解锁的时候可以进行校验是否是同一个客户端。
1.2 释放锁
释放锁时需要验证 value
值,也就是说我们在获取锁的时候需要设置一个 value
,不能直接用 del key
这种粗暴的方式,因为直接 del key
任何客户端都可以进行解锁了,所以解锁时,我们需要判断锁是否是由当前客户端创建的(基于 value
值来判断)
具体操作步骤:
- 首先,写一个简单的
Lua
脚本代码,作用是:获取锁对应的value
值,检查是否与requestId
相同,如果相同则删除锁(解锁); - 然后,将
Lua
代码传递到jedis.evel()
方法里,并使参数KEYS[1]
赋值为lockKey
,ARGV[1]
赋值为requestId
。eval()
方法是将Lua
代码交给Redis
服务端执行。
后面代码有实例
1.3案例(家庭多人领取奖励的场景)
1.3.1 准备
该案例模拟家庭内多人通过领取一个奖励,但是只能有一个人能领取成功,不能重复领取