Redisson 分布式锁原理分析

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

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

加锁流程

加锁流程：

加锁之后，hash结构为

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

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

解锁流程

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

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

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