Redisson 框架详解

目录

一.为什么要使用分布式锁？

二.Redisson 的基本使用：

1.添加 Redisson 依赖：

2.在 application.yml 配置 Redis：

3. 创建 Redisson 客户端：

（1）单节点模式：

（2）集群模式：

4.注入RedissonClient：

5.使用 Redisson 存储和获取值：

三.配置集群连接池：

1. Redisson 集群连接池配置项：

2. 配置 Redis 集群的连接池：

四.如何在Boot项目中使用Redission实现分布式锁？

1.引入 Redisson 依赖：

 2.配置 Redisson：

3.在 Spring Boot 中注入 RedissonClient：

4.使用分布式锁：

Redisson 是一个基于 Redis 的高效 Java 客户端，封装了 Redis 的大部分功能，提供了更为丰富和高效的操作接口，能够帮助开发者更便捷地进行分布式缓存、分布式锁、分布式集合等操作。它不仅支持 Redis 的基本操作，还提供了更多的高级功能，如分布式锁、分布式集合、分布式计数器等，可以大大简化分布式应用的开发。

一.为什么要使用分布式锁？

分布式锁是解决 分布式系统中的资源竞争问题 的一种有效机制。在高并发分布式系统中，多个服务节点可能同时访问同一资源（如数据库、文件系统等）。这种竞争可能导致数据的不一致性、重复操作、死锁等问题，因此，使用分布式锁来保证同一时刻只有一个节点能够访问共享资源，从而确保系统的正确性和稳定性。

在单机系统中，当多个线程访问共享资源时，操作系统通常使用互斥锁（如 Java 中的 synchronized 或 ReentrantLock）来保证同一时刻只有一个线程能访问该资源。而在分布式系统中，资源通常分布在多个服务实例或节点上，单纯的本地锁（如 synchronized）无法跨节点进行协调，因此需要分布式锁来确保不同节点间的同步。

使用分布式锁的方式：

  • 所有节点都尝试获取锁，如果一个节点获得了锁，它将执行任务。
  • 其他节点则会等待或者跳过执行该任务，避免重复执行。

使用场景：

  1. 防止多次执行相同的任务
  2. 确保分布式系统中资源的独占访问
  3. 控制并发数量

二.Redisson 的基本使用：

1.添加 Redisson 依赖：

在项目中使用 Redisson，首先需要添加 Redisson 的 Maven 依赖：

<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.1</version> <!-- 请根据最新版本替换 -->
</dependency>

2.在 application.yml 配置 Redis：

# 单节点
redisson:address: redis://127.0.0.1:6379
# 集群
redisson:cluster:addresses: - redis://127.0.0.1:7000- redis://127.0.0.1:7001- redis://127.0.0.1:7002

3. 创建 Redisson 客户端：

Redisson 提供了两种方式来创建客户端：单节点模式 和 集群模式。

（1）单节点模式：

在单节点模式下，我们只需要连接到一个 Redis 实例，在配置类中：

import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.redisson.Redisson;@Configuration
public class RedissonConfig {@Beanpublic RedissonClient redissonClient() {// 配置单节点 RedisConfig config = new Config();SingleServerConfig serverConfig = config.useSingleServer();serverConfig.setAddress("redis://127.0.0.1:6379");serverConfig.setPassword("yourpassword");return Redisson.create(config);}
}

（2）集群模式：

import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.ClusterServersConfig;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.redisson.Redisson;import java.util.List;@Configuration
public class RedissonClusterConfig {// 从配置文件中读取 Redis 集群的地址@Value("${redisson.cluster.addresses}")private List<String> clusterAddresses;@Beanpublic RedissonClient redissonClient() {// 创建 Redis 配置对象Config config = new Config();// 配置集群ClusterServersConfig clusterConfig = config.useClusterServers();// 添加集群节点地址for (String address : clusterAddresses) {clusterConfig.addNodeAddress(address);}// 如果需要配置密码，使用 setPassword 方法// clusterConfig.setPassword("yourpassword");// 创建并返回 Redisson 客户端return Redisson.create(config);}
}

4.注入RedissonClient：

通过 @Autowired 注入 RedissonClient 到需要使用的服务类中。

import org.redisson.api.RedissonClient;
import org.redisson.api.RMap;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class RedisService {@Autowiredprivate RedissonClient redissonClient;public void demoMapUsage() {// 获取 Redis 集群中的分布式 MapRMap<String, String> map = redissonClient.getMap("myMap");map.put("name", "Alice");map.put("age", "30");System.out.println("Name: " + map.get("name"));System.out.println("Age: " + map.get("age"));}
}

5.使用 Redisson 存储和获取值：

RBucket<String> 是 Redisson 提供的一个接口，它代表 Redis 中一个字符串类型的值。我们可以通过它来存储和获取一个键值对。

import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class RedisService {@Autowiredprivate RedissonClient redissonClient;// 存储值public void setValue(String key, String value) {RBucket<String> bucket = redissonClient.getBucket(key); // 获取 Redis 中的指定 keybucket.set(value);  // 存储值}// 获取值public String getValue(String key) {RBucket<String> bucket = redissonClient.getBucket(key); // 获取 Redis 中的指定 keyreturn bucket.get(); // 获取存储的值}
}

三.配置集群连接池：

在使用 Redisson 配置 Redis 集群时，我们可以通过配置连接池来管理连接的数量、连接的超时时间等。Redisson 提供了灵活的配置方式来定制集群模式的连接池。

1. Redisson 集群连接池配置项：

Redisson 提供了多个与连接池相关的配置项，主要包括以下几个：

  • masterConnectionPoolSize：主节点连接池的大小（连接数量）。
  • slaveConnectionPoolSize：从节点连接池的大小（连接数量）。
  • connectionMinimumIdleSize：连接池中保持的最小空闲连接数。
  • connectionPoolSize：连接池的最大连接数。
  • idleConnectionTimeout：空闲连接的超时时间。
  • connectTimeout：连接的超时时间。
  • timeout：操作超时时间（请求的最大等待时间）。

2. 配置 Redis 集群的连接池：

在 application.yml 中配置连接池参数：

redisson:cluster:addresses: - redis://127.0.0.1:7000- redis://127.0.0.1:7001- redis://127.0.0.1:7002# 集群连接池配置master-connection-pool-size: 100      # 主节点连接池大小slave-connection-pool-size: 50       # 从节点连接池大小connection-pool-size: 200            # 总连接池大小connection-minimum-idle-size: 10     # 最小空闲连接数idle-connection-timeout: 10000       # 空闲连接超时connect-timeout: 3000                # 连接超时timeout: 5000                        # 请求超时

配置连接池是确保 Redis 集群高效运行的关键，它能够有效管理连接的数量，提高 Redis 的性能，避免频繁地创建和销毁连接。

如果我们在 application.yml 或 application.properties 文件中配置了 Redisson 的连接池参数，并且使用了 redisson-spring-boot-starter，Spring Boot 会自动读取这些配置并初始化连接池。

四.如何在Boot项目中使用Redission实现分布式锁？

在 Spring Boot 项目中使用 Redisson 实现分布式锁，主要涉及到以下几个步骤：

  1. 引入 Redisson 依赖
  2. 配置 Redisson 客户端
  3. 在 Spring Boot 中注入 RedissonClient
  4. 使用分布式锁

1.引入 Redisson 依赖：

<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.16.1</version> <!-- 请根据最新版本替换 -->
</dependency>

 2.配置 Redisson：

redisson:# Redis 集群配置cluster:# 集群节点地址，多个节点地址用逗号分隔nodes:- redis://127.0.0.1:7000- redis://127.0.0.1:7001- redis://127.0.0.1:7002- redis://127.0.0.1:7003- redis://127.0.0.1:7004- redis://127.0.0.1:7005# Redis 密码（如果有密码的话）password: yourpassword  # Redis 的密码# 连接池配置connection-pool-size: 100            # 连接池大小connection-minimum-idle-size: 10     # 最小空闲连接数idle-connection-timeout: 10000       # 空闲连接超时（毫秒）connect-timeout: 3000                # 连接超时（毫秒）timeout: 5000                        # 请求超时（毫秒）retries: 3                           # 在获取连接时的最大重试次数retry-interval: 1000                 # Redis 集群模式下的超时时间wait-timeout: 3000                   # 最大等待连接的时间（毫秒）subscription-mode: false             # 集群模式下是否启用超时管理threads: 16                          # 线程池大小

3.在 Spring Boot 中注入 RedissonClient：

在 Spring Boot 中，我们可以通过 @Autowired 注入 RedissonClient，然后在服务类中使用它进行 Redis 操作。

import org.redisson.api.RLock;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.concurrent.TimeUnit;@Service
public class RedisWithLockService {@Autowiredprivate RedissonClient redissonClient;// 锁的名称private static final String LOCK_KEY = "myLock";// 存储到 Redis 中的键private static final String REDIS_KEY = "userBalance";// 分布式锁处理业务逻辑public void updateBalance(String userId, double newBalance) {// 获取分布式锁RLock lock = redissonClient.getLock(LOCK_KEY);try {// 尝试获取锁，最多等待 10 秒，锁自动释放时间为 30 秒if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {// 锁获取成功，执行 Redis 操作System.out.println("Lock acquired, updating balance...");// 获取当前用户的余额double currentBalance = getUserBalanceFromRedis(userId);System.out.println("Current balance: " + currentBalance);// 更新余额（模拟业务逻辑）double updatedBalance = currentBalance + newBalance;System.out.println("Updated balance: " + updatedBalance);// 将新的余额存储回 RedissetUserBalanceToRedis(userId, updatedBalance);} else {System.out.println("Unable to acquire lock for updating balance.");}} catch (InterruptedException e) {e.printStackTrace();} finally {// 确保释放锁if (lock.isHeldByCurrentThread()) {lock.unlock();}}}// 获取用户余额（从 Redis 中）private double getUserBalanceFromRedis(String userId) {RBucket<Double> bucket = redissonClient.getBucket(REDIS_KEY + ":" + userId);return bucket.isExists() ? bucket.get() : 0.0; // 如果值存在则获取，如果没有则返回 0}// 更新用户余额（存入 Redis）private void setUserBalanceToRedis(String userId, double balance) {RBucket<Double> bucket = redissonClient.getBucket(REDIS_KEY + ":" + userId);bucket.set(balance);  // 存储新的余额}
}

4.使用分布式锁：

在 RedisLockService 中定义了 processWithDistributedLock 方法，调用时，Redisson 将确保在同一时刻只有一个进程/线程可以进入锁的保护区域。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;@RestController
public class RedisWithLockController {@Autowiredprivate RedisWithLockService redisWithLockService;// 模拟调用分布式锁更新用户余额的接口@GetMapping("/updateBalance")public String updateBalance(@RequestParam String userId, @RequestParam double amount) {redisWithLockService.updateBalance(userId, amount);return "Balance update request received for user: " + userId;}
}

通过访问下面接口地址：

http://localhost:8080/updateBalance?userId=user1&amount=100

 查看后端返回数据。

总结：

  • Redisson 提供了丰富的 API 用于存储和获取 Redis 中的值。你可以通过 RBucket 等数据结构操作 Redis 中的数据。
  • 使用 分布式锁 可以确保在多个服务实例之间协调对共享资源（如 Redis 中的数据）的访问。
  • Redisson 的分布式锁非常适合用来保护 Redis 中的临界资源，避免高并发访问导致的数据不一致问题。

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

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

相关文章

Facebook 上的社群文化：连接与共享

Facebook 上的社群文化：连接与共享

随着社交媒体的普及&#xff0c;Facebook作为全球最大的社交平台之一&#xff0c;不仅改变了人们的沟通方式&#xff0c;还塑造了独特的社群文化。在Facebook上&#xff0c;用户可以轻松地与朋友、家人保持联系&#xff0c;同时也能加入兴趣相投的群组、参与讨论和共享内容。社…
阅读更多...
语言模型的革命：大型概念模型（LCM）的崛起

语言模型的革命：大型概念模型（LCM）的崛起

在人工智能领域&#xff0c;Meta最近推出的一项重大突破正在引起研究人员和开发者的广泛关注&#xff1a;大型概念模型&#xff08;Large Concept Models&#xff0c;简称LCM&#xff09;。这一创新彻底改变了我们对语言模型的理解&#xff0c;并为未来AI技术的进展指明了新的方…
阅读更多...
Python Polars快速入门指南：LazyFrames

Python Polars快速入门指南：LazyFrames

前文已经介绍了Polars的Dataframe, Contexts 和 Expressions&#xff0c;本文继续介绍Polars的惰性API。惰性API是该库最强大的功能之一&#xff0c;使用惰性API可以设定一系列操作&#xff0c;而无需立即运行它们。相反&#xff0c;这些操作被保存为计算图&#xff0c;只在必要…
阅读更多...
C# 读取多种CAN报文文件转换成统一格式数据，工具类：CanMsgRead

C# 读取多种CAN报文文件转换成统一格式数据，工具类：CanMsgRead

因为经常有读取CAN报文trace文件的需求&#xff0c;而且因为CAN卡不同、记录软件不同会导致CAN报文trace文件的格式都有差异。为了方便自己后续开发&#xff0c;我写了一个CanMsgRead工具类&#xff0c;只要提供CAN报文路径和CAN报文格式的选项即可将文件迅速读取转换为统一的C…
阅读更多...
Redis 多机功能 — 复制、Sentinel及集群

Redis 多机功能 — 复制、Sentinel及集群

Redis 的复制功能通过主从模式实现&#xff0c;允许用户为存储着目标数据库的服务器&#xff08;主服务&#xff09;创建多个拥有相同数据库副本的服务器&#xff08;从服务&#xff09;。让客户端的读请求可以分摊到从服务器中&#xff0c;从而提升性能。复制功能适合对数据一…
阅读更多...
计算机网络 （14）数字传输系统

计算机网络 （14）数字传输系统

一、定义与原理 数字传输系统&#xff0c;顾名思义&#xff0c;是一种将连续变化的模拟信号转换为离散的数字信号&#xff0c;并通过适当的传输媒介进行传递的系统。在数字传输系统中&#xff0c;信息被编码成一系列的二进制数字&#xff0c;即0和1&#xff0c;这些数字序列能够…
阅读更多...
leecode377.组合总和IV

leecode377.组合总和IV

本题其实是多重背包问题&#xff0c;对于价值和重量都是nums[i]的的物品&#xff0c;求装满这个容量为4的背包共有多少种排列方式 如果是组合问题&#xff0c;那么遍历顺序是先物品后背包&#xff0c;这样能保证物品按从小到大顺序依次放置&#xff0c;对于实例1求出来为4&…
阅读更多...
【学生管理系统】element ui级联菜单bug

【学生管理系统】element ui级联菜单bug

级联后端 通过父id来进行查询 GetMapping("/{parentId}")public BaseResult findAllByParentId(PathVariable("parentId") String parentId){//1 根据父id查询所有城市QueryWrapper<TbCity> queryWrapper new QueryWrapper<>();queryWrapper.…
阅读更多...
第十七周：Fast R-CNN论文阅读

第十七周：Fast R-CNN论文阅读

Fast R-CNN论文阅读 摘要Abstract文章简介1. 引言2. Fast R-CNN框架2.1 RoI位置信息映射2.2 RoI pooling2.3 分类器与边界框回归器2.4 以VGG16为backbone的Fast RCNN的网络结构 3. 训练细节3.1 采样3.2 多任务损失 4. 优缺点分析总结 摘要 这篇博客介绍了Fast R-CNN&#xff0…
阅读更多...
Python爬虫（二）- Requests 高级使用教程

Python爬虫（二）- Requests 高级使用教程

文章目录 前言一、Session 对象1. 简介2. 跨请求保持 Cookie3. 设置缺省数据4. 方法级别参数不被跨请求保持5. 会话作为上下文管理器6. 移除字典参数中的值 二、请求与响应1. 请求与响应对象1.1 获取响应头信息1.2 获取发送到服务器的请求头信息 三、SSL 证书验证1. 忽略 SSL 证…
阅读更多...
Java-38 深入浅出 Spring - AOP切面增强 核心概念 相关术语 Proxy配置

Java-38 深入浅出 Spring - AOP切面增强 核心概念 相关术语 Proxy配置

点一下关注吧&#xff01;&#xff01;&#xff01;非常感谢&#xff01;&#xff01;持续更新&#xff01;&#xff01;&#xff01; 大数据篇正在更新&#xff01;https://blog.csdn.net/w776341482/category_12713819.html 目前已经更新到了&#xff1a; MyBatis&#xff…
阅读更多...
【算法】复杂性理论初步

【算法】复杂性理论初步

六、算法复杂性初步 重要的复杂性类 P P P 的定义 多项式时间内可解的问题 若 L ∈ P L∈P L∈P&#xff0c;则存在确定性多项式时间的图灵机 M M M&#xff0c;使得 M ( x ) 1 ⟺ x ∈ L M(x)1⟺x∈L M(x)1⟺x∈L N P NP NP 的定义 多项式时间内可验证验证解的正确性 &…
阅读更多...
hive中的四种排序类型

hive中的四种排序类型

1、Order by 全局排序 ASC&#xff08;ascend&#xff09;: 升序&#xff08;默认&#xff09; DESC&#xff08;descend&#xff09;: 降序 注意 &#xff1a;只有一个 Reducer,即使我们在设置set reducer的数量为多个,但是在执行了order by语句之后,当前此次的运算还是只有…
阅读更多...
Mysql(MGR)和ProxySQL搭建部署-Docker版本

Mysql(MGR)和ProxySQL搭建部署-Docker版本

项目路径&#xff1a;D:\study\backend\mysql\mgr 一、Mysql(MGR) 1.1 docker-compose.yaml volumes: # MySQL配置文件目录 - "./mysql-1/conf.d/my.cnf:/etc/mysql/my.cnf" # MySQL工作目录 - "./mysql-1/data:/var/lib/mysql" …
阅读更多...
智能工厂的设计软件 应用场景的一个例子：为AI聊天工具添加一个知识系统 之1

智能工厂的设计软件 应用场景的一个例子：为AI聊天工具添加一个知识系统 之1

本文要点 这一次我们先把抛开前面对“智能工厂的软件设计”的考虑--其软件智能 产品就是 应用程序。直接看看应用程序。例如&#xff0c;在现在各种AI聊天工具层出不穷的今天&#xff0c;我觉得特别需要一个通用的AI聊天工具的图形界面能够为每个聊天者&#xff08;或一个利益…
阅读更多...
科技快讯 | 水滴筹成为民政部指定个人求助网络服务平台；小米超级小爱首次向正式版用户开放；腾讯发布全球首个重症医疗大模型

科技快讯 | 水滴筹成为民政部指定个人求助网络服务平台；小米超级小爱首次向正式版用户开放；腾讯发布全球首个重症医疗大模型

本地 AI 开发利器&#xff0c;初探微软 Win11 AI Dev Gallery 功能 12月27日&#xff0c;科技媒体Windows Latest报道&#xff0c;微软推出AI Dev Gallery功能&#xff0c;助力开发者集成端侧AI。该功能支持Windows 10/11&#xff0c;提供25个示例模型&#xff0c;涵盖多领域。…
阅读更多...
python爬虫----爬取视频实战

python爬虫----爬取视频实战

python爬虫-爬取视频 本次爬取&#xff0c;还是运用的是requests方法 首先进入此网站中&#xff0c;选取你想要爬取的视频&#xff0c;进入视频页面&#xff0c;按F12&#xff0c;将网络中的名称栏向上拉找到第一个并点击&#xff0c;可以在标头中&#xff0c;找到后续我们想要…
阅读更多...
大数据面试笔试宝典之Flink面试

大数据面试笔试宝典之Flink面试

1.Flink 是如何支持批流一体的？ F link 通过一个底层引擎同时支持流处理和批处理. 在流处理引擎之上，F link 有以下机制： 1）检查点机制和状态机制：用于实现容错、有状态的处理; 2）水印机制：用于实现事件时钟; 3）窗口和触发器：用于限制计算范围，并定义呈现结果的…
阅读更多...
AR 模型的功率谱

AR 模型的功率谱

功率谱密度&#xff08;Power Spectral Density, PSD&#xff09;的表达式是从信号的自相关函数和系统的频率响应推导出来的&#xff0c;特别是对于 AR&#xff08;Auto-Regressive&#xff0c;自回归&#xff09;模型。以下是推导的过程&#xff1a; 1. AR 模型的定义&#xf…
阅读更多...
leetcode------mysql

leetcode------mysql

177. 第N高的薪水 - 力扣&#xff08;LeetCode&#xff09; 表: Employee ------------------- | Column Name | Type | ------------------- | id | int | | salary | int | ------------------- 在 SQL 中&#xff0c;id 是该表的主键。 该表的每一行都包含…
阅读更多...
最新文章

Copyright @ 2022~2023