之前有两篇文章,已经介绍过redisson分布式的代码使用教程,上锁流程。
这篇文章主要详细解析redisson源码。Redis本身就能实现分布式锁,因为他是单线程,并且有天然的幂等性,互斥性,通过setNx也能加锁,处理好释放锁的逻辑即可,Redisson可以理解为redis的高级管理端。
Redisson有lock和tryLock两种上锁方法:
Lock:直接加锁,若锁被占用,则进入阻塞,一直等到锁被释放为止。
tryLock:返回true或false,可以设置获取锁的等待超时时间,若锁被其他线程获取,则在等待时间内一直尝试加锁,超过等待时间,则返回false,获取失败。
接下来看tryLock源码:
从源码我们可以看到,主要逻辑就是获取锁,判断其他线程是否获取锁,若获取了就重复尝试获取,然后期间有若干超时判断:
- 先是tryAcquire方法尝试获取锁,若其他线程未获取,则直接返回null,直接返回true加锁成功。
- 若其他线程获取了锁,则返回其他线程的获取锁时间。然后看自己当前锁是否超时,未超时则进入死循环继续尝试获取锁。
tryAcquire方法干嘛的呢? 上图就是在此方法里的代码,该方法里面主要和redis通信,用lua封装复杂的业务逻辑发给redis,若key没有上锁,则返回null,上锁了,则返回超时时间。
这个waiting for message 是干什么的呢?
waitTime和redis锁住的key的超时时间大小做比较,取二者中比较小的值,用java的Semaphore信号量tryAcquire方法来阻塞线程,Semaphore是由上面的代码subscribe方法控制的。
subscribe方法,它会进入到PublishSubscribe.java中,当前的线程ID添加到AsyncSemaphore,并且设置redis的监听器,这个监听器是通过redis的发布、订阅功能实现的, 一旦监听器收到redis发来的消息,就从中获取与当前thread相关的消息,如果是锁被释放的消息,就立马通过操作Semaphore来让刚才阻塞的地方释放。
如果锁重入了怎么办呢,比如同一个线程,两次tryLock,怎么保证全部都能释放锁?
lua脚本有两个if,第一个if如果成立,则会加锁成功,因为现在已经是重入锁,第二次加锁了,所以第一个if判断肯定不成立,第二个if会获取当前客户端的ID,这时候会执行可重入锁的逻辑,对当前客户端累计加1。释放锁的时候如何释放呢,其实就是unlock,每次对统计的加锁数量减1,若为0了,则del myLock,在redis里删除这个key。
最后,看到这里的读者,喜欢的话安排一波(点赞,收藏,关注),原创不易,每周定期分享编程笔记