重学SpringBoot3-集成Redis(四)之Redisson

更多SpringBoot3内容请关注我的专栏:《SpringBoot3》
期待您的点赞👍收藏⭐评论✍

重学SpringBoot3-集成Redis(四)之Redisson

  • 1. 添加 Redisson 依赖
  • 2. 配置 Redisson 客户端
  • 3. 使用 Redisson 实现分布式锁
  • 4. 调用分布式锁
  • 5. 为什么使用Redisson分布式锁
  • 6. 常见问题
  • 7. 总结

在 Spring Boot 3 中,整合 Redisson 实现分布式锁可以有效地解决分布式环境下的并发问题。Redisson 是 Redis 官方推荐的客户端,它提供了丰富的分布式对象和高级功能,包括分布式锁的实现。下面介绍如何使用 Spring Boot 3 和 Redisson 来实现分布式锁的功能。

1. 添加 Redisson 依赖

首先,需要在 pom.xml 中添加 Redisson 的依赖,并确保已经引入了 Spring Boot 和 Redis 的相关依赖:

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.23.4</version></dependency>

2. 配置 Redisson 客户端

RedissonProperties

application.yml 文件中,配置 Redis 的连接信息,此例以单机版 Redis 为例。config: 后面跟着一个管道符 (|),表示一个多行字符串,也就是一个整体。

spring:redis:redisson:config: |singleServerConfig:address: redis://localhost:6379    # Redis 连接地址,前缀为 redis://password: 			             # 如果 Redis 需要密码认证,则填写密码timeout: 3000                      # 命令执行超时时间(毫秒)

如果使用的是 Redis 集群则需要修改为如下配置:

spring:redis:redisson: config: |clusterServersConfig:password: nodeAddresses:- redis://127.0.0.1:6379- redis://127.0.0.2:6379- redis://127.0.0.3:6379

接着,在配置类中初始化 Redisson 客户端。

package com.coderjia.boot310redis.config;import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.spring.starter.RedissonProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @author CoderJia* @create 2024/10/5 下午 04:53* @Description**/
@Configuration
public class RedissonConfig {@Autowiredprivate RedissonProperties redissonProperties;@Beanpublic RedissonClient redissonClient() throws Exception{Config config = Config.fromYAML(redissonProperties.getConfig());Redisson.create(config);System.out.println("Redisson 已启动");return Redisson.create(config);}}

3. 使用 Redisson 实现分布式锁

通过 RedissonClient,我们可以使用分布式锁功能。下面是一个简单的示例,展示如何使用 Redisson 实现分布式锁。

package com.coderjia.boot310redis.service;import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Service;import java.util.concurrent.TimeUnit;/*** @author CoderJia* @create 2024/10/5 下午 05:14* @Description**/
@Service
public class LockService {private final RedissonClient redissonClient;public LockService(RedissonClient redissonClient) {this.redissonClient = redissonClient;}public void doSomethingWithLock() {// 获取锁对象RLock lock = redissonClient.getLock("myLock");try {// 尝试获取锁,等待时间 100ms,锁定时间 10秒if (lock.tryLock(100, 10, TimeUnit.SECONDS)) {try {// 加锁成功,执行业务逻辑System.out.println("锁定成功,正在执行关键任务...");Thread.sleep(5000);  // 模拟任务执行} finally {// 释放锁lock.unlock();System.out.println("任务完成,已释放锁");}} else {System.out.println("无法获取锁,其他线程正在执行该任务");}} catch (InterruptedException e) {System.out.println(e.getMessage());}}
}

4. 调用分布式锁

在你的业务逻辑中调用上面创建的 LockService 方法。

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class LockController {private final LockService lockService;public LockController(LockService lockService) {this.lockService = lockService;}@GetMapping("/test-lock")public String testLock() {lockService.doSomethingWithLock();return "分布式锁测试完成";}
}

调用 curl "http://localhost:8080/test-lock?id=A" 接口,进入分布式锁执行逻辑。

单线程情况

开启两个线程,同时调用 curl "http://localhost:8080/test-lock?id=A"curl "http://localhost:8080/test-lock?id=B",可以看到先执行的线程占用了锁,第二个线程要等第一个线程释放锁之后才能重新获得锁。

多线程情况

详细说明

  1. RLock:这是 Redisson 提供的分布式锁对象。通过 RedissonClient.getLock() 方法可以获取到一个分布式锁。

  2. tryLock(long waitTime, long leaseTime, TimeUnit unit):此方法尝试获取锁,其中:

    • waitTime 是最大等待时间,表示在该时间内如果未获取到锁则放弃。
    • leaseTime 是锁的自动释放时间,避免因为业务逻辑异常导致锁无法释放。
  3. unlock():业务逻辑执行完后需要手动释放锁,否则其他线程将无法获取锁。

5. 为什么使用Redisson分布式锁

使用 Redisson 实现的分布式锁相对于直接使用 Redis 的分布式锁,具有一些显著的优势,尤其是在功能完善性、开发便捷性以及可扩展性方面。以下是 Redisson 实现的分布式锁相对于手动实现 Redis 分布式锁的几个主要优势:

优势Redisson 实现分布式锁手动使用 Redis 实现分布式锁
锁机制支持可重入锁、公平锁、读写锁等丰富的锁机制需要手动实现
锁续期机制自动续期,防止锁超时失效需要手动续期
操作原子性内置保证需要 Lua 脚本保障原子性
易用性API 简单,易于使用和维护需要手动编写命令逻辑
部署架构支持支持单点、哨兵、集群模式需要手动处理高可用
高级功能异步、分布式对象、反压支持需要手动封装
异步和同步支持完善的异步和反应式支持需要手动编写异步代码

6. 常见问题

  • 死锁问题:如果业务逻辑执行时间超过锁的自动释放时间,会导致锁自动释放,其他线程可能会获取锁,造成数据不一致问题。为避免这种情况,可以设置足够长的 leaseTime,或者在业务逻辑完成时手动释放锁。

  • 锁竞争激烈:在高并发场景下,多个线程同时竞争锁,可能会导致部分线程长时间无法获取锁。可以通过优化锁的粒度来减少锁的竞争。

7. 总结

通过 Spring Boot 3 和 Redisson 的结合,你可以轻松实现分布式锁的功能,确保在分布式系统中关键任务的正确执行。Redisson 提供了多种锁的实现,如公平锁、读写锁、可重入锁等,能够满足不同的业务需求。

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

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

相关文章

会声会影导出视频mp4格式哪个最高清,会声会影输出格式哪个清晰

调高分辨率后&#xff0c;mp4视频还是不清晰。哪怕全部使用4K级素材&#xff0c;仍然剪不出理想中的高画质作品。不是你的操作有问题&#xff0c;而是剪辑软件没选对。Corel公司拥有全球顶尖的图像处理技术&#xff0c;该公司研发的会声会影视频剪辑软件&#xff0c;在过去的20…

Linux性能调优技巧

目录 前言1. CPU性能优化1.1 调整CPU调度策略1.2 合理分配多核处理 2. 内存性能优化2.1 调整内存分配策略2.2 缓存和分页优化 3. 磁盘I/O性能优化3.1 使用合适的I/O调度器3.2 磁盘分区和文件系统优化 4. 网络性能优化4.1 优化网络参数4.2 调整网络拥塞控制算法 5. 系统监控与优…

20款奔驰CLS300升级原厂抬头显示HUD 23P智能辅助驾驶 触摸屏人机交互系统

以下是为您生成的一份关于 18 款奔驰 CLS 老款改新款的改装文案&#xff1a; 18 款奔驰 CLS 老款改新款&#xff1a;科技升级&#xff0c;畅享极致驾驶体验 在汽车改装的世界里&#xff0c;每一次的升级都是对卓越的追求。今天&#xff0c;让我们一同探索 18 款奔驰 CLS 老款改…

arm-伪指令

在汇编语言中&#xff0c;特别是在与ARM架构相关的汇编语言中&#xff0c;ADR、ADRL、LDR 和 NOP 是具有特定功能的指令或伪指令。下面是对这些术语在ARM汇编语言中的详细解释&#xff1a; LDR&#xff08;Load Register&#xff09; 定义&#xff1a;LDR是一个指令&#xff…

代码随想录训练营第48天|单调栈

739. 每日温度 class Solution { public:vector<int> dailyTemperatures(vector<int>& temperatures) {stack<int> st;st.push(0);int ntemperatures.size();vector<int> res(n,0);for(int i1; i<n; i){while(!st.empty()&&temperatur…

重塑数字时代的生存法则:IT部门的转型与重生

在当下大环境低迷&#xff0c;经济寒冬之下&#xff0c;某数字化转型大群的一则令人震惊的消息如巨石投湖&#xff0c;激起了层层涟漪——某集团公司宣布全面裁撤IT团队&#xff0c;无一幸免。这一决定&#xff0c;不仅让群内的IT同仁们愕然失色&#xff0c;更引发了行业内外对…

记一次教学版内网渗透流程

信息收集 如果觉得文章写的不错可以共同交流 http://aertyxqdp1.target.yijinglab.com/dirsearch dirsearch -u "http://aertyxqdp1.target.yijinglab.com/"发现 http://aertyxqdp1.target.yijinglab.com/joomla/http://aertyxqdp1.target.yijinglab.com/phpMyA…

Python网络编程:开启你的网络之旅

引言 你有没有想过&#xff0c;为什么我们能在几秒钟内从世界的另一端获取信息&#xff1f;这背后&#xff0c;正是网络编程的魔力&#xff01;在这个数字化的时代&#xff0c;掌握网络编程不仅能让你在技术上游刃有余&#xff0c;还能为你的职业生涯增添一笔亮丽的色彩。今天…

知识图谱入门——3:工具分类与对比(知识建模工具:Protégé、 知识抽取工具:DeepDive、知识存储工具:Neo4j)

在知识图谱构建的过程中&#xff0c;针对不同的任务和需求&#xff0c;我们可以使用多种工具。为了帮助你快速选择合适的工具&#xff0c;本文将常用工具按类别进行分类介绍&#xff0c;并对比其优缺点&#xff0c;方便你在不同场景中做出最佳选择。 文章目录 1. 知识建模工具…

Windows Ubuntu下搭建深度学习Pytorch训练框架与转换环境TensorRT

Windows Ubuntu下搭建深度学习Pytorch训练框架与转换环境TensorRT JetBrains2024&#xff08;IntelliJ IDEA、PhpStorm、RubyMine、Rider……&#xff09;安装包Anaconda Miniconda安装.condarc 文件配置镜像源查看conda的配置和源(channel)自定义conda虚拟环境路径conda常用命…

el-pagination组件封装

组件使用 源代码&#xff1a; <script setup> import Pagination from /components/pagination/index.vue import {ref} from "vue";const pageNum ref(1) const pageSize ref(10) const total ref(120)function loadData() {// 加载数据 } </script>…

H.264编解码工具 - NVIDIA CUDA

一、简介 NVIDIA CUDA编解码是一项采用NVIDIA图形处理器(GPU)来加速视频编码和解码的技术。CUDA(Compute Unified Device Architecture)是一种并行计算平台和编程模型,允许开发者使用GPU来进行通用计算。 优点: 加速编解码速度:CUDA编解码利用GPU的并行处理能力,可以…

RabbitMQ 工作方式详解

RabbitMQ 是一个开源的消息代理软件&#xff0c;它实现了高级消息队列协议&#xff08;AMQP&#xff09;。RabbitMQ 允许应用程序或系统以异步的方式交换数据&#xff0c;从而提高了系统的可扩展性和容错性。本文将详细介绍 RabbitMQ 的工作方式&#xff0c;包括其核心概念、消…

【Unity】unity安卓打包参数(个人复习向/有不足之处欢迎指出/侵删)

1.Texture Compression 纹理压缩 设置发布后的纹理压缩格式 Use Player Settings:使用在播放器设置中设置的纹理压缩格式 ETC&#xff1a;使用ETC格式&#xff08;兼容&#xff09; ETC2&#xff1a;使用ETC2格式&#xff08;很多设备不支持&#xff09; ASTC&#xff1a;使用…

腾讯云服务器上使用Nginx部署的静态网站打开速度慢的原因分析及优化解决方案

目录 前言1. 网站打开速度慢的原因分析1.1 服务器配置不足1.2 网络延迟1.3 Nginx配置不合理1.4 静态资源未优化 2. 网站速度的测试与分析2.1 使用浏览器开发者工具分析2.2 在线工具测试 3. 网站优化的具体方法3.1 服务器配置优化3.2 CDN加速与DNS优化3.3 优化Nginx配置3.3.1 启…

Django一分钟:DRF ViewSet烹饪指南,创建好用的视图集

本文将介绍django视图集的内部实现&#xff0c;并带你重写部分代码自己组装强大且趁手的视图集&#xff0c;以满足自定义的业务需求&#xff0c;避免编写大量重复代码。 一、基础知识 Django Rest framework框架允许你将一组相关视图的逻辑组合到一个类中&#xff0c;也就是我…

PCIe6.0 AIC金手指和板端CEM连接器信号完整性设计规范

先附上我之前写的关于PCIe5.0金手指的设计解读&#xff1a; PCIe5.0的Add-in-Card(AIC)金手指layout建议&#xff08;一&#xff09;_pcie cem-CSDN博客 PCIe5.0的Add-in-Card(AIC)金手指layout建议&#xff08;二&#xff09;_gnd bar-CSDN博客 首先&#xff0c;相较于PCI…

《深度学习》【项目】OpenCV 发票识别 透视变换、轮廓检测解析及案例解析

目录 一、透视变换 1、什么是透视变换 2、操作步骤 1&#xff09;选择透视变换的源图像和目标图像 2&#xff09;确定透视变换所需的关键点 3&#xff09;计算透视变换的变换矩阵 4&#xff09;对源图像进行透视变换 5&#xff09;对变换后的图像进行插值处理 二、轮廓检测…

Python | Leetcode Python题解之第454题四数相加II

题目&#xff1a; 题解&#xff1a; class Solution:def fourSumCount(self, A: List[int], B: List[int], C: List[int], D: List[int]) -> int:countAB collections.Counter(u v for u in A for v in B)ans 0for u in C:for v in D:if -u - v in countAB:ans countAB…

P2480 [SDOI2010] 古代猪文

原题链接 简化题意&#xff1a; 给定 n , G n,G n,G&#xff0c;求 G ∑ d ∣ n C n d m o d 999911659 G^{\sum_{d|n}C_{n}^{d}}mod_{}999911659 G∑d∣n​Cnd​mod​999911659。 发现指数可能非常大&#xff0c;而模数为质数&#xff0c;此时可以考虑运用扩展欧拉定理来化…