概述
Redis 实现分布式锁
锁的本质就是独占
获取锁
setex key value
这个key就是你需要锁住的东西,如果你想要保证单用户并发:那么它就可以是用户的userId,当key不存在的时候才能成功,否则失败。以此为基础我们就能保证一个线程获得锁的时候,知道它释放,都不会被其他县城抢占。
但这里就产生了第一个问题。
如果一个线程获得锁后,在释放锁之前就挂了,这个锁永远无法得到释放
要解决这个问题也很简单,我们对这个key 设置一个超时时间。
setex key value
expire key
于是乎就产生了第二个问题。
这是两个命令,如果第一个成功了,第二个失败了,这个锁同样永远无法得到释放
要解决这个问题,实际上要把就是把这个两个命令当成是一个命令,redis中实际上已经提供了这个方法
set key value ex second nx
到这里,我们似乎已经完美的解决加锁的问题(实际上还是有些问题),接下来我们来看解锁。
释放锁
加锁的过程实际上就是set了一个key,解锁最简单的方式当然是删掉key
delete key
这里产生了第三个问题。
如果一个线程执行的很慢,甚至于锁已经被自动释放掉了,但等到它执行完,它又去释放锁,此时被释放掉的实际上就是其他线程的锁
所以我们需要一个标识来表明这个锁是它自己的,线程只能释放它自己的锁,前面我们实际上只用到了key,value就 可以派上用场了,一个简单的方式是给每一个线程分配一个UUID(要保证线程安全)。
获取锁的时候
set key ${UUID} ex second nx
释放锁的时候
# 这里是伪代码
if(get(lock)==exepectedValue){
del(lock)
}
第四个问题出现了
在代码里这还是两个命令,如果当前判断完是自己的锁之后,线程暂停了几秒后又恢复,这个时候
,可能当前线程的锁已经被超时释放了,并且其他线程获得了锁,此时被释放掉的实际上就是其他线程的锁
要解决这个问题,我们还是要把这个两个命令当成一个命令,但遗憾的是redis本身并不提供这个功能,所以我们使用lua脚本的方式来让这两个命令变成一个原子命令
if redis.call("get",KEYS[1]) == ARGV[1]
then
return redis.call("del",KEYS[1])
else
return 0
end
总结:到这里我们基本上实现了一个简单的、基于Redis的分布式锁。
但还是存在以下问题
1、我们设置的时间是一个固定的时间(一般只会有几秒),但如果线程执行花费的时间比较起来长,当锁释放的时候,线程都还没执行完。
最后
以上就是坚定网络为你收集整理的Redis 实现分布式锁Redis 实现分布式锁获取锁释放锁的全部内容,希望文章能够帮你解决Redis 实现分布式锁Redis 实现分布式锁获取锁释放锁所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复