當前位置：首頁 > 科技 > 軟件

玩轉Redis！非常強大的Redisson分布式集合，少寫60%代碼

來源：責編：時間：2024-06-05 17:39:58 168觀看

導讀環境：SpringBoot2.7.18+Redis6.2.6+Redisson3.18.01. 簡介Redisson 是 Redis Java 客戶端和實時數據平臺。它為使用 Redis 提供了更方便、更簡單的方法。Redisson 對象提供了關注點分離功能，可讓你專注于數據建模和應用

環境：SpringBoot2.7.18+Redis6.2.6+Redisson3.18.0

1. 簡介

Redisson 是 Redis Java 客戶端和實時數據平臺。它為使用 Redis 提供了更方便、更簡單的方法。Redisson 對象提供了關注點分離功能，可讓你專注于數據建模和應用邏輯。

在Java中，為我們提供了豐富的集合類，如List、Set、Map等，這些集合類在單機應用或單個JVM進程中是非常強大和有效的工具。然而，在分布式系統下，數據需要在多個JVM進程或節點之間共享和同步。為實現這一目標Redisson提供了許多分布式集合實現，如RList、RSet、RMap等，這些集合類能夠在多個Redis節點之間無縫地共享數據。通過使用Redisson，開發者可以像使用傳統Java集合類一樣，在分布式系統中進行數據的增刪改查操作，而無需擔心數據在不同節點之間的同步和一致性問題。

2. 實戰案例

2.1 Map集合

基于 Redis 的 Java 分布式 Map 對象實現了 ConcurrentMap 接口。該對象是完全線程安全的。

RMap類關系

public interface RMap<K, V> extends ConcurrentMap<K, V>, ...{}

接下來所有操作都是基于RedissonClient對象

@Resourceprivate RedissonClient redisson ;

同步存數據

RMap<String, User> map = redisson.getMap("user-list");User preValue = map.put("1", new User(2L, "張三2", 22)) ;User value = map.putIfAbsent("2", new User(2L, "李四", 33));

快速存數據

如果你不需要返回上一個值（舊值）建議使用相應fast*方法

RMap<String, User> map = redisson.getMap("user-list");map.fastPut("1", new User(2L, "張三2", 22));map.fastPutIfAbsent("2", new User(2L, "李四", 33));map.fastRemove("1") ;

以上操作不會返回對應key之前的舊值。

異步存數據

RFuture<User> f1 = map.putAsync("1", new User(2L, "張三2", 22)) ;RFuture<Boolean> f2 = map.fastPutAsync("2", new User(2L, "李四", 33)) ;RFuture<Long> f3 = map.fastRemoveAsync("2") ;

以上操作對應Redis數據結構。

HASH數據結構

Map集合中key綁定Lock

上面得知，Map保存的數據是hash數據結構，我們可以將每一個key綁定到對應的Lock/ReadWriteLock/Semaphore/CountDownLatch。

RMap<String, User> map = redisson.getMap("user-list") ;RLock lock = map.getLock(key) ;lock.lock() ;try {  System.out.printf("當前線程: %s, 當前時間: %d%n", Thread.currentThread().getName(), System.currentTimeMillis()) ;  TimeUnit.SECONDS.sleep(3) ;} finally {  lock.unlock() ;}

本地緩存

用于加快讀取操作速度，避免網絡往返。它在 Redisson 端緩存地圖條目，執行讀取操作的速度是普通實現的 45 倍。支持本地緩存的地圖對象實現了RLocalCachedMap,它擴展了 java.util.concurrent.ConcurrentMap 接口。該對象是完全線程安全的。

// 配置緩存策略final LocalCachedMapOptions<String, User> LOCAL_CACHE = LocalCachedMapOptions.<String, User>defaults()      // 緩存大小      .cacheSize(200)      // 緩存模式      .storeMode(StoreMode.LOCALCACHE_REDIS)      // 刪除策略      .evictionPolicy(EvictionPolicy.LRU) ;// 獲取指定key本地緩存      RLocalCachedMap<String,User> localCachedMap = redisson.getLocalCachedMap("user-list", LOCAL_CACHE) ;User user = localCachedMap.get("1") ;

本地緩存實例對象同樣支持fast*及異步方式，這里不再贅述。

事件監聽

Redisson 允許為每個 RMap 對象綁定監聽器，RMap 對象允許跟蹤數據上的跟蹤事件。如下表，監聽類及事件

圖片

如下示例：

RMap<String, User> map = redisson.getMap("user-list");int deletedListener = map.addListener(new DeletedObjectListener() {  @Override  public void onDeleted(String name) {    // ...  }});int expredListener = map.addListener(new ExpiredObjectListener() {  @Override  public void onExpired(String name) {    // ...  }});int putListener = map.addListener(new MapPutListener() {  @Override  public void onPut(String name) {    // ...  }});int removeListener = map.addListener(new MapRemoveListener() {  @Override  public void onRemove(String name) {    // ...  }});// 刪除監聽器map.removeListener(listenerId) ; // removeListener, putListener ...

以上是關于Map集合的常用操作。

2.2 Set集合

基于 Redis 的 Java Set 對象實現了 java.util.Set 接口。該對象完全線程安全。通過元素狀態比較保持元素的唯一性。Redis 將集合大小限制為 4 294 967 295 個元素。Redis 使用序列化狀態檢查值的唯一性，而不是值的 hashCode()/equals() 方法。

RSet類關系

public interface RSet<V> extends Set<V>,...{}

基本操作

RSet<User> set = redisson.getSet("user-set");set.add(new User(1L, "張三", 33)) ;set.add(new User(2L, "李四", 55)) ;

Redis中存儲使用的數據結構：

RSet使用Set集合。與RMap一樣，RSet也支持同步異步方式操作數據。

RFuture<Boolean> f1 = set.addAsync(new User(1L, "張三", 33)) ;RFuture<Boolean> f2 = set.addAsync(new User(2L, "李四", 55)) ;

綁定Lock操作

RSet<User> set = redisson.getSet("user-set") ;RLock lock = set.getLock(new User(1L, "張三", 33)) ;lock.lock() ;try {  // ...} finally {  lock.unlock() ;}

刪除策略

當前的Redis實現沒有設置值刪除功能。因此，過期的數據會被org.redisson.eviction.EvictionScheduler清除。它一次性刪除300個過期條目。如果clean task每次刪除300項，它將每秒執行一次(最小執行延遲)。但如果當前的過期值小于前一個，則執行延遲將增加1.5倍。

RSetCache<User> set = redisson.getSetCache("user-set") ;set.add(new User(3L, "陰陽路", 66), 180L, TimeUnit.SECONDS) ;

事件監聽

與Map一樣Set也有對應的事件監聽，詳細查看Map中對應的說明。

Set排序

基于 Redis 的 Java 分布式 SortedSet 實現了 java.util.SortedSet 接口。該對象線程安全。它使用比較器對元素進行排序并保持唯一性。對于字符串數據類型，建議使用 LexSortedSet 對象，以提高性能。

RSortedSet<Integer> set = redisson.getSortedSet("set-sort") ;// 這里不可以寫成lambda表達式：(o1, o2) -> Integer.compare(o1, o2)set.trySetComparator(new Comparator<Integer>() {  @Override  public int compare(Integer o1, Integer o2) {    return o1 > o2 ? 1 : (o1 < o2 ? -1 : 0)  ;  }}) ;set.add(3) ;set.add(1) ;set.add(2) ;

redis中生成如下2個key：

圖片

set-sort對應的值：

圖片

2.3 List集合

基于 Redis 的 Java 分布式 List 對象實現了 java.util.List 接口。它按插入順序保存元素。它有 Async、Reactive 和 RxJava3 接口。Redis 限制列表大小為 4 294 967 295 個元素。

RList類關系

public interface RList<V> extends List<V>, ... {}

基本操作

RList<User> list = redisson.getList("user-list");User user = new User(1L, "張三", 10);list.add(user) ;User ret = list.get(0) ;System.out.println("ret = " + ret) ;list.remove(user) ;

事件監聽

RList<User> list = redisson.getList("user-list") ;list.addListener(new ExpiredObjectListener() {  @Override  public void onExpired(String name) {    // ...  }}) ;// 其它事件/** * DeletedObjectListener * ListAddListener * ListInsertListener * ListSetListener * ListRemoveListener * ListTrimListener */

2.4 Queue隊列

基于 Redis 的 Java 分布式無界隊列對象，實現了 java.util.Queue 接口。該對象是完全線程安全的。它有 Async、Reactive 和 RxJava3 接口。

RQueue類關系

public interface RQueue<V> extends Queue<V>, ... {}

基本操作

RQueue<User> queue = redisson.getQueue("user-queue");queue.add(new User()) ;// 獲取但不刪除User u1 = queue.peek() ;// 獲取并刪除User u2 = queue.poll() ;

redis使用的數據結構：

圖片

事件監聽

RQueue<User> queue = redisson.getQueue("user-queue") ;queue.addListener(new ExpiredObjectListener() {  @Override  public void onExpired(String name) {    // ...  }}) ;// 其它事件/** * ListAddListener * ListInsertListener * ListRemoveListener */

2.5 阻塞隊列

基于Redis 的Java 分布式無界BlockingQueue對象，實現了 java.util.concurrent.BlockingQueue接口。該對象是完全線程安全的。它有 Async、Reactive 和 RxJava3 接口。

類關系

public interface RBlockingQueue<V> extends BlockingQueue<V>, ... {}

基本操作

RBlockingQueue<User> queue = redisson.getBlockingQueue("user-blockqueue");queue.offer(new User(1L, "哈哈", 22)) ;// queue.offer(new User(2L, "嘿嘿", 33)) ;User u1 = queue.peek() ;User u2 = queue.poll() ;// 這里會被阻塞，最多等待10s隊列中有元素則直接返回User u3 = queue.poll(10, TimeUnit.SECONDS) ;

對應redis使用的數據結構：

圖片

2.6 有界阻塞隊列

大致使用用途上面一致：

RBoundedBlockingQueue<SomeObject> queue = redisson.getBoundedBlockingQueue("user-capacity-queue");// 設置容量大小queue.trySetCapacity(2);queue.offer(new User(1L, "張三", 20));queue.offer(new User(2L, "李四", 10));

Redisson提供了很多分布式的隊列實現，如還有雙端隊列，優先級隊列等，這里就不一一展示了。

本文鏈接：http://www.www897cc.com/showinfo-26-92105-0.html玩轉Redis！非常強大的Redisson分布式集合，少寫60%代碼

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： Python 中 20 個鮮為人知的字符串函數

下一篇：為什么要限流？常見的限流算法有哪些？

標簽：

熱門焦點

鴻蒙OS 4.0公測機型公布：甚至連nova6都支持

華為全新的HarmonyOS 4.0操作系統將于今天下午正式登場，官方在發布會之前也已經正式給出了可升級的機型產品，這意味著這些機型會率先支持升級享用。這次的HarmonyOS 4.0支持
得物效率前端微應用推進過程與思考

一、背景效率工程隨著業務的發展，組織規模的擴大，越來越多的企業開始意識到協作效率對于企業團隊的重要性，甚至是決定其在某個行業競爭中突圍的關鍵，是企業長久生存的根本。得物
十個簡單但很有用的Python裝飾器

裝飾器（Decorators）是Python中一種強大而靈活的功能，用于修改或增強函數或類的行為。裝飾器本質上是一個函數，它接受另一個函數或類作為參數，并返回一個新的函數或類。它們通常用
Python異步IO編程的進程/線程通信實現

這篇文章再講3種方式，同時講4中進程間通信的方式一、 Python 中線程間通信的實現方式共享變量共享變量是多個線程可以共同訪問的變量。在Python中，可以使用threading模塊中的L
猿輔導與新東方的兩種“歸途”

作者｜卓心月出品｜零態LT（ID：LingTai_LT）如何成為一家偉大企業？答案一定是對“勢”的把握，這其中最關鍵的當屬對企業戰略的制定，且能夠站在未來看現在，即使這其中的
大廠卷向扁平化

來源：新熵作者丨南枝編輯丨月見大廠職級不香了。俗話說，兵無常勢，水無常形，互聯網企業調整職級體系并不稀奇。7月13日，淘寶天貓集團啟動了近年來最大的人力制度改革，目前已形成一
當家的盒馬，加速謀生

來源 | 價值星球Planet作者 | 歸去來自己“當家”的盒馬，開始加速謀生了。據盒馬官微消息，盒馬計劃今年開放生鮮供應鏈，將其生鮮商品送往食堂。目前，盒馬在上海已經與
OPPO Reno10 Pro英雄聯盟定制禮盒公布：薩勒芬妮同款配色夢幻十足

5月24日，OPPO推出了全新的OPPO Reno 10系列，包含OPPO Reno10、OPPO Reno10 Pro和OPPO Reno10 Pro+三款新機，全系標配了超光影長焦鏡頭，是迄今為止拍照
外交部：美方應停止在網絡安全問題上不負責任地指責他國

　中國外交部今天（16日）舉行例行記者會。會上，有記者問，美國情報官員稱，他們正在阻攔來自中國以及其他國家的黑客獲取相關科研成果。中方對此有何評論？對此

日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

玩轉Redis！非常強大的Redisson分布式集合，少寫60%代碼

1. 簡介

2. 實戰案例

2.1 Map集合

2.2 Set集合

2.3 List集合

2.4 Queue隊列

2.5 阻塞隊列

2.6 有界阻塞隊列

鴻蒙OS 4.0公測機型公布：甚至連nova6都支持

得物效率前端微應用推進過程與思考

十個簡單但很有用的Python裝飾器

Python異步IO編程的進程/線程通信實現

猿輔導與新東方的兩種“歸途”

大廠卷向扁平化

當家的盒馬，加速謀生

OPPO Reno10 Pro英雄聯盟定制禮盒公布：薩勒芬妮同款配色夢幻十足

外交部：美方應停止在網絡安全問題上不負責任地指責他國

最新推薦

猜你喜歡

熱門推薦

相關資訊