当前位置：首页 > 科技 > 软件

玩转Redis！非常强大的Redisson分布式集合，少写60%代码

来源：责编：时间：2024-06-05 17:39:58 68观看

导读环境：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.28at.com/showinfo-26-92105-0.html玩转Redis！非常强大的Redisson分布式集合，少写60%代码

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇： Python 中 20 个鲜为人知的字符串函数

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

标签：

热门焦点

vivo TWS Air开箱体验：真轻臻好听

在vivo S15系列新机的发布会上，vivo的最新款真无线蓝牙耳机vivo TWS Air也一同发布，本次就这款耳机新品给大家带来一个简单的分享。外包装盒上，vivo TWS Air保持了vivo自家产
女孩租房开2小时空调用完100元电费引热议：5级能耗惹不起月薪过万电费也交不起

近日，江苏苏州一女孩租房当天充值了100元电费，开着空调不到2小时发现电费已用完。对于为什么这个快，房东表示，电表坏了这种情况很多，之前也遇到过，给租客换
一文掌握 Golang 模糊测试（Fuzz Testing）

模糊测试（Fuzz Testing）模糊测试（Fuzz Testing）是通过向目标系统提供非预期的输入并监视异常结果来发现软件漏洞的方法。可以用来发现应用程序、操作系统和网络协议等中的漏洞或
为什么你不应该使用Div作为可点击元素

按钮是为任何网络应用程序提供交互性的最常见方式。但我们经常倾向于使用其他HTML元素，如 div span 等作为 clickable 元素。但通过这样做，我们错过了许多内置浏览器的功能。
猿辅导与新东方的两种“归途”

作者｜卓心月出品｜零态LT（ID：LingTai_LT）如何成为一家伟大企业？答案一定是对“势”的把握，这其中最关键的当属对企业战略的制定，且能够站在未来看现在，即使这其中的
网红炒股不为了赚钱，那就是耍流氓！

来源：首席商业评论6月26日高调宣布入市，网络名嘴大v胡锡进居然进军了股市。在一次财经媒体峰会上，几个财经圈媒体大佬就“胡锡进炒股是否知道认真报道”展开讨论。有
2纳米决战2025

集微网报道从三强争霸到四雄逐鹿，2nm的厮杀声已然隐约传来。无论是老牌劲旅台积电、三星，还是誓言重回先进制程领先地位的英特尔，甚至初成立不久的新
国行版三星Galaxy Z Fold5/Z Flip5发布售价7499元起

2023年8月3日，三星电子举行Galaxy新品中国发布会，正式在国内推出了新一代折叠屏智能手机三星Galaxy Z Fold5与Galaxy Z Flip5，以及三星Galaxy Tab S9
三星Galaxy Z Fold/Flip 5国行售价曝光：最低7499元/12999元起

据官方此前宣布，三星将于7月26日也就是明天在韩国首尔举办Unpacked活动，届时将带来带来包括Galaxy Buds 3、Galaxy Watch 6、Galaxy Tab S9、Galaxy