如何实现Redisson分布式锁

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

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

java导出excel思路

1、构建导出的数据模型&#xff0c; 这个模型可以自己画&#xff0c;也可以读取一个自己制作好的模板&#xff0c;根据模板填充数据&#xff0c;然后flush到一个新的excel文件。 1&#xff09;、自己画 GetMapping("/exportTemplate") public void exportTemp…

链表相关题目

一、反转单向链表 private static void reverseNode(Node head) {Node pre null;Node currentNode head;while (currentNode ! null) {Node next currentNode.next;currentNode.next pre;pre currentNode;currentNode next;}二、反转双向链表 private static void revers…

Live800:金牌客服常用的6大提问技巧

在客服行业&#xff0c;提问技巧是非常重要的一项技能。好的提问技巧不仅能够帮助客服人员更好地了解客户需求&#xff0c;还能够提高客户满意度和忠诚度。以下是金牌客服常用的6大提问技巧&#xff0c;希望能够对客服人员提升工作效率有所帮助。 1、开放性问题 开放性问题是指…

【Linux】Ubuntu16.04配置repo

Ubuntu16.04配置repo失败 在学习韦东山Linux嵌入式开发过程中&#xff0c;使用repo获取内核及工具链: git clone https://e.coding.net/codebug8/repo.gitmkdir -p 100ask_imx6ull-sdk && cd 100ask_imx6ull-sdk../repo/repo init -u https://gitee.com/weidongshan/…

腾讯云标准型S5服务器五年优惠价格表(4核8G和2核4G)

腾讯云服务器网整理五年云服务器优惠活动 txyfwq.com/go/txy 配置可选2核4G和4核8G&#xff0c;公网带宽可选1M、3M或5M&#xff0c;系统盘为50G高性能云硬盘&#xff0c;标准型S5实例CPU采用主频2.5GHz的Intel Xeon Cascade Lake或者Intel Xeon Cooper Lake处理器&#xff0c;…

3. 【自动驾驶和机器人中的SLAM技术】实现基于预积分和图优化的GNSS+IMU+Odom的融合定位系统

目录 1. 公式推导2. GNSSIMUOdom融合定位3. 利用数值求导工具&#xff0c;验证本书实验中的雅可比矩阵的正确性4. 也欢迎大家来我公众号读书--“过千帆” 1. 公式推导 2. GNSSIMUOdom融合定位 程序实现以及运行效果&#xff1a; ①首先是在预积分程序中记录了预积分积累的IMU数…

智安网络|探索语音识别技术:优势与挑战的全面解析

语音识别技术是人工智能领域的重要应用之一&#xff0c;它通过将语音信号转化为文本&#xff0c;实现了人机交互的一种新形式。随着科技的不断发展&#xff0c;语音识别技术在各个行业中得到了广泛的应用&#xff0c;但同时也存在着一些优势和劣势。 首先&#xff0c;语音识别…

环保气膜建筑的运维成本在哪几个方面

作为一种环保建筑&#xff0c;气膜结构在工业和文体领域得到了广泛认可。尽管气膜建筑在经济上具有明显的优势&#xff0c;但对于不了解它的人来说&#xff0c;他们可能会下意识地认为在运营和维护过程中会产生大量费用。今天&#xff0c;让我们一起了解一下气膜建筑在运营维护…

MHA实验

MHA: 什么是MHA masterhigh availabulity :基于主库的高可用环境下&#xff1a;主从复制&#xff0c;故障切换 主从的架构&#xff1a; MHA&#xff1a;最少要一主两从 mysql的单点故障问题&#xff0c;一旦主库崩溃&#xff0c;MHA可以在0-30秒内可以自动完成故障切换 M…

创作者焦点:Royal Flushed(第二章)

一起来看看「Dr. Bomkus 的试炼」幕后的创作故事吧&#xff5e; 「创作者焦点」系列报道将带来六篇关于「Dr. Bomkus 的试炼」游戏的创作过程&#xff0c;以及其独特的游戏玩法和功能。 屏住呼吸&#xff0c;潜入沉没区。穿过 Bomkus 设计的水下迷宫&#xff0c;回到地面上&…

为什么重写equals方法必须重写hashcode方法

在Java中&#xff0c;重写equals()方法的同时也应该重写hashCode()方法&#xff0c;这是因为这两个方法在 Java 中是有关联的&#xff0c;而且它们一起影响着集合类的行为。 Java中的hashCode()方法用于返回对象的哈希码&#xff0c;而equals()方法用于比较两个对象是否相等。…

Techgen ict 转 qrcTechFile问题整理

我正在「拾陆楼」和朋友们讨论有趣的话题&#xff0c;你⼀起来吧&#xff1f; 拾陆楼知识星球入口 ERROR (EXTZTECH-157) : Density value need to increase monotonically . 根据提示定位到ict的以下内容: resistivity 0.231 106.5192 ... ... 1.9 81.3252 根据错误提示我…

中电金信:语言服务解决方案

​​ ​​ 点击或扫描下图二维码&#xff0c;查看更多相关内容 ​​ ​​ ​​ ​​ 01方案概述 我们以成熟的语言服务能力为核心&#xff0c;围绕出海企业的需求&#xff0c;构建覆盖企业出海全生命周期的语言服务。我们在全球31个城市设有交付中心&#xff0c;可以为出海…

MDM9205开发环境搭建与编译调试

前言 如题,这篇文章说的是高通mdm9205这颗物联网芯片,从官方资源的获取(包括文档、代码、软件工具等等)到如何编译出可运行固件的方法。 对经历了不止一次这颗芯片开发的我来说,在过程中遇到问题,除了寄希望于可能在工作日第二天凌晨得到的case回复,有一篇最新的有指导方…

Vue3中的 ref() 为何需要 .value ?

前言 本文是 Vue3 源码实战专栏的第 7 篇&#xff0c;从 0-1 实现 ref 功能函数。 官方文档 中对ref的定义&#xff0c; 接受一个内部值&#xff0c;返回一个响应式的、可更改的 ref 对象&#xff0c;此对象只有一个指向其内部值的属性 .value。 老规矩还是从单测入手&…

Failed to restart network.service: Unit network.service not found.

执行systemctl restart network命令&#xff0c;报错Failed to restart network.service: Unit network.service not found. 执行 yum install network-scripts命令 再次执行&#xff0c;正常

计算机视觉基础(6)——光流估计

前言 本章我们来学习一下图像处理基础中的运动估计。主要内容包括运动场估计和光流估计两个部分。在运动场估计中&#xff0c;我们将学习到运动场、光流、光流和运动场的区别&#xff1b;在光流估计中&#xff0c;我们将学习到光流估计任务、孔径问题&#xff0c;以及光流估计两…

μC/OS-II---计时器管理1(os_tmr.c)

目录 创建一个计时器重新启动一个计时器停止一个计时器删除一个计时器 计时器是倒计时器&#xff0c;当计数器达到零时执行某个动作。用户通过回调函数提供这个动作。回调函数是用户声明的函数&#xff0c;在计时器到期时被调用。在回调函数中绝对不能进行阻塞调用&#xff08;…

腾讯云五年服务器CVM和三年轻量应用服务器选哪个?

腾讯云3年轻量和5年云服务器CVM优惠活动入口&#xff0c;3年轻量应用服务器配置可选2核2G4M和2核4G5M带宽&#xff0c;5年CVM云服务器可以选择2核4G和4核8G配置可选&#xff0c;阿腾云atengyun.com分享腾讯云3年轻量应用服务器和5年云服务器CVM优惠活动入口和配置报价&#xff…

【STM32单片机】比赛计时计分系统设计

文章目录 一、功能简介二、软件设计三、实验现象联系作者 一、功能简介 本项目使用STM32F103C8T6单片机控制器&#xff0c;使用OLED显示模块、矩阵按键模块、蜂鸣器等。 主要功能&#xff1a; 系统运行后&#xff0c;OLED默认显示第1节次比赛时间、AB得分。默认是12分钟倒计时…