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

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

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

導讀環境：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.tebozhan.com/showinfo-26-92105-0.html玩轉Redis！非常強大的Redisson分布式集合，少寫60%代碼

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

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

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

標簽：

熱門焦點

盧偉冰長文解析K60至尊版對Redmi有著里程碑式的意義

在今天的Redmi后性能時代戰略發布會結束之后，Redmi總經理盧偉冰又帶來了一篇長文，詳解了為什么 Redmi 要開啟后性能時代？為什么選擇和 MediaTek、Pixelworks 深度合作？以及后性
Raft算法：保障分布式系統共識的穩健之道

1. 什么是Raft算法？Raft 是英文”Reliable、Replicated、Redundant、And Fault-Tolerant”（“可靠、可復制、可冗余、可容錯”）的首字母縮寫。Raft算法是一種用于在分布式系統
如何通過Python線程池實現異步編程？

線程池的概念和基本原理線程池是一種并發處理機制，它可以在程序啟動時創建一組線程，并將它們置于等待任務的狀態。當任務到達時，線程池中的某個線程會被喚醒并執行任務，執行完任
本地生活這塊肥肉，拼多多也想吃一口

出品/壹覽商業作者/李彥編輯/木魚拼多多也看上本地生活這塊蛋糕了。近期，拼多多在App首頁“充值中心”入口上線了本機生活界面。壹覽商業發現，該界面目前主要
花7萬退貨退款無門：誰在縱容淘寶珠寶商家造假？

來源：極點商業作者：楊銘在淘寶購買珠寶玉石后，因為保證金不夠賠付，店鋪關閉，退貨退款難、維權無門的比比皆是。“提供相關產品鑒定證書，支持全國復檢，可以30天無理由退換貨。&
攜眾多高端產品亮相ChinaJoy，小米帶來一場科技與人文的視聽盛宴

7月28日，全球數字娛樂領域最具知名度與影響力的年度盛會中國國際數碼互動娛樂展覽會（簡稱ChinaJoy）在上海新國際博覽中心盛大開幕。作為全球領先的科
疑似小米14外觀設計圖曝光：后置相機模組變化不大

下半年的大幕已經開啟，而誰將成為下半年手機圈的主角就成為了大家關注的焦點，其中被傳有望拿下新一代驍龍8 Gen3旗艦芯片的小米14系列更是備受大家矚
AI芯片初創公司Tenstorrent獲三星和現代1億美元投資

Tenstorrent是一家由芯片行業資深人士Jim Keller領導的加拿大初創公司，專注于開發人工智能芯片，該公司周三表示，已經從現代汽車集團和三星投資基金等
引領旗艦級影像能力向中端機普及 OPPO K11 系列發布 1799 元起

7月25日，OPPO正式發布K系列新品—— OPPO K11 。此次 K11 在中端手機市場長期被忽視的影像板塊發力，突破性地搭載索尼 IMX890 旗艦大底主攝，支持 OIS

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

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

1. 簡介

2. 實戰案例

2.1 Map集合

2.2 Set集合

2.3 List集合

2.4 Queue隊列

2.5 阻塞隊列

2.6 有界阻塞隊列

盧偉冰長文解析K60至尊版對Redmi有著里程碑式的意義

Raft算法：保障分布式系統共識的穩健之道

如何通過Python線程池實現異步編程？

本地生活這塊肥肉，拼多多也想吃一口

花7萬退貨退款無門：誰在縱容淘寶珠寶商家造假？

攜眾多高端產品亮相ChinaJoy，小米帶來一場科技與人文的視聽盛宴

疑似小米14外觀設計圖曝光：后置相機模組變化不大

AI芯片初創公司Tenstorrent獲三星和現代1億美元投資

引領旗艦級影像能力向中端機普及 OPPO K11 系列發布 1799 元起

最新推薦

猜你喜歡

熱門推薦

相關資訊