Redisson看门狗机制和mulitLock原理保姆级别

news2025/2/28 21:36:13

Redisson看门狗机制

这段代码主要实现了异步处理一个任务,并根据任务结果来执行不同的操作。

首先,调用handleNoSync方法进行异步处理,并返回一个表示异步计算结果的CompletionStage<Long>对象,这里使用了threadId和ttlRemainingFuture作为参数。

然后,通过CompletableFutureWrapper将上一步返回的CompletionStage包装起来,创建一个新的CompletableFutureWrapper对象。

接下来,调用ttlRemainingFuture.thenApply方法,注册一个回调函数来处理异步任务的结果。这个回调函数接收一个ttlRemaining参数,表示异步任务的结果。

在回调函数中,首先判断ttlRemaining是否为null。如果是null,则根据leaseTime的值执行不同的操作:

如果leaseTime大于0,则将internalLockLeaseTime设置为leaseTime的毫秒值。

如果leaseTime小于等于0,则调用scheduleExpirationRenewal方法进行过期时间的续期操作,传入threadId作为参数。

最后,回调函数返回ttlRemaining作为新的CompletionStage<Long>对象的结果。

整个代码段利用了CompletableFuture和CompletionStage来实现异步任务的处理和结果的回调。

创建了一个ExpirationEntry对象,并放入hashmap中,key为他的名字,vale为他自己,只有当这个entry实体不存才的时候才会放入map中,这样保证了每次放入的都是新的entry实体然后将它加入线程中,如果它是第一次创建则会执行renewExpiration完成续约

 首先从集合中获取实体名字,然后开启一个延时任务它有两个参数,一个是延迟任务本身还有一个是延迟时间internalLockLeaseTime / 3 internalLockLeaseTime默认为30毫秒,也就是这个延时任务每10秒执行一次。首先获取entry名字和线程id。

然后执行renewExpirationAsync方法开始重新设置有效时间redis.call('pexpire', KEYS[1], ARGV[1])会重置当前有效时间

 之后它会递归的调用自己实现一直续约,最后将这个任务添加到实体中,所以一开始的map会用putifabsent,因为已经存在的实体一定是已经续约过的。不需要重复添加。

 redisson释放锁

先从map中将对应锁的实体取出来,然后分别获线程id和定时任务删除,最终完成锁的释放

redisson的mulitLock原理

首先redisson会将所有的redisclient添加到一个集合中

 根据是否传入等待时间和超时时间来设置

locakWaitTime其实等于remainTime定义failedLocksLimit 默认为0,进入for循环遍历锁的集合如果传入等待时间和超时时间则执行重试,否则执行一次。如果获取锁成功则添加到acquiredLocks集合中表示已经获取成功的集合。如果获取失败进行if判断failedLockLimit的默认值为0,只有当全部锁等于已成获取锁的数量时if条件才会成立,从而退出循环只有将所有的锁都成功获取才能退出,只要有一把锁获取失败就重新开始获取。进入下一个if判断将之前获取到的锁删掉,如果没有传递waitTime说明不需要重试,直接退出,然后将之前的锁全部清空,将迭代器中的指针移到第一个重新开始遍历 

如果等待时间大于0则计算剩余等待时间,当前时间减去刚才获取锁所消耗的时间

remainTime -= System.currentTimeMillis() - time;

time = System.currentTimeMillis();

如果剩余等待时间小于0则将所有成功获取的锁释放,只有将所有的锁都成功获取才能退出,只要有一把锁获取失败就重新开始获取

最后的if逻辑是为了保证所有锁的过期时间是一致的,过期时间是从获取锁成功后就开始减少,防止第一把锁的过期时间短而最后一把锁的过期时间长,最后返回true直到所有锁被成功获取

 

 

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

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

相关文章

mathtype7.8永久激活码下载并安装激活MathType7.8破解版

“我好像被数学公式PUA了……” 最近&#xff0c;有位朋友跟我吐槽&#xff1a;自己每次做数学题、写论文&#xff0c;只要遇到复杂的公式和符号&#xff0c;就会特别焦虑。她觉得&#xff0c;自己好像被数学公式PUA了。 “明明知道它很重要&#xff0c;但就是不想面对它。” 其…

[Git][多人协作][下]详细讲解

目录 1.不同分支下多人协作2.远程分⽀删除后&#xff0c;本地git branch -a依然能看到 1.不同分支下多人协作 ⼀般情况下&#xff0c;如果有多需求需要多⼈同时进⾏开发&#xff0c;是不会在⼀个分⽀上进⾏多⼈开发&#xff0c;⽽是⼀个需求或⼀个功能点就要创建⼀个feature分…

CSS技巧专栏:一日一例 19 -纯CSS实现超酷的水晶按钮特效

CSS技巧专栏:一日一例 19 -纯CSS实现超酷的水晶按钮特效 今天给大家分享一个纯CSS按钮水晶按钮,效果很赞,希望对大家有所帮助。 本例图片 案例分析 这个按钮看起来效果很赞,我们分析一下它由几个层组成: 1. 按钮本体:渐变层+按钮文字 2.用before伪元素实现高光层+内…

Visual Studio 和 Visual Studio Code 的比较与应用偏向

Visual Studio 和 Visual Studio Code&#xff08;VS Code&#xff09;是微软开发的两个不同的开发工具&#xff0c;各有特点和优势&#xff0c;适用于不同的开发需求。下面是详细的比较和在实际应用中的偏向。 功能和特性 Visual Studio 完整的IDE&#xff1a;支持多种编程…

reNgine:终极 Web 侦察和漏洞扫描器

reNgine 是一个针对 Web 应用程序的开源自动侦察框架&#xff0c;专注于高度可配置和简化的侦察过程。 reNgine 的开发是为了克服传统侦察工具的限制。它是漏洞赏金猎人、渗透测试人员和企业安全团队的不错选择&#xff0c;可以自动化和完善他们的信息收集流程。 reNgine 是作为…

LeetCode 热题 HOT 100 (019/100)【宇宙最简单版】[创作中]

【链表】No. 0142 环形链表 II【中等】&#x1f449;力扣对应题目指路 希望对你有帮助呀&#xff01;&#xff01;&#x1f49c;&#x1f49c; 如有更好理解的思路&#xff0c;欢迎大家留言补充 ~ 一起加油叭 &#x1f4a6; 欢迎关注、订阅专栏 【力扣详解】谢谢你的支持&#…

AutoGPT 最最最新安装教程

介绍 本指南将帮助您为项目设置服务器和构建器。 先决条件 要设置服务器&#xff0c;您需要安装以下内容&#xff1a; Node.jsPython 3.10 检查是否已安装 Node.js 和 Python 您可以通过运行以下命令来检查是否已安装 Node.js&#xff1a; node -v您可以通过运行以下命…

剪画小程序:录音,怎么一键变成文字!

在学习的道路上&#xff0c;我们总是不断地参加各种讲座、研讨会&#xff0c;渴望汲取更多的知识。 但有时候&#xff0c;一场精彩的讲座结束后&#xff0c;想要回顾其中的重点内容&#xff0c;却发现仅凭记忆难以完整重现。 又或者在与朋友的深度交流中&#xff0c;大家碰撞出…

套接字编程

网络套接字编程 先将数据通过os&#xff0c;将数据发送到目标主机&#xff08;手段&#xff09;TCP/IP协议完成&#xff0c;再在本主机将收到的数据推送到自己上层指定的进程&#xff0c;这时候网络通信本质上就成了进程间的通信。其中ip地址可以标识互联网上唯一的一台主机&a…

Codeforces Round 964 (Div. 4) A~G

封面原图 画师ideolo A - AB Again? 题意 给你一个两位数&#xff0c;把他的个位和十位加起来 代码 #include <bits/stdc.h> using namespace std; typedef long long ll; typedef double db; typedef pair<int,int> pii; typedef pair<ll,ll> pll;voi…

嵌入式学习之路 13(C语言基础学习——预处理命令)

编程流程 在进行程序开发时&#xff0c;通常遵循编辑源代码、编译、运行和调试这几个主要步骤。 编辑源代码&#xff1a;使用文本编辑器创建或修改程序的源代码&#xff0c;这是整个编程过程的起点。编译&#xff1a;将源代码转换为可执行文件的关键步骤。 预处理&#xff1a…

LeetCode.27.移除元素

题目描述&#xff1a; 给你一个数组 nums 和一个值 val&#xff0c;你需要 原地 移除所有数值等于 val 的元素。元素的顺序可能发生改变。然后返回 nums 中与 val 不同的元素的数量。 假设 nums 中不等于 val 的元素数量为 k&#xff0c;要通过此题&#xff0c;您需要执行以…

Mojo使用调试工具(Visual Studio Code)详解

Visual Studio Code 的 Mojo 扩展使您可以将 VS Code 的内置调试器与 Mojo 程序一起使用。(Mojo 扩展还支持调试 C、C++ 和 Objective-C。) 有关 VS Code 调试功能的完整介绍,请参阅 Visual Studio Code 中的调试。 本文介绍了可通过 Mojo 扩展获得的功能,以及 Mojo 调试…

【k8s集群部署篇】在openEuler环境下部署多master高可用kubernetes集群详细教程(V1.30版本)

【k8s集群部署篇】在openEuler环境下部署多master高可用kubernetes集群详细教程(V1.30版本) 一、相关名词介绍1.1 k8s简介1.2 Keepalived简介1.3 HAProxy简介二、本次实践介绍2.1 环境规划介绍2.2 本次实践简介三、所有节点基础环境配置3.1 主机配置工作3.2 关闭防火墙和seli…

[Unity实战]Mirror网络与Addressable场景管理

前言 很遗憾&#xff0c;Mirror包括UNET的场景管理不支持Addressables。我做手机游戏&#xff0c;需要实现服务器广播场景切换&#xff0c;但主程序没有场景&#xff0c;热更代码和资源都在AB包里。我已经在Google上搜索了一段时间&#xff0c;没有找到有用的解决方案。 Redd…

KVM——虚拟机中使用命令行形式安装虚拟机

目录 一. 删除虚拟机中的虚拟机步骤 二. 虚拟机中以命令行形式安装虚拟机 一. 删除虚拟机中的虚拟机步骤 这样就删除成功了。 二. 虚拟机中以命令行形式安装虚拟机 安装 [rootkvm-server ~]# virt-install --connect qemu:///system -n vm10 -r 3100 --disk path/var/lib…

【Material-UI】复杂按钮 (Complex Button) 自定义详解

文章目录 一、ButtonBase 组件简介二、实例讲解&#xff1a;创建复杂的图片按钮1. 样式定义2. 核心组件构建3. 交互效果 三、高级自定义技巧1. 响应式设计2. 动态内容与动画 四、总结 在现代 Web 应用中&#xff0c;按钮不仅仅是一个点击交互元素&#xff0c;它们也承载着传递信…

批发行业进销存-登录适配 android 横竖屏幕 源码CyberWinApp-SAAS 本地化及未来之窗行业应用跨平台架构

一、横竖屏切换的意义 以下是移动端横屏竖屏可切换在进销存中的一些重要应用&#xff1a; a、数据录入与查看 在录入商品信息、库存数量等大量数据时&#xff0c;横屏模式可以提供更宽阔的输入区域&#xff0c;减少输入错误。例如&#xff0c;在输入长串的商品编码或详细的商…

数值分析【1】

第一章&#xff1a; 相对误差 四 规格化浮点数 秦九韶 第二章&#xff1a; 二分法 不动点迭代法 Taylor 埃特金加速 构造新的同根函数 有个公式 牛顿法&#xff08;切线法&#xff09;、弦截法&#xff08;割线法&#xff09;

谷粒商城实战笔记-137-商城业务-首页-整合dev-tools渲染一级分类数据

文章目录 一&#xff0c;使用热加载工具spring-boot-devtools1&#xff0c;引入devtools依赖2&#xff0c;ctrlshiftf9 编译静态资源 二&#xff0c;thymeleaf原理三&#xff0c;渲染一级分类 一&#xff0c;使用热加载工具spring-boot-devtools 因为我们采用的前后端一体的开…