Redisson分布式锁底层实现原理

古城微笑少年丶 2023-10-13 15:49 25阅读 0赞

在Java中有很多保证线程安全的方式，比如synchorized，lock锁等等，这些在单机环境下都能发挥不错的作用，但是在分布式的环境下，这些机制就会失去大部分的作用。

在分布式环境下就需要引入分布式锁，实现分布式锁的方式有好多种，比如redis、zookeeper，或者通过数据库来实现，但是在分布式的情况下还需要考虑机器宕机的情况，如果某台机器上的线程获取到了这个锁，但此时机器宕机了。那么就没办法去释放，就会造成死锁的情况。

为了避免这种情况，就需要给锁加上一个过期时间，而过期时间的设定又是一个令人非常头疼的问题。

在Redisson种有一个看门狗机制，它给出了一种过期时间的很好的解决办法。下面就来研究一下它具体实现吧。

Redisson的加锁入口是tryLock()，此方法需提供获取锁的等待时间，如果在规定时间内未抢到锁，会返回false。

![format_png][]

这里可以看到tryLock()方法实际上是调用了下面这个方法，这里给了一个leaseTime的默认值，至于为什么是-1，我们接着往下看。

![format_png 1][]

进来之后会发现，这个方法的核心就是执行一个tryAcquire方法，我们点进去看一下。

![format_png 2][]

tryAcquire方法实际会去执行tryAcquireAsync异步的去获取锁，然后再使用get获取结果，如果结果为null代表获取锁成功，这里后面会讲。

![format_png 3][]

然后进到tryAcquireAsync方法，在这里判断了leaseTime是不是-1，如果我们自己设定了过期时间，那么就会以我们设置的为准，并且不会去开启自动续期。

如果是默认的-1，那么异步获取锁之后，后面还会去开启一个自动续期的定时任务。

![format_png 4][]

异步获取锁是通过tryLockInnerAsync这个方法实现的。第一个参数是30000，传入的是commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout()，点进去可以看到

![format_png 5][]

在这个方法里使用lua脚本的方式去执行了set操作

这段lua脚本的意思是：

锁不存在，加锁成功，设置hash数据结构锁: 锁名 -> 加锁线程:id -> 加锁次数(1)  
锁存在且是本线程的锁 加锁次数增加：锁名 -> 加锁线程:id -> 加锁次数+1  
锁存在且不是本线程的锁 加锁失败 返回锁剩余过期时间

从这里也可以体现出此锁的可重入，即某一线程获取到锁之后，那么这个线程再去获取该锁的话也可以成功

同时也可以如果返回为null那么说明获取锁成功。

![format_png 6][]

然后后面会判断如果结果为null，就会去执行scheduleExpirationRenewal(threadId)方法，进去看一下

![format_png 7][]

由于我们的Redission的分布式锁是可重入锁，所以这里会首先判断一下是不是第一次加锁，如果不是第一次则加锁次数加 1 不会再开启续期 因为第一次加锁时调用

如果是第一次加锁的话就回去调用renewExpiraton()去开启自动续期。

![format_png 8][]

addThreadId：重入次数+1

![format_png 9][]

renewExpiraton()开启自动续期这个方法里面创建了一个定时任务，主要逻辑是通过renewExpirationAsync(threadId)方法去执行续期逻辑，执行成功后还会通过下面if (res) \{renewExpiration();\}方法递归调用。

注意到这个线程执行的间隔是internalLockLeaseTime / 3，也就是30 / 3 = 10s

![format_png 10][]

我们可以看一下renewExpirationAsync方法里面的逻辑

此lua脚本的意思是：当前线程持有的锁是否还存在 存在的话重新设置锁的过期时间(默认 30 秒)

![format_png 11][]

至此加锁的逻辑就追完了。

下面我们看一看释放锁的逻辑。其入口为：unlock方法，它会去调用unlockAsync方法。

![format_png 12][]

unlockAsync里面掉了unlockInnerAsync方法去释放锁，

![format_png 13][]

unlockInnerAsync方法点进去我们可以看到它也是通过lua脚本的方式去释放锁。

若锁不存在 返回 若锁存在 加锁次数 -1 若加锁次数仍不等于 0 (可重入)，重新设置锁的过期时间，返回 若加锁次数减为 0，删除锁，同步发布释放锁事件，返回

![format_png 14][]

[format_png]: https://img-blog.csdnimg.cn/img_convert/863cfe24365e6f34e1d43761847f7bf0.webp?x-oss-process=image/format,png
[format_png 1]: https://img-blog.csdnimg.cn/img_convert/50550ec476c503b89467bcff4f2f66a5.webp?x-oss-process=image/format,png
[format_png 2]: https://img-blog.csdnimg.cn/img_convert/b73f007dd4fd1a565e09f6ce0743fdbd.webp?x-oss-process=image/format,png
[format_png 3]: https://img-blog.csdnimg.cn/img_convert/b2aafc232223e16429a457a8864fdcf0.webp?x-oss-process=image/format,png
[format_png 4]: https://img-blog.csdnimg.cn/img_convert/135e4e64c1d0320c87383f2732c8bd78.webp?x-oss-process=image/format,png
[format_png 5]: https://img-blog.csdnimg.cn/img_convert/89a67f7cd154fc587b5639683ffd5c6a.webp?x-oss-process=image/format,png
[format_png 6]: https://img-blog.csdnimg.cn/img_convert/df35c44305aac87ecae3b2cd0e87cbfc.webp?x-oss-process=image/format,png
[format_png 7]: https://img-blog.csdnimg.cn/img_convert/57375cc8ef0145cccacef9da56f3d74f.webp?x-oss-process=image/format,png
[format_png 8]: https://img-blog.csdnimg.cn/img_convert/1d2386cddc4802fce8448aa65393fac8.webp?x-oss-process=image/format,png
[format_png 9]: https://img-blog.csdnimg.cn/img_convert/52c702bac1e0625a78cb477386050585.webp?x-oss-process=image/format,png
[format_png 10]: https://img-blog.csdnimg.cn/img_convert/4d0f87de3112ac2e1f5318565906eced.webp?x-oss-process=image/format,png
[format_png 11]: https://img-blog.csdnimg.cn/img_convert/93bdd9ad5a22a9fd387fdb36d94fcfe0.webp?x-oss-process=image/format,png
[format_png 12]: https://img-blog.csdnimg.cn/img_convert/304c71a3c860e0072a85aa654cf5cc6f.webp?x-oss-process=image/format,png
[format_png 13]: https://img-blog.csdnimg.cn/img_convert/1bf142ad96dee2ab451e4271e8888dc2.webp?x-oss-process=image/format,png
[format_png 14]: https://img-blog.csdnimg.cn/img_convert/80cef6e87dd6f4824e219ce2730533f6.webp?x-oss-process=image/format,png