分布式锁工具：Redisson

Redisson是一个在Redis的基础上实现的Java驻内存数据网格（In-Memory Data Grid）。它不仅提供了一系列的分布式的Java常用对象，还提供了许多分布式服务。,Redisson的宗旨是促进使用者对Redis的关注分离（Separation of Concern），从而让使用者能够将精力更集中地放在处理业务逻辑上。,一个基于Redis实现的分布式工具，有基本分布式对象和高级又抽象的分布式服务，为每个试图再造分布式轮子的程序员带来了大部分分布式问题的解决办法。,Redisson和Jedis、Lettuce有什么区别？倒也不是雷锋和雷锋塔,Redisson和它俩的区别就像一个用鼠标操作图形化界面，一个用命令行操作文件。Redisson是更高层的抽象，Jedis和Lettuce是Redis命令的封装。,Jedis把Redis命令封装好，Lettuce则进一步有了更丰富的Api，也支持集群等模式。但是两者也都点到为止，只给了你操作Redis数据库的脚手架，而Redisson则是基于Redis、Lua和Netty建立起了成熟的分布式解决方案，甚至redis官方都推荐的一种工具集。,分布式锁是并发业务下的刚需，虽然实现五花八门：ZooKeeper有Znode顺序节点，数据库有表级锁和乐/悲观锁，Redis有setNx，但是殊途同归，最终还是要回到互斥上来，本篇介绍Redisson，那就以redis为例。,以Spring Data Redis为例，用RedisTemplate来操作Redis（setIfAbsent已经是setNx + expire的合并命令），如下：,简单1.0版本完成，聪明的小张一眼看出，这是锁没错，但get和del操作非原子性，并发一旦大了，无法保证进程安全。于是小张提议，用Lua脚本。,Lua脚本是redis已经内置的一种轻量小巧语言，其执行是通过redis的eval /evalsha 命令来运行，把操作封装成一个Lua脚本，如论如何都是一次执行的原子操作。,于是2.0版本通过Lua脚本删除。,lockDel.lua如下：,delete操作时执行Lua命令：,2.0似乎更像一把锁，但好像又缺少了什么，小张一拍脑袋，synchronized和ReentrantLock都很丝滑，因为他们都是可重入锁，一个线程多次拿锁也不会死锁，我们需要可重入。,重入就是，同一个线程多次获取同一把锁是允许的，不会造成死锁，这一点synchronized偏向锁提供了很好的思路，synchronized的实现重入是在JVM层面，JAVA对象头MARK WORD中便藏有线程ID和计数器来对当前线程做重入判断，避免每次CAS。,当一个线程访问同步块并获取锁时，会在对象头和栈帧中的锁记录里存储偏向的线程ID，以后该线程在进入和退出同步块时不需要进行CAS操作来加锁和解锁，只需简单测试一下对象头的Mark Word里是否存储着指向当前线程的偏向锁。如果测试成功，表示线程已经获得了锁。如果测试失败，则需要再测试一下Mark Word中偏向锁标志是否设置成1：没有则CAS竞争；设置了，则CAS将对象头偏向锁指向当前线程。,再维护一个计数器，同个线程进入则自增1，离开再减1，直到为0才能释放,可重入锁,仿造该方案，我们需改造Lua脚本：,每次线程获取锁时，判断是否已存在该锁；,每次线程来解锁时，判断是否已存在该锁；,（1）存储结构,为了方便维护这个对象，我们用Hash结构来存储这些字段。Redis的Hash类似Java的HashMap，适合存储对象。,,设置一个名字为lockname1 的hash结构，该hash结构key为threadId ，值value为1；,获取lockname1的threadId的值；,存储结构为：,redis中的结构,,（2）计数器的加减,当同一个线程获取同一把锁时，我们需要对对应线程的计数器count做加减,判断一个redis key是否存在，可以用exists，而判断一个hash的key是否存在，可以用hexists,,而redis也有hash自增的命令hincrby,每次自增1时 hincrby lockname1 threadId 1，自减1时 hincrby lockname1 threadId -1,,（3）解锁的判断,当一把锁不再被需要了，每次解锁一次，count减1，直到为0时，执行删除；,综合上述的存储结构和判断流程，加锁和解锁Lua如下：,加锁 lock.lua；,解锁 unlock.lua；,代码；,至此已经完成了一把分布式锁，符合互斥、可重入、防死锁的基本特点。,严谨的小张觉得虽然当个普通互斥锁，已经稳稳够用，可是业务里总是又很多特殊情况的，比如A进程在获取到锁的时候，因业务操作时间太长，锁释放了但是业务还在执行，而此刻B进程又可以正常拿到锁做业务操作，两个进程操作就会存在依旧有共享资源的问题 。,而且如果负责储存这个分布式锁的Redis节点宕机以后，而且这个锁正好处于锁住的状态时，这个锁会出现锁死的状态 。,小张不是杠精，因为库存操作总有这样那样的特殊。,所以我们希望在这种情况时，可以延长锁的releaseTime延迟释放锁来直到完成业务期望结果，这种不断延长锁过期时间来保证业务执行完成的操作就是锁续约。,读写分离也是常见，一个读多写少的业务为了性能，常常是有读锁和写锁的。,而此刻的扩展已经超出了一把简单轮子的复杂程度，光是处理续约，就够小张喝一壶，何况在性能（锁的最大等待时间）、优雅（无效锁申请）、重试（失败重试机制）等方面还要下功夫研究。,在小张苦思冥想时，旁边的小白凑过来看了看小张，很好奇，都2021年了，为什么不直接用redisson呢？,Redisson就有这把你要的锁。,（1）依赖,（2）配置,（3）启用分布式锁,简洁明了，只需要一个RLock，既然推荐Redisson，就往里面看看他是怎么实现的。,RLock是Redisson分布式锁的最核心接口，继承了concurrent包的Lock接口和自己的RLockAsync接口，RLockAsync的返回值都是RFuture，是Redisson执行异步实现的核心逻辑，也是Netty发挥的主要阵地。,从RLock进入，找到RedissonLock类，找到tryLock 方法再递进到干事的tryAcquireOnceAsync 方法，这是加锁的主要代码（版本不一此处实现有差别，和最新3.15.x有一定出入，但是核心逻辑依然未变。此处以3.13.6为例）。,此处出现leaseTime时间判断的2个分支，实际上就是加锁时是否设置过期时间，未设置过期时间（-1）时则会有watchDog 的锁续约 （下文），一个注册了加锁事件的续约任务。我们先来看有过期时间tryLockInnerAsync 部分，,evalWriteAsync是eval命令执行lua的入口；,这里揭开真面目，eval命令执行Lua脚本的地方，此处的Lua脚本展开；,和前面我们写自定义的分布式锁的脚本几乎一致，看来redisson也是一样的实现，具体参数分析：,总共3个参数完成了一段逻辑,也和上述自定义锁没有区别,既然如此，那解锁的步骤也肯定有对应的-1操作，再看unlock方法，同样查找方法名，一路到；,掏出Lua部分；,该Lua KEYS有2个Arrays.asList(getName(), getChannelName())；,ARGV变量有三个LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId)；,步骤如下：,其中unLock的时候使用到了Redis发布订阅PubSub完成消息通知。,而订阅的步骤就在RedissonLock的加锁入口的lock方法里；,当锁被其他线程占用时，通过监听锁的释放通知（在其他线程通过RedissonLock释放锁时，会通过发布订阅pub/sub功能发起通知），等待锁被其他线程释放，也是为了避免自旋的一种常用效率手段。,（1）解锁消息,为了一探究竟通知了什么，通知后又做了什么，进入LockPubSub。,这里只有一个明显的监听方法onMessage，其订阅和信号量的释放都在父类PublishSubscribe，我们只关注监听事件的实际操作。,发现一个是默认解锁消息 ，一个是读锁解锁消息 ，因为redisson是有提供读写锁的，而读写锁读读情况和读写、写写情况互斥情况不同，我们只看上面的默认解锁消息unlockMessage分支。,LockPubSub监听最终执行了2件事,Redisson通过LockPubSub 监听解锁消息，执行监听回调和释放信号量通知等待线程可以重新抢锁。,这时再回来看tryAcquireOnceAsync另一分支；,可以看到，无超时时间时，在执行加锁操作后，还执行了一段费解的逻辑；,此处涉及到Netty的Future/Promise-Listener模型，Redisson中几乎全部以这种方式通信（所以说Redisson是基于Netty通信机制实现的），理解这段逻辑可以试着先理解。,在 Java 的 Future 中，业务逻辑为一个 Callable 或 Runnable 实现类，该类的 call()或 run()执行完毕意味着业务逻辑的完结，在 Promise 机制中，可以在业务逻辑中人工设置业务逻辑的成功与失败，这样更加方便的监控自己的业务逻辑。,这块代码的表面意义就是，在执行异步加锁的操作后，加锁成功则根据加锁完成返回的ttl是否过期来确认是否执行一段定时任务。,这段定时任务的就是watchDog的核心。,（2）锁续约,查看RedissonLock.this.scheduleExpirationRenewal(threadId)；,拆分来看，这段连续嵌套且冗长的代码实际上做了几步：,renewExpirationAsync 的Lua如下：,重新设置了超时时间。,Redisson加这段逻辑的目的是什么？,目的是为了某种场景下保证业务不影响，如任务执行超时但未结束，锁已经释放的问题。,当一个线程持有了一把锁，由于并未设置超时时间leaseTime，Redisson默认配置了30S，开启watchDog，每10S对该锁进行一次续约，维持30S的超时时间，直到任务完成再删除锁。,这就是Redisson的锁续约 ，也就是WatchDog 实现的基本思路。,（3）流程概括,通过整体的介绍，流程简单概括：,详细加锁解锁流程总结如下图：,
,,以上介绍的可重入锁是非公平锁，Redisson还基于Redis的队列（List）和ZSet实现了公平锁。,公平就是按照客户端的请求先来后到排队来获取锁，先到先得，也就是FIFO，所以队列和容器顺序编排必不可少。,FairSync,回顾JUC的ReentrantLock公平锁的实现；,AQS已经提供了整个实现，是否公平取决于实现类取出节点逻辑是否顺序取；,,AbstractQueuedSynchronizer是用来构建锁或者其他同步组件的基础框架，通过内置FIFO队列来完成资源获取线程的排队工作，他自身没有实现同步接口，仅仅定义了若干同步状态获取和释放的方法来供自定义同步组件使用（上图），支持独占和共享获取，这是基于模版方法模式的一种设计，给公平/非公平提供了土壤。,我们用2张图来简单解释AQS的等待流程（出自《JAVA并发编程的艺术》）。,一张是同步队列（FIFO双向队列）管理 获取同步状态失败（抢锁失败）的线程引用、等待状态和前驱后继节点的流程图。,,一张是独占式获取同步状态的总流程 ，核心acquire(int arg)方法调用流程。,,可以看出锁的获取流程：,AQS维护一个同步队列，获取状态失败的线程都会加入到队列中进行自旋，移出队列或停止自旋的条件是前驱节点为头节点切成功获取了同步状态。,而比较另一段非公平锁类NonfairSync可以发现，控制公平和非公平的关键代码，在于hasQueuedPredecessors方法。,NonfairSync减少了了hasQueuedPredecessors判断条件，该方法的作用就是。,查看同步队列中当前节点是否有前驱节点，如果有比当前线程更早请求获取锁则返回true。,保证每次都取队列的第一个节点（线程）来获取锁，这就是公平规则。,为什么JUC以默认非公平锁呢？,因为当一个线程请求锁时，只要获取来同步状态即成功获取。在此前提下，刚释放的线程再次获取同步状态的几率会非常大，使得其他线程只能在同步队列中等待。但这样带来的好处是，非公平锁大大减少了系统线程上下文的切换开销。,可见公平的代价是性能与吞吐量。,Redis里没有AQS，但是有List和zSet，看看Redisson是怎么实现公平的。,RedissonFairLock,RedissonFairLock 用法依然很简单,RedissonFairLock继承自RedissonLock，同样一路向下找到加锁实现方法tryLockInnerAsync 。,这里有2段冗长的Lua，但是Debug发现，公平锁的入口在 command == RedisCommands.EVAL_LONG 之后，此段Lua较长，参数也多，我们着重分析Lua的实现规则。,参数,公平锁实现的Lua脚本,公平锁加锁步骤,通过以上Lua，可以发现，lua操作的关键结构是列表（list）和有序集合（zSet）。,保证队列中只有未过期的等待线程；,hset加锁，pexpire过期时间；,此处同可重入锁lua；,初始值为锁的剩余过期时间；,ttl + 2 * currentTime + waitTime是score的默认值计算公式。,模拟,如果模拟以下顺序，就会明了redisson公平锁整个加锁流程。,假设 t1 10:00:00 < t2 10:00:10 < t3 10:00:20。,t1：当线程1初次获取锁,加锁成功，线程1获取到锁，结束。,t2：线程2尝试获取锁（线程1未释放锁）,score = 20S + 5000ms + 10:00:10 + 10:00:10 = 10:00:35 + 10:00:10,t3：线程3尝试获取锁（线程1未释放锁）,score = 10S + 5000ms + 10:00:20 + 10:00:20 = 10:00:35 + 10:00:20,如此一来，三个需要抢夺一把锁的线程，完成了一次排队，在list中排列他们等待线程id，在zSet中存放过期时间（便于排列优先级）。其中返回ttl的线程2客户端、线程3客户端将会一直按一定间隔自旋重复执行该段Lua，尝试加锁，如此一来便和AQS有了异曲同工之处。,而当线程1释放锁之后（这里依旧有通过Pub/Sub发布解锁消息，通知其他线程获取）。,10:00:30 线程2尝试获取锁（线程1已释放锁）,线程2 10:00:35 + 10:00:10 - 10:00:30 = 10:00:15,线程3 10:00:35 + 10:00:20 - 10:00:30 = 10:00:25,加锁成功，线程2获取到锁，结束,排队结构如图：,,公平锁的释放脚本和重入锁类似，多了一步加锁开头的清理过期key的while true逻辑，在此不再展开篇幅描述。,由上可以看出，Redisson公平锁的玩法类似于延迟队列的玩法，核心都在Redis的List和zSet结构的搭配，但又借鉴了AQS实现，在定时判断头节点上如出一辙（watchDog），保证了锁的竞争公平和互斥。并发场景下，lua脚本里，zSet的score很好地解决了顺序插入的问题，排列好优先级。,并且为了防止因异常而退出的线程无法清理，每次请求都会判断头节点的过期情况给予清理，最后释放时通过CHANNEL通知订阅线程可以来获取锁，重复一开始的步骤，顺利交接到下一个顺序线程。,Redisson整体实现分布式加解锁流程的实现稍显复杂，作者Rui Gu对Netty和JUC、Redis研究深入，利用了很多高级特性和语义，值得深入学习，本次介绍也只是单机Redis下锁实现。,Redisson也提供了多机情况下的联锁MultiLock：,https://github.com/redisson/redisson/wiki/8.-分布式锁和同步器#81-可重入锁reentrant-lock,和官方推荐的红锁RedLock：,https://github.com/redisson/redisson/wiki/8.-分布式锁和同步器#84-红锁redlock,所以，当你真的需要分布式锁时，不妨先来Redisson里找找。,