深度解析Redisson框架的分布式锁运行原理与高级知识点
推荐阅读
项目实战:AI文本 OCR识别最佳实践
AI Gamma一键生成PPT工具直达链接
玩转cloud Studio 在线编码神器
玩转 GPU AI绘画、AI讲话、翻译,GPU点亮AI想象空间
资源分享
史上最全文档AI绘画stablediffusion资料分享
AI绘画关于SD,MJ,GPT,SDXL百科全书
AI绘画 stable diffusion Midjourney 官方GPT文档 AIGC百科全书资料收集
「java、python面试题」来自UC网盘app分享,打开手机app,额外获得1T空间
https://drive.uc.cn/s/2aeb6c2dcedd4
AIGC资料包
https://drive.uc.cn/s/6077fc42116d4
https://pan.xunlei.com/s/VN_qC7kwpKFgKLto4KgP4Do_A1?pwd=7kbv#
分布式系统中的锁管理一直是一个复杂而关键的问
题。在这个领域,Redisson框架凭借其出色的性能和功能成为了开发者的首选之一。本篇博客将深入探讨Redisson框架的分布式锁运行原理以及涉及的高级知识点。通过详细的解释和示例代码,您将更好地理解如何在分布式环境中使用Redisson框架来实现分布式锁。
引言
分布式系统中,多个节点需要协同工作来完成任务,但在某些情况下,为了保证数据的一致性和正确性,需要引入分布式锁。Redisson是一个基于Redis的Java框架,提供了分布式锁的实现,它不仅易于使用,而且性能卓越。在深入探讨Redisson分布式锁的原理之前,我们先了解一下分布式锁的基本概念。
分布式锁的基本概念
分布式锁是一种用于控制分布式系统中多个节点对共享资源的访问的机制。它可以确保在任何给定时刻,只有一个节点可以持有锁,并且只有持有锁的节点可以执行关键代码块。分布式锁通常需要满足以下条件:
- 互斥性:同一时刻只能有一个节点持有锁。
- 可重入性:允许持有锁的节点在释放锁后再次获取锁。
- 安全性:确保即使节点崩溃或网络故障,锁也不会被永久占用。
- 高性能:锁的获取和释放应该是高效的操作。
Redisson框架在满足这些条件的同时,还提供了一些高级功能,使得分布式锁更加强大和灵活。
Redisson框架概述
Redisson是一个基于Redis的Java框架,它提供了多种分布式对象和服务的实现,包括分布式锁、分布式集合、分布式消息队列等。本文主要关注Redisson框架的分布式锁实现。
Redisson的分布式锁不仅仅提供了常规锁的功能,还包括以下特性:
- 可重入锁:同一线程可以多次获取同一个锁。
- 公平锁:基于Redis的有序集合实现,保证等待最久的线程最先获取锁。
- 联锁:支持同时获取多个锁,防止死锁。
- 红锁:在多个Redis节点上获取锁,确保高可用性。
- 读写锁:支持读锁和写锁,允许多个读操作同时进行。
Redisson分布式锁的运行原理
Redisson框架的分布式锁是基于Redis的数据结构实现的,它主要使用了以下两种数据结构:
- Redis的字符串(String):用于存储锁的持有者和锁的有效期。
- Redis的有序集合(Sorted Set):用于实现锁的公平性和释放锁的操作。
下面我们将深入探讨Redisson分布式锁的运行原理:
锁的获取
- 当一个线程尝试获取锁时,Redisson会在Redis中创建一个字符串类型的键值对,键是锁的名称,值是线程的唯一标识(通常是线程ID)。
- 如果获取锁成功,Redisson会设置一个过期时间,以防止锁被长时间占用。过期时间通常使用随机值,以避免锁过期时间冲突。
- 如果获取锁失败,Redisson会等待一段时间,然后重试。这个等待时间通常是随机的,以减少锁争用。
锁的释放
- 当一个线程释放锁时,Redisson会检查锁的持有者是否与当前线程匹配。如果匹配,Redisson会删除锁的键值对,释放锁。
- 如果持有锁的线程在锁过期后仍然未释放锁,其他线程可以尝试获取锁。
锁的公平性
Redisson的公平锁是通过有序集合实现的。每个锁都对应一个有序集合,集合中的成员是等待锁的线程,分数是线程的等待时间戳。获取锁时,Redisson会将线程添加到有序集合中,并按照时间戳排序。当释放锁时,Redisson会从有序集合中移除线程,使等待时间最长的线程获取锁,从而实现公平性。
高级知识点
除了基本的分布式锁原理,Redisson框架还涉及一些高级知识点,这些知识点可以帮助您更好地理解和使用Redisson分布式锁:
1. 联锁
Redisson的联锁允许同时获取多个锁,以避免死锁情况的发生。当多个线程需要获取多个锁时,如果按照相同的顺序获取锁,可以有效地避免死锁。
示例代码:
RBatch batch = redisson.createBatch();
RLock lock1 = batch.getLock("lock1");
RLock lock2 = batch.getLock("lock2");batch.execute();boolean hasLocks = redisson.getLock(lock1, lock2);
if (hasLocks) {try {// 执行需要锁保护的代码} finally {redisson.unlock(lock1, lock2);}
}
在上面的示例中,我们使用了RLock
来创建两个锁对象,并使用redisson.getLock()
来获取这两个锁。然后,在执行需要锁保护的代码块之前,我们使用redisson.unlock()
来释放这两个锁。这样,可以确保在获取多个锁时不会发生死锁。
2. 红锁
Redisson的红锁是一种高可用性的分布式锁,它可以在多个Redis节点上获取锁,以确保即使部分节点故障,也能够正常获取锁。红锁的实现基于Quorum算法,确保在大多数节点可用时才能获取锁。
示例代码:
RRedLock redLock = new RRedLock("lock1", "lock2", "lock3");boolean hasLocks = redLock.tryLock(10, TimeUnit.SECONDS);
if (hasLocks) {try {// 执行需要锁保护的代码} finally {redLock.unlock();}
}
在上面的示例中,我们使用RRedLock
来创建一个红锁对象,然后使用redLock.tryLock()
来尝试获取锁。如果大多数节点成功获取锁,就会执行锁保护的代码。
3. 读写锁
Redisson支持读写锁,允许多个线程同时读取共享资源,但只允许一个线程写入资源。这在某些场景下可以提高性能。
示例代码:
RReadWriteLock rwLock = redisson.getReadWriteLock("myReadWriteLock");
RLock readLock = rwLock.readLock();
RLock writeLock = rwLock.writeLock();// 获取读锁
readLock.lock();
try {// 执行读操作
} finally {readLock.unlock();
}// 获取写锁
writeLock.lock();
try {// 执行写操作
} finally {writeLock.unlock();
}
在上面的示例中,我们使用RReadWriteLock
来创建一个读写锁对象,并分别使用readLock
和writeLock
来获取读锁和写锁。这样,可以实现多个线程同时读取资源,但只有一个线程能够写入资源。
示例代码演示
下面是一个简单的示例,演示了如何使用Redisson框架来实现分布式锁,以及如何使用高级功能:
public class DistributedLockDemo {public static void main(String[] args) {Config config = new Config();config.useSingleServer().setAddress("redis://localhost:6379");RedissonClient redisson = Redisson.create(config);RLock lock = redisson.getLock("myLock");try {boolean isLocked = lock.tryLock(10, 60, TimeUnit.SECONDS);if (isLocked) {System.out.println("Lock acquired. Performing some critical task...");Thread.sleep(5000); // Simulate some critical taskSystem.out.println("Critical task completed.");} else {System.out.println("Failed to acquire lock. Another process holds it.");}} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}redisson.shutdown();}
}
在这个示例中,我们创建了一个Redisson客户端,获取了一个名为"myLock"的锁,然后尝试获取锁并执行关键任务。如果锁被其他线程持有,它将等待一段时间,然后重试。最后,我们释放锁并关闭Redisson客户端。
结论
通过本文的详细解释和示例代码,您现在应该对Redisson框架的分布式锁原理和高级知识点有了更深入的了解。Redisson框架不仅提供了基本的分布式锁功能,还支持可重入锁、公平锁、联锁、红锁、读写锁等高级功能,使得分布式锁的管理变得更加灵活和可靠。
如果您在分布式系统中需要使用分布式锁来管理共享资源的访问,Redisson框架是一个强大且成熟的解决方案。希望本文对您有所帮助,如果您有任何问题或意见,请在下面的评论中分享,让我们一起探讨分布式锁的奥秘!同时,如果您觉得这篇文章对您有帮助,请点赞、评论并分享给更多的开发者。谢谢您的阅读!
相关文章:
深度解析Redisson框架的分布式锁运行原理与高级知识点
推荐阅读 项目实战:AI文本 OCR识别最佳实践 AI Gamma一键生成PPT工具直达链接 玩转cloud Studio 在线编码神器 玩转 GPU AI绘画、AI讲话、翻译,GPU点亮AI想象空间 资源分享 史上最全文档AI绘画stablediffusion资料分享 AI绘画关于SD,MJ,GPT,SDXL百科全书 AI绘画 stable…...
C#扩展方法
参数列表中this的这种用法是在.NET 3.0之后新增的一种特性---扩展方法。通过这个属性可以让程序员在现有的类型上添加扩展方法(无需创建新的派生类型、重新编译或者以其他方式修改原始类型)。 扩展方法是一种特殊的静态方法,虽然是静态方法&a…...
uniapp 高度铺满全屏
问题:在有uni-tabbar的情况下,页面铺满剩下的部分 <template><view :style"{height:screenHeightpx}" class"page"></view> </template> <script>export default {data() {return {screenHeight: &q…...
UG\NX二次开发 判断向量在指定的公差内是否为零,判断是否是零向量 UF_VEC3_is_zero
文章作者:里海 来源网站:王牌飞行员_里海_里海NX二次开发3000例,里海BlockUI专栏,C\C++-CSDN博客 简介: UG\NX二次开发 判断向量在指定的公差内是否为零,判断是否是零向量 UF_VEC3_is_zero 效果: 代码: #include "me.hpp"void ufusr(char* param, int* retco…...
2023年MySQL实战核心技术第一篇
目录 四 . 基础架构:一条SQl查询语句是如何执行的? 4.1 MySQL逻辑架构图: 4.2 MySQL的Server层和存储引擎层 4.2.1 连接器 4.2.1.1 解释 4.2.1.2 MySQL 异常重启 解决方案: 4.2.1.2.1. 定期断开长连接: 4.2.1.2.2. 初始…...
hivesql执行过程
语法解析 SemanticAnalyzer SemanticAnalyzer是Hive中的语义分析器,负责检查Hive SQL程序的语义是否正确。SemanticAnalyzer会对Hive SQL程序进行以下检查: 检查过程 语法检查 SemanticAnalyzer会检查Hive SQL程序的语法是否正确,包括关…...
C语言学习:8、深入数据类型
数据超过类型规定的大小怎么办 C语言中,如果需要用的整数大于int类型的最大值了怎么办? 我们知道int能表示的最大数是2147483647,最小的数是-2147483648,为什么? 因为字32位系统中,寄存器是32位的&#…...
生成树协议 STP(spanning-tree protocol)
一、STP作用 1、消除环路:通过阻断冗余链路来消除网络中可能存在的环路。 2、链路备份:当活动路径发生故障时,激活备份链路,及时恢复网络连通性。 二、STP选举机制 1、目的:找到阻塞的端口 2、STP交换机的角色&am…...
【LeetCode】312.戳气球
题目 有 n 个气球,编号为0 到 n - 1,每个气球上都标有一个数字,这些数字存在数组 nums 中。 现在要求你戳破所有的气球。戳破第 i 个气球,你可以获得 nums[i - 1] * nums[i] * nums[i 1] 枚硬币。 这里的 i - 1 和 i 1 代表和…...
商业数据分析概论
🐳 我正在和鲸社区参加“商业数据分析训练营活动” https://www.heywhale.com/home/competition/6487de6649463ee38dbaf58b ,以下是我的学习笔记: 学习主题:波士顿房价数据快速查看 日期:2023.9.4 关键概念/知识点&…...
Golang GUI框架
Golang GUI框架fyne fyne简介第一个fyne应用fyne应用程序和运行循环fyne更新GUI内容fyne窗口处理fyne解决中文乱码问题fyne应用打包fyne画布和画布对象fyne容器和布局fyne绘制和动画fyne盒子布局fyne网格grid布局fyne网格包裹布局fyne边框布局fyne表单布局fyne中心布局fyne ma…...
LeetCode刷题笔记【24】:贪心算法专题-2(买卖股票的最佳时机II、跳跃游戏、跳跃游戏II)
文章目录 前置知识122.买卖股票的最佳时机II题目描述贪心-直观写法贪心-优化代码更简洁 55. 跳跃游戏题目描述贪心-借助ability数组贪心-只用int far记录最远距离 45.跳跃游戏II题目描述回溯算法贪心算法 总结 前置知识 参考前文 参考文章: LeetCode刷题笔记【23】…...
游戏出现卡顿有哪些因素
一、服务器CPU内存占用过大会导致卡顿,升级CPU内存或者优化自身程序占用都可以解决。 二、带宽跑满导致卡,可以升级带宽解决。 二、平常不卡,有大型的活动的时候会卡,这方面主要是服务器性能方面不够导致的,性能常说…...
学习Bootstrap 5的第八天
目录 加载器 彩色加载器 实例 闪烁加载器 实例 加载器大小 实例 加载器按钮 实例 分页 分页的基本结构 实例 活动状态 实例 禁用状态 实例 分页大小 实例 分页对齐 实例 面包屑(Breadcrumbs) 实例 加载器 彩色加载器 在 Bootstr…...
vue中自定义指令
什么是指令 在Vue.js中,指令是一种特殊的 token,用于在模板中以声明式方式将响应式数据绑定到 DOM 元素上,从而实现与 DOM 元素的交互和操作。指令以 “v-” 前缀开始,后跟指令的名称,例如 v-model、v-bind 和 v-on。…...
Python:安装Flask web框架hello world
安装easy_install pip install distribute 安装pip easy_install pip 安装 virtualenv pip install virtualenv 激活Flask pip install Flask 创建web页面demo.py from flask import Flask app Flask(__name__)app.route(/) def hello_world():return Hello World! 2023if _…...
小程序点击复制功能制作
在wxml文件中添加一个按钮或需要点击的元素,并绑定点击事件监听器2 <button bindtap"copyText">点击复制</button> 2 在对应的js文件中定义点击事件处理函数,并在函数中调用小程序的API进行复制操作, copyText(e){co…...
20230909java面经整理
1.java常用集合 ArrayList动态数组,动态调整大小,实现List接口 LinkedList双向链表,实现list和queue接口,适用于频繁插入和删除操作 HashSet无序,使用哈希表实现 TreeSet有序,使用红黑树实现 HashMap无序&…...
常用的css命名规则
一、命名规则说明: 1)、所有的命名最好都小写 2)、属性的值一定要用双引号(“”)括起来 3)、给图片加上alt标签 4)、尽量使用英文命名原则 5)、尽量不缩写,除非一看就明白的单词 二、相对网页外…...
【Linux编程Shell自动化脚本】03 shell四剑客(find、sed、grep、awk)
文章目录 一、find1. 常用expression2. 时间参数3. 其他选项参数3.1 查找深度3.2 执行命令 二、sed1. 常用命令选项2. 常用动作脚本命令2.1 s 替换2.2 已匹配字符串标记&2.3 在当前行前后插入文本 a\ 和 i\2.4 p 打印指定行2.5 匹配行的方式2.5.1 以数字形式指定行区间2.5.…...
java的springboot框架中使用logback日志框架使用RabbitHandler注解为什么获取不到消费的traceId信息?
当使用 Logback 日志框架和 RabbitMQ 的 RabbitHandler 注解时,如果无法获取消费的 traceId 信息,可能是因为在处理 RabbitMQ 消息时,没有正确地将 traceId 传递到日志中。 为了将 traceId 传递到日志中,你可以利用 MDCÿ…...
初探Vue.js及Vue-Cli
一、使用vue框架的简单示例 我们本次的vue系列就使用webstorm来演示: 对于vue.js的安装我们直接使用script的cdn链接来实现 具体可以参考如下网址: https://www.bootcdn.cn/ 进入vue部分,可以筛选版本,我这里使用的是2.7.10版本的ÿ…...
大数据课程K21——Spark的SparkSQL基础语法
文章作者邮箱:yugongshiye@sina.cn 地址:广东惠州 ▲ 本章节目的 ⚪ 掌握Spark的SparkSQL通过方法来使用; ⚪ 掌握Spark的SparkSQL通过sql语句来调用; 一、SparkSQL基础语法——通过方法来使用 1. 查询 df.select("id","name").show()…...
【实践篇】Redis最强Java客户端(三)之Redisson 7种分布式锁使用指南
文章目录 0. 前言1. Redisson 7种分布式锁使用指南1.1 简单锁:1.2 公平锁:1.3 可重入锁:1.4 红锁:1.5 读写锁:1.6 信号量:1.7 闭锁: 2. Spring boot 集成Redisson 验证分布式锁3. 参考资料4. 源…...
卫星通话过后,卫星导航产业被彻底激活
华为新手机发布后,其主打的卫星通话功能备受热议。在卫星产业链发展的背后,下一个大产业在哪里让人颇为好奇。 目前,卫星导航颇被看好,或将引领下一个技术狂潮。它的特点是产业大、发展快、参与者多。继电动汽车、新能源和芯片产…...
【算法训练-链表 七】【排序】:链表排序、链表的奇偶重排、重排链表
废话不多说,喊一句号子鼓励自己:程序员永不失业,程序员走向架构!本篇Blog的主题是【链表的排序】,使用【链表】这个基本的数据结构来实现,这个高频题的站点是:CodeTop,筛选条件为&am…...
LGB的两种写法
方法一 import lightgbm as lgb import pandas as pd from sklearn.model_selection import train_test_split, KFold from sklearn.metrics import accuracy_score# 读取训练集和测试集数据 train_data pd.read_csv(train.csv) test_data pd.read_csv(test.csv)# 分割特征和…...
【Unity的HDRP下ShaderGraph实现权重缩放全息投影_(内附源码)】
实现权重缩放全息投影 效果如下 效果如下 顶点位置偏移 链接: 提取码:1234...
透视俄乌网络战之二:Conti勒索软件集团(上)
透视俄乌网络战之一:数据擦除软件 Conti勒索软件集团(上) 1. Conti简介2. 组织架构3. 核心成员4. 招募途径5. 工作薪酬6. 未来计划参考 1. Conti简介 Conti于2019年首次被发现,现已成为网络世界中最危险的勒索软件之一࿰…...
【华为OD机试python】拔河比赛【2023 B卷|100分】
【华为OD机试】-真题 !!点这里!! 【华为OD机试】真题考点分类 !!点这里 !! 题目描述 公司最近准备进行拔河比赛,需要在全部员工中进行挑选。 选拔的规则如下: 按照身高优先、体重次优先的方式准备比赛阵容; 规定参赛的队伍派出10名选手。 请实现一个选拔队员的小程序。 输…...
网站建设如何做/媒体发布公司
欢迎访问我的个人博客 传送门 任务和返回栈 应用通常包含多个 Activity ,每个 Activity 均应围绕用户可以执行的特定操作设计,并且能够启动其他 Activity,一个 Activity 可以启动设备上其他应用中的 Activity,即使两个 Activity 可…...
怎么建单位的网站/soso搜搜
一直想把 Android 的 APIDEMO 里面的DEMO 写出来,一来可以方便自己查看,二来方便大家能够早一点切入,从基础的控件到界面布局乃至到OPEN GL 等深入知识。不过惰性使然,一直迟迟未动手,今天外面下着大雨,没心…...
wordpress插件小蜜蜂/网页制作软件免费版
建立拓扑,在实验4所实现的二层交换机基础之上 将Router0的gi0/0/0接口与switch0的fa0/22相连,且由于fa0/22是单臂路由的接口,需要传递两个vlan之间的信息(和实验4中连接两台交换机的fa0/21一样),因此fa0/22…...
ai做漫画头像网站/首码项目推广平台
json.load()从json文件中读取数据 json.loads()将str类型的数据转换为dict类型 json.dumps()将dict类型的数据转成str json.dump()将数据以json的数据类型写入文件中 参考文献 https://blog.csdn.net/weixin_43631296/article/details/105253434...
html查询网站制作/宁波好的seo外包公司
“为什么上周没发布?”作为管理人员,很容易将延迟发布的责任归咎于开发团队成员。但是你是否有认真想过,这些“慢悠悠”的我们采集了大量关于程序员开发周期的数据,主要记录他们需要多久才能完成不同类型(Stories、Tests、Bugs)和…...
做网站开发学什么语言/关键词搜索排名推广
ArrayList遍历:取出ArrayList集合中的数据方式一:for循环方式二:增强for循环:foreach方式三:Iterator:迭代器方式四:ListIterator:双向迭代器免费视频教程推荐:java在线教…...