Redisson 核心原理详解：分布式锁与对象映射

3. 分布式锁 - 核心亮点

这是 Redisson 最著名的功能。它实现了 java.util.concurrent.locks.Lock 接口。

原理图如下：

加锁原理（lock() 方法）：

1. 唯一值：每个锁请求都会有一个唯一的 UUID + 线程 ID 作为值。这用于标识锁的持有者，避免其他客户端释放了不属于自己的锁。
2. Lua 脚本：加锁操作是通过执行一段 Lua 脚本完成的。Lua 脚本在 Redis 中执行是原子性的，这是实现锁的关键。

-- KEYS[1] 是锁的 key，ARGV[1] 是锁的过期时间，ARGV[2] 是唯一值
if (redis.call('exists', KEYS[1]) == 0) then
    -- 锁不存在，则加锁
    redis.call('hset', KEYS[1], ARGV[2], 1);
    redis.call('pexpire', KEYS[1], ARGV[1]);
    return nil;
end;
-- 锁已存在，检查是否是当前线程持有的
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then
    -- 是当前线程，重入次数 +1
    redis.call('hincrby', KEYS[1], ARGV[2], 1);
    redis.call('pexpire', KEYS[1], ARGV[1]);
    return nil;
end;
-- 锁被其他线程占用，返回锁的剩余生存时间
return redis.call('pttl', KEYS[1]);

1. 看门狗（Watchdog）机制：如果客户端没有显式指定锁的超时时间，Redisson 会启动一个看门狗线程。它会在锁过期时间的三分之一左右时，不断延长锁的持有时间（通过 pexpire 命令）。只要 JVM 没有挂掉，这个锁就不会因为超时而被意外释放，从而避免了死锁。如果 JVM 挂掉，看门狗线程也随之停止，锁最终会自动过期。

解锁原理（unlock() 方法）：

1. Lua 脚本：同样通过 Lua 脚本保证原子性。

-- KEYS[1] 是锁的 key，ARGV[1] 是唯一值
if (redis.call('hexists', KEYS[1], ARGV[1]) == 0) then
    return nil;
end;
-- 重入次数 -1
local counter = redis.call('hincrby', KEYS[1], ARGV[1], -1);
if (counter > 0) then
    -- 如果重入次数还大于 0，则重新设置过期时间
    redis.call('pexpire', KEYS[1], 30000);
    return 0;
else
    -- 重入次数为 0，删除 key
    redis.call('del', KEYS[1]);
    -- 发布一条解锁消息，通知其他等待的客户端
    redis.call('publish', KEYS[2], ARGV[2]);
    return 1;
end;
return nil;

等待锁的原理：如果获取锁失败，客户端并不会不停地轮询，而是通过 Redis 的发布订阅（Pub/Sub） 功能，订阅一个特定的频道。当锁被释放时，当前持有锁的客户端会发布一个消息（见上面解锁脚本的最后），所有等待的客户端都会收到通知，然后竞争性地再次尝试加锁。这大大减少了不必要的网络请求。

4. 其他同步器（如 RSemaphore, RCountDownLatch）

原理与锁类似，都是基于 Redis 的原子性操作（Lua 脚本）和发布订阅机制。

• **RSemaphore**：使用 Redis 的字符串结构存储许可数量。acquire() 减少数量，release() 增加数量。如果没有许可，则通过发布订阅等待。
• **RCountDownLatch**：使用 Redis 的字符串结构存储计数。countDown() 递减计数，await() 等待计数变为 0。当计数为 0 时，通过发布订阅通知所有等待的线程。

四、数据分片与集群支持

Redisson 能够无缝地与 Redis 集群配合工作。

• 自动重定向：当在集群模式下执行一个命令时，如果返回 -MOVED 错误，Redisson 的 ClusterConnectionManager 会自动更新其 Slot-Node 映射表，并将命令重新路由到正确的节点。
• Pipelining：支持在集群模式下将多个命令打包成一个 pipeline 发送，以提高性能。

五、总结：Redisson 的核心原理

1. 网络与通信：基于 Netty 的高性能、异步、非阻塞通信模型。
2. 原子性基石：充分利用 Lua 脚本 在 Redis 中执行的原子性，来实现复杂的分布式同步逻辑。
3. 事件驱动：广泛使用 发布订阅（Pub/Sub） 机制来实现事件通知，避免低效的轮询，如锁的等待、缓存失效等。
4. 对象映射：将 Redis 的数据结构通过编解码器映射为熟悉的 Java 对象接口（List, Map, Lock 等）。
5. 容错与高可用：通过看门狗机制、连接池管理、重连机制、哨兵和集群模式的支持，保证了服务的鲁棒性。

简单来说，Redisson 的原理就是 '用 Redis 的命令做砖瓦，用 Lua 脚本做水泥，用 Netty 做骨架，为 Java 世界构建了一座名为 '分布式工具' 的大厦'。它让你在分布式环境中，获得了近乎与单机应用相同的编程体验。