如何实现Redisson分布式锁

news2024/7/4 4:30:00

首先,不要将分布式锁想的太复杂,如果我们只是平时业务中去使用,其实不算难,但是很多人写的文章不能让人快速上手,接下来,一起看下Redisson分布式锁的快速实现

Redisson 是一个在 Redis 的基础上实现的 Java 驻内存数据网格客户端(In-Memory Data Grid)。它不仅提供了一系列的 redis 常用数据结构命令服务,还提供了许多分布式服务,例如分布式锁、分布式对象、分布式集合、分布式远程服务、分布式调度任务服务等等。

Redisson:其实就是相当于在redis的基础上进行了加强,让redisson不像redis的分布式是直接基于指令setnx(set if not exists: 如果不存在)去实现的。

开始配置

因为redission是基于redis的,所以我们需要本地安装reids,redis安装这里就不演示了,这里是使用springboot创建的项目,我们默认项目已经创建完成了,所以直接开始配置

项目结构

1、配置redis

#以下是application.yml中的配置
server:
  port: 8083


spring:
  redis:
    host: localhost
    port: 6379
    timeout: 1000
    jedis:
      pool:
        min-idle: 5
        max-idle: 10
        max-wait: -1
2、配置pom.xml 引入相关jar包
        <!-- 引入redis -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

        <!-- 引入redisson -->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.17.7</version>
        </dependency>
3、编写测试并发类
package cn.sendmsg.test;
import lombok.extern.slf4j.Slf4j;
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.TimeUnit;

@RestController
@Slf4j
public class redissonController {


    @RequestMapping("/testLock")
    public void  testRedissLock(){
        // 使用Redisson 设置分布式锁
        //1、配置Redisson客户端  Config对象用于配置 Redisson 客户端的参数。
        Config config = new Config();
        //2、连接地址    连接方式redis://  或者 rediss://

        // 集群使用
        // config.useClusterServers()
        //    .setScanInterval(2000) // 集群状态扫描间隔时间,单位是毫秒
        //    //可以用"rediss://"来启用SSL连接
        //    .addNodeAddress("redis://127.0.0.1:7000", "redis://127.0.0.1:7001")
        //    .addNodeAddress("redis://127.0.0.1:7002");
        /*
        *  userSingleServer():指定使用单个redis服务配置
        *  setAddress() :  设置 Redis 服务器的地址
        *  setPassWord(): 设置连接 Redis 服务器的密码,如果有的话
        *  setDatabase(0): 设置连接的数据库索引,0就表示第一个
        * */
        config.useSingleServer().setAddress("redis://localhost:6379");

        //3、 创建Redisson客户端
        RedissonClient redissonClient = Redisson.create(config);

        String lockValue = "isLock";
        // 获取红锁
        RLock redissonLock = redissonClient.getLock(lockValue);
        try {
            // 后去锁,如果获取到返回true
            // tryLock():尝试3秒内获取锁,如果获取到了,最长3秒自动释放
            boolean lock = redissonLock.tryLock(3L,3L, TimeUnit.SECONDS);
            // 获取锁后,开始执行需要加锁的逻辑代码
            if(lock){
                System.out.println("获取到锁了");
                for(int i =0;i<5;i++){
                    log.info("执行逻辑,查看打印结果:{}",i);
                }

            }
        } catch (InterruptedException e) {
            log.info("获取锁失败,失败原因:{}",e.getMessage());
            throw new RuntimeException(e);
        }finally {
            // 最后一定要释放锁,不然有可能造成死锁现象
            redissonLock.unlock();
        }

    }


    // 用于jmater测试不加锁的信息,对比看
    @RequestMapping("/testNoLock")
    public void  testRedissNoLock(){
        for(int i =0;i< 10;i++){
            log.info("无分布式锁的逻辑:"+i);
        }
    }

}
4、使用jmater测试(这是个压测工具,可以一次性发多个线程,来进行压力测试),这个自行安装以下

以下是jmater工具页面截图,这个花3分钟时间,自己学习下,主要还是设置yml、pom.xml、测试类,这个属于工具

 5、查看本地代码运行结果(注意看打印结果,因为获得了分布式锁,所以在执行代码块for循环时,是顺序的,不然不是顺序的)
获取到锁了
2023-11-14 14:51:45.840  INFO 40508 --- [nio-8083-exec-4] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:0
2023-11-14 14:51:45.840  INFO 40508 --- [nio-8083-exec-4] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:1
2023-11-14 14:51:45.840  INFO 40508 --- [nio-8083-exec-4] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:2
2023-11-14 14:51:45.840  INFO 40508 --- [nio-8083-exec-4] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:3
2023-11-14 14:51:45.840  INFO 40508 --- [nio-8083-exec-4] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:4
获取到锁了
2023-11-14 14:51:45.862  INFO 40508 --- [nio-8083-exec-5] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:0
2023-11-14 14:51:45.862  INFO 40508 --- [nio-8083-exec-5] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:1
2023-11-14 14:51:45.862  INFO 40508 --- [nio-8083-exec-5] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:2
2023-11-14 14:51:45.862  INFO 40508 --- [nio-8083-exec-5] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:3
2023-11-14 14:51:45.862  INFO 40508 --- [nio-8083-exec-5] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:4
获取到锁了
2023-11-14 14:51:45.866  INFO 40508 --- [nio-8083-exec-2] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:0
2023-11-14 14:51:45.866  INFO 40508 --- [nio-8083-exec-2] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:1
2023-11-14 14:51:45.866  INFO 40508 --- [nio-8083-exec-2] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:2
2023-11-14 14:51:45.866  INFO 40508 --- [nio-8083-exec-2] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:3
2023-11-14 14:51:45.866  INFO 40508 --- [nio-8083-exec-2] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:4
获取到锁了
2023-11-14 14:51:45.869  INFO 40508 --- [nio-8083-exec-3] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:0
2023-11-14 14:51:45.869  INFO 40508 --- [nio-8083-exec-3] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:1
2023-11-14 14:51:45.869  INFO 40508 --- [nio-8083-exec-3] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:2
2023-11-14 14:51:45.869  INFO 40508 --- [nio-8083-exec-3] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:3
2023-11-14 14:51:45.869  INFO 40508 --- [nio-8083-exec-3] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:4
获取到锁了
2023-11-14 14:51:45.872  INFO 40508 --- [nio-8083-exec-1] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:0
2023-11-14 14:51:45.872  INFO 40508 --- [nio-8083-exec-1] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:1
2023-11-14 14:51:45.872  INFO 40508 --- [nio-8083-exec-1] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:2
2023-11-14 14:51:45.872  INFO 40508 --- [nio-8083-exec-1] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:3
2023-11-14 14:51:45.872  INFO 40508 --- [nio-8083-exec-1] cn.sendmsg.test.redissonController       : 执行逻辑,查看打印结果:4

到这里,其实我们就已经实现Redisson分布式锁了,不要把这个想的太复杂,可能在集群时需要注意些。  示例代码中演示了集群时如何设置。这是一个简单的案例,但实际开发者,获取锁-释放锁也是这么用的。加油

6、不加锁使用jmater打印的信息

不加锁,for循环打印时,输出日志就不是有顺序的

15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:3
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:4
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:5
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-17] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:9
2023-11-14 15:00:40.081  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:1
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:2
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:3
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:4
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:5
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.217  INFO 40508 --- [io-8083-exec-16] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:9
2023-11-14 15:00:40.078  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:5
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:9
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:0
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:1
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:2
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:3
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:4
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:5
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-23] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:9
2023-11-14 15:00:40.210  INFO 40508 --- [io-8083-exec-25] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-25] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.218  INFO 40508 --- [io-8083-exec-25] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:0
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:1
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:2
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:3
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:4
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:5
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:6
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:7
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:8
2023-11-14 15:00:40.218  INFO 40508 --- [nio-8083-exec-7] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:9
2023-11-14 15:00:40.211  INFO 40508 --- [io-8083-exec-26] cn.sendmsg.test.redissonController       : 无分布式锁的逻辑:0

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

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

相关文章

Postman配置环境请求接口

一、准备配置dev、test、demo、eprod 二、使用切换环境变量调用接口 三、使用登录接口自动获取token

python数据处理作业11:建一个5*3的随机数组和一个3*2的数组,其元素为1,2,3,4,5,6,求两矩阵的积

每日小语 打碎的杯子&#xff0c;烫伤的手&#xff0c;对菩萨是堪忍&#xff0c;因为他在里面得悟甚深之法&#xff0c;心生欢喜。 可是对一般人来说&#xff0c;一生何止打破千百个杯子&#xff1f;何止烫伤过千百次手&#xff1f;他只是痛苦地忍受&#xff0c;只记得下次要…

创建具有负载平衡和集群的可扩展 Node.js 应用程序

创建具有负载平衡和集群的可扩展 Node.js 应用程序 负载平衡是提高应用程序性能、可扩展性和可用性的一项重要技术。当客户端向负载均衡器发出请求时&#xff0c;负载均衡器根据预定义的规则将请求分发到不同的实例。 可以使用cluster集群模块或 PM2 等工具根据负载均衡器的流…

谈谈一个IT杂家的职业生涯规划,你的护城河被AI 攻破了么

文章大纲 没有顶会的从业者&#xff1a;成为深度学习老中医AIGC 还未能克服的难点&#xff1a;忽然的惊喜 -- 大模型的智能涌现未来还能做点什么&#xff0c;从计算机视觉的发展走向看T 字型人才与护城河成为更加熟练使用人工智能的人 参考文献与学习路径 我的职业生涯将近十年…

【多项式回归】拟合有噪声的正弦曲线

先导入模块并创建数据&#xff1a; from sklearn.preprocessing import PolynomialFeatures as PF from sklearn.linear_model import LinearRegression import numpy as nprnd np.random.RandomState(42) #设置随机数种子 X rnd.uniform(-3, 3, size100) y np.sin(X) rnd…

飞书开发学习笔记(六)-网页应用免登

飞书开发学习笔记(六)-网页应用免登 一.上一例的问题修正 在上一例中&#xff0c;飞书登录查看网页的界面显示是有误的&#xff0c;看了代码&#xff0c;理论上登录成功之后&#xff0c;应该显示用户名等信息。 最后的res.nickName是用户名&#xff0c;res.i18nName.en_us是英…

冲击900亿美元估值!邀约路演、秘密交表的Shein上市有望

双十一的狂欢刚刚结束&#xff0c;Shein即将赴美上市的消息又在电商圈里投下一枚重磅炸弹。 继被媒体曝光其寻求900亿美金估值后&#xff0c;最新的消息称其已邀请投资人参与路演&#xff0c;且已秘密完成交表。这个神秘的中国独角兽&#xff0c;离敲钟登陆美股的日子越来越近…

爬虫----robots.txt 协议简介

文章目录 robots.txt 是一个用于指示网络爬虫(web spider或web robot)如何与网站上的内容进行交互的协议。这个文件被网站管理员放置在网站的根目录下,用于告知爬虫哪些部分的网站是可以被抓取的,哪些是不被允许的。以下是 robots.txt 协议的一些关键要点: 控制爬虫访问:…

“技能兴鲁”职业技能大赛-网络安全赛项-学生组初赛 WP

Crypto BabyRSA 共模攻击 题目附件&#xff1a; from gmpy2 import * from Crypto.Util.number import *flag flag{I\m not gonna tell you the FLAG} # 这个肯定不是FLAG了&#xff0c;不要交这个咯p getPrime(2048) q getPrime(2048) m1 bytes_to_long(bytes(flag.e…

MHA的那些事儿

什么是MHA&#xff1f; masterhight availability&#xff1a;基于主库的高可用环境下&#xff0c;主从复制和故障切换 主从的架构 MHA至少要一主两从 出现的目的&#xff1a;解决MySQL的单点故障问题。一旦主库崩溃&#xff0c;MHA可以在0-30s内自动完成故障切换 MHA使用的…

毫米波雷达模块的目标检测与跟踪

毫米波雷达技术在目标检测与跟踪方面具有独特的优势&#xff0c;其高精度、不受光照影响等特点使其在汽车、军事、工业等领域广泛应用。本文深入探讨毫米波雷达模块在目标检测与跟踪方面的研究现状、关键技术以及未来发展方向。 随着科技的不断进步&#xff0c;毫米波雷达技术在…

深入解析 Azure 机器学习平台:架构与组成部分

Azure机器学习平台是Microsoft Azure提供的一种云上机器学习服务&#xff0c;为开发者和数据科学家提供了一个全面且易于使用的环境来创建、训练、部署和管理机器学习模型。本文将对Azure机器学习平台的基本架构和组成部分进行深入解析&#xff0c;帮助读者全面了解该平台的工作…

10-18 请求与相应1

前后台联调 前台通过一个表单, action写的servlet绑定的url,提交表单,请求我们servlet的doGet()/ doPost()方法 问题: 1.后台怎么获取前端的提交,请求的数据?底层:TCP通信,socket的得到输入流,读取数据 2.后台处理请求之后,怎么把结果给到前端?底层:TCP通信,socket的得到输入…

VR全景:打造虚拟政务服务,打通服务群众“最后一公里”

大家对政务大厅的工作效率可能已经司空见惯&#xff0c;办事窗口少&#xff0c;而需要办理的群众和业务却很多&#xff0c;很多去政务大厅办理业务的&#xff0c;排队几个小时也是常有的。并且在传统政务服务中&#xff0c;办事流程一般都较为复杂、耗时长&#xff0c;往往需要…

TSINGSEE视频汇聚管理与AI算法视频质量检测方案

一、建设背景 随着互联网视频技术的发展&#xff0c;视频监管在辅助安全生产、管理等方面发挥了不可替代的作用。但是&#xff0c;在监管场景中&#xff0c;仍然存在视频掉线、视频人为遮挡、视频录像存储时长不足等问题&#xff0c;对企业的日常管理和运转存在较大的安全隐患…

uniapp插件开发

安装android studio&#xff1a;安装目录下bin下的此文件&#xff0c;是用来修改分配给android studio的占用内存。 Android 11足够用。 创建新项目&#xff1a; 目录结构介绍&#xff1a; UI组件介绍&#xff1a;在设计程序界面时可以使用可视化拖拽的方式&#xff0c;没有必要…

DGL如何表征一张图

有关于DGL中图的构建 DGL 将有向图表示为一个 DGL 图对象。图中的节点编号连续&#xff0c;从0开始。我们一般通过指定图中的节点数&#xff0c;以及源节点和目标节点的列表&#xff0c;来构建这么一个图。 下面的代码构造了一个图&#xff0c;这个图有五个叶子节点。中心节点…

03 # 类型基础:动态类型与静态类型

通俗定义 静态类型语言&#xff1a;在编译阶段确定所有变量的类型 编译阶段确定属性偏移量用偏移量访问代替属性名访问偏移量信息共享 动态类型语言&#xff1a;在执行阶段确定所有变量的类型 在程序运行时&#xff0c;动态计算属性偏移量需要额外的空间存储属性名所有对象的…

246:vue+openlayers 绘制多边形,drawend获取最大幅宽

第246个 点击查看专栏目录 本示例是演示如何在vue+openlayers项目中绘制多边形,drawend获取最大幅宽。这里利用turf的turf.distance和openlayers的getExtent获取坐标值。 距离赤道越近,幅宽会越大一些,这里面利用了Math.abs来做绝对值的判断处理。 直接复制下面的 vue+open…

HBase学习笔记(3)—— HBase整合Phoenix

目录 Phoenix Shell 操作 Phoenix JDBC 操作 Phoenix 二级索引 HBase整合Phoenix Phoenix 简介 Phoenix 是 HBase 的开源 SQL 皮肤。可以使用标准 JDBC API 代替 HBase 客户端 API来创建表&#xff0c;插入数据和查询 HBase 数据 使用Phoenix的优点 在 Client 和 HBase …