【实践篇】Redis最强Java客户端(四)之Ression分布式集合使用指南

news2025/1/18 3:48:56

文章目录

  • 0. 前言
  • 1.Ression分布式集合
    • 1.1 分布式列表
      • 1.1.1 使用场景和实现原理：
      • 1.1.2 基本概念和使用方法：
    • 1.2 分布式集合
      • 1.2.1 使用场景和实现原理：
      • 1.2.2 基本概念和使用方法：
    • 1.3 分布式映射
      • 1.3.1 使用场景和实现原理：
      • 1.3.2 基本概念和使用方法：
    • 1.4 分布式有序集合
      • 1.4.1 使用场景和实现原理：
      • 1.4.2 基本概念和使用方法：
    • 1.5 分布式队列
      • 1.5.1 使用场景和实现原理：
      • 1.5.2 基本概念和使用方法：
    • 1.6 分布式双端队列
      • 1.6.1 使用场景和实现原理：
      • 1.6.2 基本概念和使用方法：
    • 1.7 分布式阻塞队列
      • 1.7.1 使用场景和实现原理：
      • 1.7.2 基本概念和使用方法：
  • 2. 完整代码示例
  • 3. 参考资料
  • 4. 源码地址
  • 5. Redis从入门到精通系列文章

在这里插入图片描述

0. 前言

前两章我们了解了《【实践篇】Redis最强Java客户端(一)之Redisson入门介绍》和《【实践篇】Redis最强Java客户端(二)之Redisson基础概念》
本章第四章主要介绍Ression分布式集合使用指南。
上一章《Redisson 7种分布式锁使用指南》回顾。

在这里插入图片描述

本章我们介绍了在Redisson中实现的各种分布式集合，这些集合适应于各种不同类型的使用场景。每个分布式集合的实现原理都基于对应的Redis数据结构。 每种集合的简要总结：

  • 分布式列表：基于Redis的List数据结构，操作简单且原子性强，主要用于日志记录、收藏列表等。

  • 分布式集合：基于Redis的Set数据结构，能够高效地完成添加、删除和查找等操作，适合用于标签系统、好友关系等。

  • 分布式映射：基于Redis的Hash数据结构，即使在处理大量键值对时，也能保持高效的读写性能，适合存储用户信息、配置信息等。

  • 分布式有序集合：基于Redis的Sorted set数据结构，常用于实现需要排序的场景，例如排名系统、时间序列数据等。

  • 分布式队列：基于Redis的List数据结构，满足先进先出（FIFO）规则，适合用于消息队列、任务队列等。

  • 分布式双端队列：同样基于Redis的List数据结构，两端都可以进行入队和出队操作，更具灵活性，适用于实现LRU缓存、多任务调度等。

  • 分布式阻塞队列：也是基于Redis的List数据结构，可以阻塞操作，适合于实现高并发场景下的生产者-消费者模型。

1.Ression分布式集合

1.1 分布式列表

1.1.1 使用场景和实现原理：

Redisson的分布式列表基于Redis的List数据结构，操作简单、原子性强，适合用于实现日志记录、收藏列表等场景。

1.1.2 基本概念和使用方法：

分布式列表是一种有序集合，用户可在列表的任意位置插入或删除元素。以下是在Redisson中创建和操作分布式列表的示例：

RList<String> list = redisson.getList("myList");
list.add("1");
list.add("2");
list.add("3");

1.2 分布式集合

1.2.1 使用场景和实现原理：

Redisson的分布式集合基于Redis的Set数据结构，能高效地完成添加、删除和查找等操作，适合实现标签系统、好友关系等功能。

1.2.2 基本概念和使用方法：

分布式集合是一种无序集合，所有存入其中的元素都是唯一的。以下是在Redisson中创建和操作分布式集合的示例：

RSet<String> set = redisson.getSet("mySet");
set.add("A");
set.add("B");
set.add("C");

1.3 分布式映射

1.3.1 使用场景和实现原理：

Redisson的分布式映射基于Redis的Hash数据结构，即使面对大量键值对，也能保持高效的读写性能，适合存储用户信息、配置信息等数据。

1.3.2 基本概念和使用方法：

分布式映射是一种键值对的集合。以下是在Redisson中创建和操作分布式映射的示例：

RMap<String, Integer> map = redisson.getMap("myMap");
map.put("A", 1);
map.put("B", 2);
map.put("C", 3);

1.4 分布式有序集合

1.4.1 使用场景和实现原理：

分布式有序集合基于Redis的Sorted set数据结构，可以用于实现排名系统、时间序列数据等需要排序的场景。

1.4.2 基本概念和使用方法：

分布式有序集合是一种有序的集合。以下是在Redisson中创建和操作分布式有序集合的示例：

RSortedSet<Integer> sortedSet = redisson.getSortedSet("mySortedSet");
sortedSet.add(3);
sortedSet.add(1);
sortedSet.add(2);

1.5 分布式队列

1.5.1 使用场景和实现原理：

Redisson的分布式队列实现基于Redis的List数据结构，操作简单，适合用于消息队列、任务队列等需要严格按照加入顺序进行处理的场景。

1.5.2 基本概念和使用方法：

分布式队列是一种遵循先进先出（FIFO）原则的数据结构。以下是在Redisson中创建和操作分布式队列的示例：

RQueue<String> queue = redisson.getQueue("myQueue");
queue.add("A");
queue.add("B");
queue.add("C");

1.6 分布式双端队列

1.6.1 使用场景和实现原理：

Redisson的分布式双端队列基于Redis的List数据结构，与分布式队列相比更加灵活，适合实现LRU缓存、多任务调度等场景。

1.6.2 基本概念和使用方法：

分布式双端队列是一种两端都可以进行入队和出队操作的队列。以下是在Redisson中创建和操作分布式双端队列的示例：

RDeque<String> deque = redisson.getDeque("myDeque");
deque.addFirst("D");
deque.addLast("E");
deque.addLast("F");

1.7 分布式阻塞队列

1.7.1 使用场景和实现原理：

分布式阻塞队列基于Redis的List数据结构，支持阻塞操作，适合于实现生产者-消费者模型的高并发场景。

1.7.2 基本概念和使用方法：

分布式阻塞队列是一种支持阻塞操作的队列。以下是在Redisson中创建和操作分布式阻塞队列的示例：

RBlockingQueue<String> blockingQueue = redisson.getBlockingQueue("myBlockingQueue");
blockingQueue.put("G");

2. 完整代码示例

在Controller类中使用Redisson分布式集合

pom.xml配置相应依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.16.3</version>
</dependency>

配置文件(application.yml)：

# application.yml
spring:
  application:
    name: redisson-example-app

redisson:
  config: classpath:redisson.yaml

Redisson的配置文件(redisson.yaml)：

singleServerConfig:
  idleConnectionTimeout: 10000
  connectTimeout: 10000
  timeout: 3000
  retryAttempts: 3
  retryInterval: 1500
  password: null
  subscriptionsPerConnection: 5
  clientName: null
  address: "redis://127.0.0.1:6379"  # adjust this address to your Redis server
  subscriptionConnectionMinimumIdleSize: 1
  subscriptionConnectionPoolSize: 50
  connectionMinimumIdleSize: 24
  connectionPoolSize: 64
  database: 0
  dnsMonitoringInterval: 5000
threads: 0
nettyThreads: 0
codec: !<org.redisson.codec.JsonJacksonCodec> {}
transportMode: "NIO"

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class RedissonExampleApplication {

    public static void main(String[] args) {
        SpringApplication.run(RedissonExampleApplication.class, args);
    }

}

RedissonExampleController

import org.redisson.api.RList;
import org.redisson.api.RSet;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/redisson")
public class RedissonExampleController {

    @Autowired
    private RedissonClient redissonClient;

    @PostMapping("/list")
    public void addToList(@RequestParam String element) {
        RList<String> list = redissonClient.getList("myList");
        list.add(element);
    }

    @GetMapping("/list")
    public RList<String> readFromList() {
        return redissonClient.getList("myList");
    }

    @PostMapping("/set")
    public void addToSet(@RequestParam String element) {
        RSet<String> set = redissonClient.getSet("mySet");
        set.add(element);
    }

    @GetMapping("/set")
    public RSet<String> readFromSet() {
        return redissonClient.getSet("mySet");
    }
}

Service

@Autowired
private RedissonClient redissonClient;

public void listExample() {
RList<String> list = redissonClient.getList("myList");
list.add("1");
list.add("2");
list.add("3");
}

public void setExample() {
RSet<String> set = redissonClient.getSet("mySet");
set.add("A");
set.add("B");
set.add("C");
}

public void mapExample() {
RMap<String, Integer> map = redissonClient.getMap("myMap");
map.put("A", 1);
map.put("B", 2);
map.put("C", 3);
}

public void sortedSetExample() {
RSortedSet<Integer> sortedSet = redissonClient.getSortedSet("mySortedSet");
sortedSet.add(3);
sortedSet.add(1);
sortedSet.add(2);
}

public void queueExample() {
RQueue<String> queue = redissonClient.getQueue("myQueue");
queue.add("A");
queue.add("B");
queue.add("C");
}

public void dequeExample() {
RDeque<String> deque = redissonClient.getDeque("myDeque");
deque.addFirst("D");
deque.addLast("E");
deque.addLast("F");
}

public void blockingQueueExample() throws InterruptedException {
RBlockingQueue<String> blockingQueue = redissonClient.getBlockingQueue("myBlockingQueue");
blockingQueue.put("G");
}

3. 参考资料

  1. Redisson官方网站：https://redisson.org/

  2. Redisson GitHub仓库：https://github.com/redisson/redisson

  3. redisson 参考文档 https://redisson.org/documentation.html

4. 源码地址

https://github.com/wangshuai67/icepip-springboot-action-examples
https://github.com/wangshuai67/Redis-Tutorial-2023

5. Redis从入门到精通系列文章

  • 《【Redis实践篇】使用Redisson 优雅实现项目实践过程中的5种场景》
  • 《Redis使用Lua脚本和Redisson来保证库存扣减中的原子性和一致性》
  • 《SpringBoot Redis 使用Lettuce和Jedis配置哨兵模式》
  • 《Redis【应用篇】之RedisTemplate基本操作》
  • 《Redis 从入门到精通【实践篇】之SpringBoot配置Redis多数据源》
  • 《Redis 从入门到精通【进阶篇】之三分钟了解Redis HyperLogLog 数据结构》
  • 《Redis 从入门到精通【进阶篇】之三分钟了解Redis地理位置数据结构GeoHash》
  • 《Redis 从入门到精通【进阶篇】之高可用哨兵机制(Redis Sentinel)详解》
  • 《Redis 从入门到精通【进阶篇】之redis主从复制详解》
  • 《Redis 从入门到精通【进阶篇】之Redis事务详解》
  • 《Redis从入门到精通【进阶篇】之对象机制详解》
  • 《Redis从入门到精通【进阶篇】之消息传递发布订阅模式详解》
  • 《Redis从入门到精通【进阶篇】之持久化 AOF详解》
  • 《Redis从入门到精通【进阶篇】之持久化RDB详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构字典(Dictionary)详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构快表QuickList详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构简单动态字符串(SDS)详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构压缩列表(ZipList)详解》
  • 《Redis从入门到精通【进阶篇】之数据类型Stream详解和使用示例》
    在这里插入图片描述大家好，我是冰点，今天的【实践篇】Redis最强Java客户端(四)之Ression分布式集合使用指南。如果你有疑问或见解可以在评论区留言。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/997860.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

CSS三种样式表、样式表优先级、CSS选择器

CSS三种样式表、样式表优先级、CSS选择器

一、CSS介绍&#xff1a; 1.1、CSS介绍&#xff1a; CSS&#xff0c;全称是&#xff1a;Cascading Style Sheets&#xff0c;层叠样式表&#xff0c;用于修饰HTML页面的。 CSS编写规则如下所示&#xff1a; CSS编写的规则分为两部分&#xff0c;分别是&#xff1a;选择器、声…
阅读更多...
SpringMVC学习简要

SpringMVC学习简要

学习资料&#xff1a; SpringMVC-03-入门案例工作流程解析_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV1ZF411G7eP/?p3&spm_id_frompageDriver&vd_source4ac53f52a57eb96a3c8406b971b038ae 常用MYSQL命令&#xff1a;http://t.csdn.cn/zshCP 学习要求 什么是…
阅读更多...
微信小程序Day4笔记

微信小程序Day4笔记

1. 组件的创建与引用 创建组件 在项目的根目录中&#xff0c;鼠标右键&#xff0c;创建components -> test文件夹在新建的test文件夹上&#xff0c;鼠标右键&#xff0c;点击新建Component键入组件的名称之后回车&#xff0c;会自动生成组件对应的4个文件&#xff0c;后缀…
阅读更多...
《服务器无状态设计：为什么如何实现无状态API？》

《服务器无状态设计：为什么如何实现无状态API？》

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
3.1 栈和队列的定义和特点

3.1 栈和队列的定义和特点

3.1.1 栈的定义和特点 主要内容&#xff1a; 3.1 栈和队列的定义和特点 3.1.1 栈的定义和特点 定义&#xff1a; 栈是一种特殊的线性表&#xff0c;只允许在一端进行插入或删除操作。这一端被称为栈顶&#xff0c;而另一端则称为栈底。不包含任何元素的栈被称为空栈。 特点…
阅读更多...
分布式调度 Elastic-job

分布式调度 Elastic-job

分布式调度 Elastic-job 1.概述 1.1什么是任务调度 我们可以思考一下下面业务场景的解决方案: 某电商平台需要每天上午10点&#xff0c;下午3点&#xff0c;晚上8点发放一批优惠券某银行系统需要在信用卡到期还款日的前三天进行短信提醒某财务系统需要在每天凌晨0:10分结算…
阅读更多...
Java虚拟机（JVM）解析：内存区域、类加载、垃圾回收和选型考虑

Java虚拟机（JVM）解析：内存区域、类加载、垃圾回收和选型考虑

目录 一、JVM内存区域划分 二、JVM类加载 三、JVM垃圾回收&#xff08;GC&#xff09; 一、JVM内存区域划分 栈堆方法区(元数据区)程序计数器 1.栈 举个例子&#xff1a; 那具体是怎么分的呢&#xff1f;如下图 本地方法栈&#xff1a;给JVM内部的方法准备的栈空间 虚拟…
阅读更多...
在MySQL客户端使用Tab健进行命令补全

在MySQL客户端使用Tab健进行命令补全

在MySQL客户端中&#xff0c;你可以使用Tab键进行命令补全&#xff0c;这将提高我们的效率&#xff0c;这与Linux命令行中的行为类似。例如&#xff0c;如果你输入SEL然后按Tab键&#xff0c;MySQL客户端会自动补全为SELECT。 然而&#xff0c;需要注意的是&#xff0c;这个功能…
阅读更多...
数据结构 - 栈

数据结构 - 栈

目录 二、栈的实现 1.数组模拟实现栈 设计思想: 方法实现: Peek(): 偷窥栈顶元素 pop(): 栈顶出栈 push(): 2.链表模拟实现 3 . 栈的继承体系 总结 前言 大家好,这篇博客带大家了解一下栈是什么? 并且用两种方式为大家实现一下栈 一、栈是什么&#xff1f; 栈是一种数…
阅读更多...
npm介绍

npm介绍

npm介绍 npm&#xff08;Node Package Manager的缩写&#xff09;是一个软件包管理器&#xff0c;主要进行JavaScript的包管理。通过npm&#xff0c;我们可以很方便地进行JavaScript包的下载、升级&#xff0c;我们也可以把我们开发的JavaScript包共享给其他使用者。 在npm没…
阅读更多...
大数据-玩转数据-Flink状态后端（下）

大数据-玩转数据-Flink状态后端（下）

一、状态后端 每传入一条数据&#xff0c;有状态的算子任务都会读取和更新状态。由于有效的状态访问对于处理数据的低延迟至关重要&#xff0c;因此每个并行任务(子任务)都会在本地维护其状态&#xff0c;以确保快速的状态访问。 状态的存储、访问以及维护&#xff0c;由一个…
阅读更多...
goweb入门

goweb入门

创建gomod项目 go mod init web01新建main.go package mainimport ("fmt""net/http" )func handler(writer http.ResponseWriter, request *http.Request) {fmt.Fprintf(writer, "Hello World,%s!", request.URL.Path[1:]) } func main() {fmt…
阅读更多...
Mysql基于成本选择索引

Mysql基于成本选择索引

本篇文章介绍mysql基于成本选择索引的行为&#xff0c;解释为什么有时候明明可以走索引&#xff0c;但mysql却没有走索引的原因 mysql索引失效的场景大致有几种 不符合最左前缀原则在索引列上使用函数或隐式类型转换使用like查询&#xff0c;如 %xxx回表代价太大索引列区分度过…
阅读更多...
PHP8中获取并删除数组中最后一个元素-PHP8知识详解

PHP8中获取并删除数组中最后一个元素-PHP8知识详解

在php8中&#xff0c;array_pop()函数将返回数组的最后一个元素&#xff0c;并且将该元素从数组中删除。语法格式如下&#xff1a; array_pop(目标数组) 获取并删除数组中最后一个元素&#xff0c;参考代码&#xff1a; <?php $stu array(s001>明明,s002>亮亮,s…
阅读更多...
Ansible数组同步至Shell脚本数组中

Ansible数组同步至Shell脚本数组中

1、ansible中定义数组&#xff0c;我以 ccaPojectList 数组为例子,如下图数组内容 2、需要写一个j2模板的Shell脚本&#xff0c;在j2模板的Shell脚本中引用ansible的 ccaPojectList 数组&#xff0c;大致如下图&#xff1a; {% for item in ccaPojectList %} "{{ item }…
阅读更多...
Linux JAVA环境的搭建tomcat的部署（含多实例）

Linux JAVA环境的搭建tomcat的部署（含多实例）

tomcat tomcat是Apache软件基金会项目中的一个核心项目由 Apache、Sun 和其他一些公司及个人共同开发而成。tomcat 是 Java 语言开发的&#xff0c;Tomcat 服务器是一个免费的开放源代码的 Web 应用服务器. tomcat的组成 tomcat用于支持Java Servlet和JSP。它是一个重要的We…
阅读更多...
手动开发-简单的Spring基于注解配置的程序--源码解析

手动开发-简单的Spring基于注解配置的程序--源码解析

文章目录 设计注解$设计容器 $#完整代码# 在前文中 《手动开发-简单的Spring基于XML配置的程序–源码解析》&#xff0c;我们是从XML配置文件中去读取bean对象信息&#xff0c;再在自己设计的容器中进行初始化&#xff0c;属性注入&#xff0c;最后通过getBean()方法进行返回。…
阅读更多...
Service Mesh目的：是解决系统架构微服务化后的服务间通信和治理问题。

Service Mesh目的：是解决系统架构微服务化后的服务间通信和治理问题。

参考链接&#xff1a;https://www.zhihu.com/tardis/bd/art/397945267?source_id1001 1、Service Mesh 是什么 Service Mesh的定义&#xff1a; 服务网格是一个基础设施层&#xff0c;用于处理服务间通信。云原生应用有着复杂的服务拓扑&#xff0c;服务网格保证请求在这些…
阅读更多...
Docker：01 OverView

Docker：01 OverView

Docker&#xff1a;01 OverView 基本介绍 Docker是一个用于开发、交付、运行应用程序的开放平台&#xff0c;可以使应用程序与基础架构分开&#xff0c;以便快速交付软件。 Docker在一个被叫做容器的隔离环境下&#xff0c;提供了打包和运行的能力。 容器非常轻量化&#x…
阅读更多...
[SICTF 2023] webmisc

[SICTF 2023] webmisc

文章目录 webBaby_PHP涉及知识点 我全都要RCE你能跟得上我的speed吗 miscPixel_art攻破这个压缩包&#xff01; web Baby_PHP 涉及知识点 php解析特性apache换行解析漏洞无参RCE 源代码 <?php highlight_file(__FILE__); error_reporting(0);$query $_SERVER[QUERY_ST…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023