Redisson 分布式锁原理分析

示例程序

示例程序：

public class RedissonTest {public static void main(String[] args) {Config config = new Config();config.useSingleServer().setPassword("123456").setAddress("redis://127.0.0.1:6379");RedissonClient redisson = Redisson.create(config);// RLock对象RLock lock = redisson.getLock("MY_KEY");ExecutorService pool = Executors.newFixedThreadPool(5);IntStream.range(1, 5).forEach(item -> {pool.execute(() -> {try {if (lock.tryLock(2000, TimeUnit.MILLISECONDS)) {System.out.println(Thread.currentThread().getName() + "get Lock!!");if (lock.tryLock(2000, TimeUnit.MILLISECONDS)) {System.out.println(Thread.currentThread().getName() + "get Lock!!");Thread.sleep(300000);lock.unlock();}Thread.sleep(500000);lock.unlock();}} catch (Exception e) {System.out.println("error!!");}});});}
}

运行结果：

redis中的值：

原理

分布式锁实现加锁解锁都需要使用lua脚本。
利用Redis的Hash结构实现可重入。

Hash结构存值如下：

key	field	value

• key：就是分布式锁的key
• field：用于存储一个能够表示一个线程的唯一标识（Redisson使用的UUID）
• value：表示当前锁被同一个线程加锁的次数（可重入的实现方式）

下面以key为MY_KEY，field线程唯一标识为：WWSSWWWKKII99I为例，总结下加锁解锁流程：

加锁流程

加锁流程：

加锁之后，hash结构为

key	field	value
MY_KEY	WWSSWWWKKII99I	1

实际的存储示例：
一个线程获取了一次：

一个线程获取了两次（可重入）：

解锁流程

解锁流程：
假设当前锁的hash结构是

key	field	value
MY_KEY	WWSSWWWKKII99I	2

这代表分布式锁 MY_KEY 被线程标识为 WWSSWWWKKII99I 的线程获取了两次

需要注意，整个加锁解锁的命令全都需要使用lua脚本。这样能保证操作的原子性。