前言

Redisson 不僅僅是一個 Redis 客戶端，它更是一個在 Redis 基礎(chǔ)上實現(xiàn)的 Java 駐內(nèi)存數(shù)據(jù)網(wǎng)格（In-Memory Data Grid）。它的核心目標(biāo)是讓 Java 開發(fā)者能夠以最自然的方式使用 Redis，將復(fù)雜的 Redis 命令封裝成大家熟悉的 Java 接口（如 java.util.concurrent 包下的接口）。

一、核心設(shè)計理念

Redisson 的原理可以概括為：通過 Netty 實現(xiàn)高性能、非阻塞的通信，將 Redis 的數(shù)據(jù)結(jié)構(gòu)映射為 Java 對象和分布式對象，并在此基礎(chǔ)上，利用 Redis 的單線程原子性特性，實現(xiàn)了一系列分布式的、線程安全的 Java 常用工具。

二、核心架構(gòu)與通信層

1. 基于 Netty 的異步非阻塞通信

• Netty 框架：Redisson 使用 Netty 4+ 作為其網(wǎng)絡(luò)通信框架。這保證了高吞吐量和低延遲的連接管理。它允許同時處理成千上萬的連接，而不會為每個連接創(chuàng)建單獨的線程。
• 連接管理：Redisson 維護(hù)著一個與 Redis 服務(wù)器的連接池（可以是單機、哨兵、集群等模式）。它通過 ConnectionManager 來統(tǒng)一管理這些連接的生命周期、心跳檢測、重連機制等。
• 異步與響應(yīng)式：所有操作在底層都是異步的。當(dāng)你調(diào)用 get("key") 時，Redisson 會通過 Netty 將一個請求寫入 Channel，然后立即返回一個 RFuture 對象。你可以同步等待這個 Future（future.get()），也可以為其添加監(jiān)聽器進(jìn)行異步回調(diào)。這為構(gòu)建高并發(fā)應(yīng)用打下了基礎(chǔ)。

2. 編解碼器

• Redisson 使用可插拔的編解碼器來序列化/反序列化 Java 對象和 Redis 存儲的二進(jìn)制數(shù)據(jù)。
• 默認(rèn)使用 JacksonJsonCodec，但你也可以選擇 StringCodec、AvroCodec 等，或者自定義。這保證了存儲格式的靈活性。

三、關(guān)鍵原理詳解：如何實現(xiàn)分布式對象與服務(wù)

這是 Redisson 最核心、最巧妙的部分。它不僅僅是發(fā)送命令，而是在 Redis 的數(shù)據(jù)結(jié)構(gòu)上構(gòu)建了一層對象邏輯。

1. 分布式對象

Redisson 將 Redis 的每一種基本數(shù)據(jù)結(jié)構(gòu)都包裝成了一個 Java 對象。

• RList： 對應(yīng) Redis 的 List。當(dāng)你調(diào)用 RList.add(object) 時，Redisson 底層會執(zhí)行 RPUSH 命令。RList 實現(xiàn)了 java.util.List 接口，所以你感覺像是在操作本地集合。
• RMap： 對應(yīng) Redis 的 Hash。實現(xiàn)了 java.util.Map 接口。底層使用 HMSET, HGETALL 等命令。
• RSortedSet： 對應(yīng) Redis 的 Sorted Set。實現(xiàn)了 java.util.SortedSet 接口。

原理：這些對象內(nèi)部持有一個 CommandAsyncExecutor。你的每一個方法調(diào)用（如 map.put(key, value)），都會被轉(zhuǎn)換成一個或多個 Redis 命令，并通過 Netty 發(fā)送給 Redis 服務(wù)器。

2. 分布式集合

這是對分布式對象的擴展，增加了本地緩存功能。例如 RListCache 和 RMapCache。

• 原理：它們不僅將數(shù)據(jù)存儲在 Redis 中，還會在 JVM 本地內(nèi)存中緩存一份。它們通過監(jiān)聽 Redis 的發(fā)布訂閱（Pub/Sub） 頻道來保證集群中所有節(jié)點的本地緩存一致性。當(dāng)任何一個節(jié)點修改了數(shù)據(jù)，它會發(fā)布一個消息，其他節(jié)點收到后，會使自己本地的對應(yīng)緩存失效。

3. 分布式鎖 - 核心亮點

這是 Redisson 最著名的功能。它實現(xiàn)了 java.util.concurrent.locks.Lock 接口。

原理圖如下：

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

1. 唯一值： 每個鎖請求都會有一個唯一的 UUID + 線程 ID 作為值。這用于標(biāo)識鎖的持有者，避免其他客戶端釋放了不屬于自己的鎖。
2. Lua 腳本： 加鎖操作是通過執(zhí)行一段 Lua 腳本完成的。Lua 腳本在 Redis 中執(zhí)行是原子性的，這是實現(xiàn)鎖的關(guān)鍵。

-- 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;
-- 鎖已存在，檢查是否是當(dāng)前線程持有的
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then
    -- 是當(dāng)前線程，重入次數(shù)+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;
-- 重入次數(shù)-1
local counter = redis.call('hincrby', KEYS[1], ARGV[1], -1);
if (counter > 0) then
    -- 如果重入次數(shù)還大于0，則重新設(shè)置過期時間
    redis.call('pexpire', KEYS[1], 30000);
    return 0;
else
    -- 重入次數(shù)為0，刪除key
    redis.call('del', KEYS[1]);
    -- 發(fā)布一條解鎖消息，通知其他等待的客戶端
    redis.call('publish', KEYS[2], ARGV[2]);
    return 1;
end;
return nil;

等待鎖的原理： 如果獲取鎖失敗，客戶端并不會不停地輪詢，而是通過 Redis 的發(fā)布訂閱（Pub/Sub） 功能，訂閱一個特定的頻道。當(dāng)鎖被釋放時，當(dāng)前持有鎖的客戶端會發(fā)布一個消息（見上面解鎖腳本的最后），所有等待的客戶端都會收到通知，然后競爭性地再次嘗試加鎖。這大大減少了不必要的網(wǎng)絡(luò)請求。

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

原理與鎖類似，都是基于 Redis 的原子性操作（Lua 腳本）和發(fā)布訂閱機制。

• RSemaphore： 使用 Redis 的字符串結(jié)構(gòu)存儲許可數(shù)量。acquire() 減少數(shù)量，release() 增加數(shù)量。如果沒有許可，則通過發(fā)布訂閱等待。
• RCountDownLatch： 使用 Redis 的字符串結(jié)構(gòu)存儲計數(shù)。countDown() 遞減計數(shù)，await() 等待計數(shù)變?yōu)?。當(dāng)計數(shù)為0時，通過發(fā)布訂閱通知所有等待的線程。

四、數(shù)據(jù)分片與集群支持

Redisson 能夠無縫地與 Redis 集群配合工作。

• 自動重定向： 當(dāng)在集群模式下執(zhí)行一個命令時，如果返回 -MOVED 錯誤，Redisson 的 ClusterConnectionManager 會自動更新其 Slot-Node 映射表，并將命令重新路由到正確的節(jié)點。
• Pipelining： 支持在集群模式下將多個命令打包成一個 pipeline 發(fā)送，以提高性能。

五、總結(jié)：Redisson 的核心原理

1. 網(wǎng)絡(luò)與通信： 基于 Netty 的高性能、異步、非阻塞通信模型。
2. 原子性基石： 充分利用 Lua 腳本 在 Redis 中執(zhí)行的原子性，來實現(xiàn)復(fù)雜的分布式同步邏輯。
3. 事件驅(qū)動： 廣泛使用 發(fā)布訂閱（Pub/Sub） 機制來實現(xiàn)事件通知，避免低效的輪詢，如鎖的等待、緩存失效等。
4. 對象映射： 將 Redis 的數(shù)據(jù)結(jié)構(gòu)通過編解碼器映射為熟悉的 Java 對象接口（List, Map, Lock 等）。
5. 容錯與高可用： 通過看門狗機制、連接池管理、重連機制、哨兵和集群模式的支持，保證了服務(wù)的魯棒性。

簡單來說，Redisson 的原理就是 “用 Redis 的命令做磚瓦，用 Lua 腳本做水泥，用 Netty 做骨架，為 Java 世界構(gòu)建了一座名為 ‘分布式工具’ 的大廈”。它讓你在分布式環(huán)境中，獲得了近乎與單機應(yīng)用相同的編程體驗。

到此這篇關(guān)于Java中Redisson 的原理深度解析的文章就介紹到這了,更多相關(guān)java redisson原理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論