分布式锁4-Redisson分布式锁实现与看门狗原理

news2024/11/15 6:11:07

文章目录

    • 一.Redisson介绍
    • 二.分布式锁的运用
      • 1.引入依赖.
      • 2.增加配置类.
      • 3.简单代码实现
        • 1.不指定加锁时间,会默认启动看门狗.自动帮你的锁进行续期.
        • 2.指定加锁时间,不启用看门狗续期,到期自动解锁.
    • 三.分布式锁实现原理
      • 加锁过程
      • 看门狗续期过程

一.Redisson介绍

   Redisson 是架设在 Redis 基础上的一个 Java 驻内存数据网格(In-Memory Data Grid)。充分的利用了 Redis 键值数据库提供的一系列优势, 基于 Java 实用工具包中常用接口,为使用者提供了一系列具有分布式特性的常用工具类。 使得原本作为协调单机多线程并发程序的工具包获得了协调分布式多机多线程并发系统的能力,大大降低了设计和研发大规模分布式系统的难度。同时结合各富特色的分布式服务,更进一步简化了分布式环境中程序相互之间的协作。

   以上是官网的介绍,主要就是基于redis分布式锁实现了jvm ReentrantLock锁的几乎所有功能, 读写锁,重入锁,公平锁,信号量等等.让你就像调用本地锁一样简单.可以说非常强大.

官方文档:Redisson

二.分布式锁的运用

1.引入依赖.

        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.12.0</version>
        </dependency>

2.增加配置类.

@Configuration
public class RedissonConfig {

    @Bean
    public RedissonClient redissonClient(){
        Config config = new Config();
        //集群配置
//        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");
        //单节点配置
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        return Redisson.create(config);
    }
}

3.简单代码实现

注意:此分布式锁默认实现均为可重入锁,和jvm锁一样,持有当前锁的线程可以重复获取锁

1.不指定加锁时间,会默认启动看门狗.自动帮你的锁进行续期.

    @Autowired
    RedissonClient redissonClient;

     public void test(){
        //传入的名称要注意,名称一样即为同一把锁
        RLock lock = redissonClient.getLock("lock");
        lock.lock();
        try{
            //执行具体的业务逻辑
            

        }finally {
            lock.unlock();
        }

    }

2.指定加锁时间,不启用看门狗续期,到期自动解锁.

    @Autowired
    RedissonClient redissonClient;

     public void test(){
        //传入的名称要注意,名称一样即为同一把锁
        RLock lock = redissonClient.getLock("lock");
        lock.lock(30,TimeUnit.SECONDS);
        //执行具体的业务逻辑
        
    }

注意传入的名称为同一个,即为同一把锁,所以这个锁的名称就涉及到锁的粒度,锁的粒度是越小越好的

此外,Reddssion还提供了公平锁,红锁,读写锁,信号量等等,这里不再说明,可以参照文档.
官方文档:Redisson

三.分布式锁实现原理

这里以不指定过期时间,使用看门狗进行续期的情况进行分析.

加锁过程

这里会默认传一个-1的过期时间,以便后续进行判断,是-1的话则使用看门狗续期

在这里插入图片描述
然后进行尝试加锁

在这里插入图片描述

这里采用了异步加锁的方式,当加锁成功后,回调执行看门狗逻辑的方法.

在这里插入图片描述
这里我们先看它的异步加锁方法:
其实最主要的就是执行了一段lua脚本,保证了多个操作的原子性
根据这个lua脚本,也能看出这个锁是可重入的,如果当前key存在的话,就将value进行+1.

在这里插入图片描述

看门狗续期过程

这里我们再回到使用看门狗进行续期的方法

在这里插入图片描述
在整个加锁过程中,这个看门狗的实现还是很细节的,这是一个比较复杂的操作.

因为这里有一个问题,我们知道,如果想对一个key进行续期,我们最简单的可以指定一个定时任务,重复的去执行这个续期逻辑.但是在一个项目中,可能会有很多不同的分布式锁, 那每一个锁都单独的一个定时任务吗?那很多锁的情况下岂不是要很多的定时任务?这样的话对项目影响岂不是很大?

那Reddssion是怎样处理的呢?我们一起看一下
在这里插入图片描述
这里往一个东西里面添加了定时任务,这个定时任务具体要做的就是使用lua脚本对key进行续期,续期成功后,递归执行这个方法,为什么要递归呢?这个定时任务谁控制去执行的呢?

在这里插入图片描述
我们点开 commandExecutor.getConnectionManager().newTimeout()方法,看看它做了什么?

在这里插入图片描述
   看到这里,可能有的人就知道了,这里其实运用了HashedWheelTimer类,它是netty内部的一个工具类,主要运用了时间轮算法,内部有且仅有一个worker线程,可以动态的添加延时任务,但是每个任务只会执行一次,所以上面会递归的去添加任务.

   而因为其内部只有一个worker线程,所以并不会对项目影响很大,有小伙伴不了解这个HashedWheelTimer,可以看下这个文章时间轮算法HashedWheelTimer
看完就会理解看门狗为什么要这样实现了.

这里要注意:
如果你不主动释放锁的话,redisson中的看门狗默认会一直帮你续期,即使程序出现异常或者线程中断,除非整个项目停止,这个时候看门狗也停止了,也就不会再续期了.所以一定要记得释放锁.

今天的分享就到这里了,有问题可以在评论区留言,均会及时回复呀.
我是bling,未来不会太差,只要我们不要太懒就行, 咱们下期见.
在这里插入图片描述

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

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

相关文章

读《冯诺依曼传》

关于冯诺依曼 冯诺依曼是20世纪的全才,原名约翰尼,匈牙利美籍科学家,被称为计算机之父和博弈论之父。计算机和博弈论都深刻改变人类的生活工作和思维方式,极大地促进了社会和人类文明的进步发展。在六个哲学领域他都做出了相当大的贡献,把模糊的问题用数学精确地表述出来…

扩散模型的迁移和应用(DiffusionDet,AR-LDM,MagicVideo,RenderDiffusion,AltDiffusion,VD)

在上一篇博文中&#xff0c;博主已经整理了扩散模型&#xff08;Diffusion Model&#xff0c;DDPM&#xff0c;GLIDE&#xff0c;DALLE2&#xff0c;Stable Diffusion&#xff09;的基本原理&#xff0c;后续不再赘述其细节。作为一个最近被讨论热烈的方向&#xff0c;很自然地…

干Java开发快30岁了,没有核心竞争力,该怎么跳槽面试?

今年互联网大环境的确不怎么好&#xff0c;互联网公司纷纷陷入裁员风波并缩减规模&#xff0c;这就导致更多程序员需要去竞争更少的就业岗位&#xff0c;搞的整个IT 行业越来越卷。作为Java程序员的我们就更不用说了&#xff0c;除去加班的可能性&#xff0c;每天上班8小时需要…

Java项目:SSM药品进货销售仓储信息管理系统

作者主页&#xff1a;源码空间站2022 简介&#xff1a;Java领域优质创作者、Java项目、学习资料、技术互助 文末获取源码 项目介绍 管理员角色包含以下功能&#xff1a; 管理员登录,用户信息管理,个人信息管理,药品信息管理,药品类别信息管理,选购药品管理,订单管理,订单记录管…

余生很短,及时止损--爱摸鱼的美工(九)

-----------作者&#xff1a;天涯小Y 余生很短&#xff0c;及时止损 今日份垃圾清理完毕 有的人就像垃圾车 他们装满了垃圾四处奔走 充满懊悔、愤怒.失望的情绪 随着垃圾越堆越高 就需要找地方倾倒&#xff0c;释放出来 他们会逮着一切机会 到处碰瓷、找茬、泄愤 如果你给他们…

Js逆向教程22-AST 抽象语法树babel安装

作者&#xff1a;虚坏叔叔 博客&#xff1a;https://xuhss.com 早餐店不会开到晚上&#xff0c;想吃的人早就来了&#xff01;&#x1f604; AST 抽象语法树babel安装 一、什么是AST js代码&#xff1a; var a1;json标识&#xff1a; 赋值语句左边为定义定义的名称为a(作用域…

python——面向对象

1、概念 ①OOP&#xff1a;Object Oriented Programming ②面向对象&#xff1a;只关心哪个对象完成这个功能&#xff0c;它关注的是完成功能的结果&#xff0c;以结果为导向 python、Java、js、c... ③面向过程&面向对象 ④面向对象三大特征&#xff1a;封装、继承、多…

springcloud(配置中心)

目录 1. 为何需要配置中心2. nacos的配置中心 2.1 配置示例2.2 多环境配置2.3 GROUP2.4 namespace 1. 为何需要配置中心 没有配置中心的情况下会出现什么情况&#xff1a; 如果没有配置中心&#xff0c;则各个服务的配置文件分散在各个项目中&#xff0c;不方便维护出于安全考…

代码审计学习 : xhcms

前言 从大佬那里听说&#xff0c;xhcms 很适合代码审计的新手。 环境 php 5.4.45 Apache 2.4.39 Mysql 5.7.26 文件上传配合文件包含 /index.php 和 /admin/index.php error_reporting(0); //关闭错误显示 $fileaddslashes($_GET[r]); //接收文件名 $action$file?index:…

FH30502输入3.7V升5V电流3A-5A同步整流升压芯片

3.3V升5V电流3A-5A同步整流升压芯片&#xff0c;2.7V到18V的输入电压支持供电系统和电池的较宽范围应用。FH30502根据负载情况的变化自动切换工作模式&#xff0c;在轻载Burst模式下静态电流处于低状态。FH30502使用自适应常数断开时间峰值电流模式控制。FH30502有一个内部特性…

C 语言实现经典贪吃蛇游戏

原文链接&#xff1a;C语言 贪吃蛇游戏 文章目录一、说明二、效果2.1 欢迎界面2.2 游戏规则2.3 得分排行2.4 退出游戏2.5 游戏界面2.6 游戏结束三、源码3.1 cmd.h3.2 cmd.c3.3 io.h3.4 io.c3.5 model.h3.6 service.h3.7 service.c3.8 ui.h3.9 ui.c3.10 utils.h3.11 utils.c3.12…

m蜂窝移动通信系统中越区切换的matlab仿真分析

目录 1.算法描述 2.仿真效果预览 3.MATLAB核心程序 4.完整MATLAB 1.算法描述 用Matlab仿真一个蜂窝模型&#xff0c;用户在打电话时产生切换的过程。建立蜂窝越区切换&#xff0c;假设有16个蜂窝&#xff0c;实现两个小区之间的硬切换&#xff0c;每个小区假设能容纳30个用…

UDS入门至精通系列:Service 14

文章目录 一、Service 14功能是什么二、UDS协议对服务的定义三、用图形说明Service 14四、手动测试总结一、Service 14功能是什么? 在汽车电子诊断领域,在新车型定义诊断需求时,会给每一个ECU的故障类型定义一个DTC,ECU中运行代码判定DTC是否产生(判定机制和原理我会在关于…

Gateway之限流、熔断

目录 一、Sentinel--服务容错 ① 简化启动我们的nacos 1.高并发带来的问题 ① 修改配置文件中tomcat的并发数 ② 使用压测工具&#xff0c;对请求进行压力测试 第一步&#xff1a;修改配置&#xff0c;并启动软件 第二步&#xff1a;添加线程组 第三步&#xff1a;配置线…

MySQL 小版本升级步骤

MySQL mysql 5.7.38 升级到 5.7.40 下载软件升级包 参考下载地址&#xff1a;https://dev.mysql.com/get/Downloads/MySQL-5.7/mysql-5.7.40-linux-glibc2.12-x86_64.tar.gz 上传软件包至服务器 可以使用rz命令或scp上传本地文件 比如上传至服务器目录为 /usr/local/software…

关于如何获取上周均值的实时数据思路,吾之解合君意否?

&#x1f4da; 在前端界面图形化展示中&#xff0c;目前主流以报表形式&#xff0c;或者以曲线图形式展示其所需数据的数字动态变化效果居多。在数据量不大或者不需要模糊对比的情况下&#xff0c;我们以报表展示为主&#xff1b;而我们需要从肉眼宏观可见的监控数据变化&#…

volatile解决有序性和可见性问题

线程可见性问题分析 什么是可见性&#xff1f; 如果一个线程对一个共享变量进行了修改 而其他线程不能及时地读取修改后的值 所以在多线程情况下该共享变量就会存在可见性问题 package com.alipay.alibabademo.thread;import lombok.extern.slf4j.Slf4j;import java.util.co…

改进遗传算法在TSP问题中的应用(Matlab代码实现)

&#x1f468;‍&#x1f393;个人主页&#xff1a;研学社的博客 &#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜…

玩转Python图片处理(OpenCV)

OpenCV是一个基于BSD许可&#xff08;开源&#xff09;发行的跨平台计算机视觉库&#xff0c;可以运行在Linux、Windows、Android和Mac OS操作系统上。它轻量级而且高效——由一系列 C 函数和少量 C 类构成&#xff0c;同时提供了Python、Ruby、MATLAB等语言的接口&#xff0c;…

Qt扫盲-QLabel使用总结

QLabel使用总结一、QLabel 显示内容二、注意事项1. 格式注意2. 不保留先前状态3. 格式对齐4. 伙伴焦点三、信号和槽函数使用1. 信号2. 槽函数总结&#xff1a;QLabel 其实就是一个用来只读显示的简易控件。适合数据量很小的内容显示。QLabel用于显示 文本或图像。 不提供用户交…