【Redis】Redis实现分布式锁合理的控制锁的有效时长的方法

在分布式系统中,合理地控制 Redis 分布式锁的有效时长(即过期时间)非常重要,以确保锁既能防止死锁又能提供高可用性。设置合理的过期时间可以防止客户端在持有锁期间崩溃而导致其他客户端无法获取锁的情况,同时也能确保锁在操作未完成时不会过早失效。

以下是实现合理控制 Redis 分布式锁有效时长的方法和注意事项:

方法一:估算操作时间并加上缓冲时间

最简单的方法是根据操作的预期时间设置锁的有效时长。通常会估算操作需要的时间,并加上一些缓冲时间,以应对网络延迟和其他不确定因素。

示例代码

public class RedisDistributedLock {private Jedis jedis;private String lockKey;private int expireTime; // 锁的过期时间(秒)public RedisDistributedLock(Jedis jedis, String lockKey, int expireTime) {this.jedis = jedis;this.lockKey = lockKey;this.expireTime = expireTime;}public boolean acquireLock(String requestId) {String result = jedis.set(lockKey, requestId, "NX", "EX", expireTime);return "OK".equals(result);}public boolean releaseLock(String requestId) {String script ="if redis.call('get', KEYS[1]) == ARGV[1] then " +"return redis.call('del', KEYS[1]) " +"else " +"return 0 " +"end";Object result = jedis.eval(script, 1, lockKey, requestId);return "1".equals(result.toString());}
}

在上述代码中,expireTime 应根据操作的预期时间加上缓冲时间来设置。

方法二:锁续命(Lock Renewal)

对于一些可能超过预期时间的长时间操作,可以使用锁续命机制。在锁快要过期时,客户端可以通过续命机制延长锁的有效时间。

实现思路

  1. 在锁快要过期时,客户端定期检查锁是否仍然持有,并尝试续命。
  2. 续命可以通过重新设置过期时间实现。

示例代码

public class RedisDistributedLock {private Jedis jedis;private String lockKey;private int expireTime; // 锁的过期时间(秒)private volatile boolean keepExtending = true;public RedisDistributedLock(Jedis jedis, String lockKey, int expireTime) {this.jedis = jedis;this.lockKey = lockKey;this.expireTime = expireTime;}public boolean acquireLock(String requestId) {String result = jedis.set(lockKey, requestId, "NX", "EX", expireTime);if ("OK".equals(result)) {startRenewalTask(requestId);return true;}return false;}public boolean releaseLock(String requestId) {keepExtending = false;String script ="if redis.call('get', KEYS[1]) == ARGV[1] then " +"return redis.call('del', KEYS[1]) " +"else " +"return 0 " +"end";Object result = jedis.eval(script, 1, lockKey, requestId);return "1".equals(result.toString());}private void startRenewalTask(String requestId) {Thread renewalThread = new Thread(() -> {while (keepExtending) {try {Thread.sleep(expireTime * 1000 / 2);String script ="if redis.call('get', KEYS[1]) == ARGV[1] then " +"return redis.call('expire', KEYS[1], ARGV[2]) " +"else " +"return 0 " +"end";jedis.eval(script, 1, lockKey, requestId, String.valueOf(expireTime));} catch (InterruptedException e) {Thread.currentThread().interrupt();}}});renewalThread.setDaemon(true);renewalThread.start();}
}

在上述代码中:

  • startRenewalTask 方法启动一个后台线程,在锁的过期时间的一半时尝试续命。
  • keepExtending 标志用于控制续命线程的生命周期。

方法三:使用 Watchdog 机制

类似于锁续命机制,但更加高级的是 Watchdog 机制。在许多分布式锁实现中(例如 Apache Curator 的分布式锁),Watchdog 机制会自动续命直到客户端明确释放锁。

实现思路

  1. 获取锁时,启动 Watchdog 线程,该线程定期检查并续命。
  2. 释放锁时,停止 Watchdog 线程。

注意事项

  1. 锁的过期时间:设置过期时间时,需要根据操作的复杂度和预期执行时间设置一个合理的值,避免锁过早过期。
  2. 锁续命机制:确保续命操作是安全且高效的,避免过多的续命操作增加 Redis 的负担。
  3. 网络和系统故障:考虑网络延迟和系统故障的情况,确保锁机制在这些情况下仍然有效。
  4. 锁的标识:确保每个锁操作都有唯一的标识,避免误删锁(例如使用 UUID 作为锁的标识)。

通过合理设置锁的有效时长,并结合锁续命或 Watchdog 机制,可以有效地控制 Redis 分布式锁的有效性,确保系统在高并发和分布式环境下的稳定性和一致性。

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

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

相关文章

[数据集][目标检测]足球场足球运动员身份识别足球裁判员数据集VOC+YOLO格式312张4类别

数据集格式:Pascal VOC格式YOLO格式(不包含分割路径的txt文件,仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数):312 标注数量(xml文件个数):312 标注数量(txt文件个数):312 标注类别…

调查显示各公司在 IT 安全培训方面存在差距

网络安全提供商 Hornetsecurity 最近进行的一项调查显示,许多组织的 IT 安全培训存在严重缺陷。 这项调查是在伦敦举行的 Infosecurity Europe 2024 期间发布的,调查发现 26% 的组织没有为其最终用户提供任何 IT 安全培训。 这些调查结果来自世界各地的…

阿里云活动推荐:AI 应用 DevOps 新体验

活动简介 阿里云新活动,体验阿里云的云效应用交付平台。体验了下,总体感觉还不错。平台把常规的开发过程封装成了模板,部署发布基本都是一键式操作,并且对自定义支持的比较好。 如果考虑将发布和部署搬到云上,可以玩一…

代码随想录算法训练营DAY32|122.买卖股票的最佳时机II、55. 跳跃游戏、45.跳跃游戏II

122.买卖股票的最佳时机II 题目链接:122.买卖股票的最佳时机II class Solution(object):def maxProfit(self, prices):""":type prices: List[int]:rtype: int"""max_profit 0profit 0buyin_idx 0for i in range(len(prices)):p…

力扣第185题:部门工资前三高的员工

关注微信公众号 数据分析螺丝钉 免费领取价值万元的python/java/商业分析/数据结构与算法学习资料 在本篇文章中,我们将详细解读力扣第185题“部门工资前三高的员工”。通过学习本篇文章,读者将掌握如何使用SQL语句来解决这一问题,并了解相关…

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

加个启动参数: --allow-running-insecure-content没了 参考文章:List of Chromium Command Line Switches

Directory Opus 13.6 可用的apk文件右键菜单脚本

// apk文件的右键经过adb安装的脚本,可以在多个设备中选择function OnClick(clickData) {try {// 检查是否选中了文件if (clickData.func.sourcetab.selected_files.count 0) {DOpus.Output("没有选中任何文件");return;}// 获取选中的文件名var selectedFile clic…

JSTL知识点讲解与配置

JSTL(JavaServer Pages Standard Tag Library)是Java EE平台中的一个标准库,提供了一组用于在JSP(JavaServer Pages)中简化和标准化常见任务的标签。这些标签封装了很多常见的JSP功能,可以使得JSP页面更加简…

18-Nacos-NacosRule负载均衡

18-Nacos-NacosRule负载均衡 1.根据集群负载均衡 1.修改order-service中的application.yml,设置集群为HZ: spring:cloud:nacos:server-addr: localhost:8848 #nacos服务端地址discovery:cluster-name: HZ #配置集群名,也就是机房位置,例如:HZ,杭州2.然后在order-servi…

服务部署:Ubuntu安装搭建docker

1. 更新系统包 首先,确保你的系统包是最新的: sudo apt-get update sudo apt-get upgrade 2. 安装必要的依赖包 安装一些必要的依赖包,以便后续添加 Docker 的 APT 源: sudo apt-get install apt-transport-https ca-certifi…

LabVIEW软件开发人员如何在软件开发中捕捉需求?

在LabVIEW软件开发过程中,捕捉需求是确保项目成功的关键步骤。以下是一个系统化的方法,帮助LabVIEW软件开发人员有效地捕捉、分析和管理需求。 步骤1:需求收集 1.1 与客户沟通 与客户进行初步沟通,了解项目的背景、目标和期望。…

天工开物 #14 分析时序数据:从 InfluxQL 到 SQL 的演变

近年来,时序数据的增长是 Data Infra 领域一个不容忽视的趋势。这主要得益于万物互联带来的自然时序数据增长,以及软件应用上云和自身复杂化后的可观测性需求。前者可以认为是对联网设备的可观测性,而可观测性主要就建构在设备或应用不断上报…

【C#】WinForm关闭新(二级)界面使主程序关闭

参考视频:https://www.bilibili.com/video/BV1JY4y1G7jo?p14&vd_source1c57ab1b2e551da5b65c0dfb0f05a493 1.背景介绍 主程序界面,点击弹出二级界面(同时隐藏主界面),不做任何设置,这时关闭二级界面…

Java基础_Stream流

Java基础_Stream流 Stream流的简单使用Stream流的获取Stream流的中间方法Stream流的终结方法综合练习数字过滤字符串过滤并收集自定义对象过滤并收集 来源Gitee地址 Stream流的简单使用 public class StreamDemo01 {public static void main(String[] args) {/*** 创建集合添加…

java.lang.IllegalArgumentException: This Style does not belong to the supplied Workbook异常的解决办法

java.lang.IllegalArgumentException: This Style does not belong to the supplied Workbook异常的解决办法 文章目录 报错问题报错原因解决方法 报错问题 java.lang.IllegalArgumentException: This Style does not belong to the supplied Workbook异常 报错原因 在Java中&a…

Ubuntu虚拟机使用纯命令行对根分区进行扩展

Ubuntu虚拟机使用纯命令行对根分区进行扩展 前排提示 因为Ubuntu再安装时,根分区是没有使用LVM进行磁盘管理的,所以如果想扩展根分区,我们不得不使用另外一种暴力的方法。简单来说就是利用fdisk删除原来的根分区再基于原来的起始块号重新建…

C++对象池设计与实现

目录 一、对象池简介 1.1 池化技术 1.2 什么是对象池 1.3 对象池分配策略 二、C new和delete运算符重载 三、实现一个对象池框架 3.1 策略接口 四、实现几种对象池的分配策略 4.1 数组策略 4.2 堆策略 ​编辑 4.3 栈策略 4.4 区块策略 一、对象池简介 1.1 池化技…

【CS.AL】八大排序算法 —— 快速排序全揭秘:从基础到优化

文章目录 1. 快速排序简介1.1 定义1.2 时间复杂度1.3 相关资源 2. 最优的Partition算法 🔥2.1 Introsort简介2.2 过程示例 3. 非递归快速排序3.1 实现 4. 递归快速排序4.1 实现 5. 有问题的Partition5.1 实现 6. 三中位数主元选择6.1 实现 7. 总结 1. 快速排序简介 …

新增FTP功能、支持添加Redis远程数据库,专业版新增网站监控和黑金主题,1Panel开源面板v1.10.10版本发布

2024年6月7日,现代化、开源的Linux服务器运维管理面板1Panel发布v1.10.10版本。 在这一版本中,1Panel新增了多项实用功能。社区版方面,新增了FTP功能、支持添加Redis远程数据库、支持设置压缩密码,并新增了清理镜像构建缓存的功能…

[ue5]建模场景学习笔记(5)——必修内容可交互的地形,交互沙(2)

1需求分析: 继续制作可交互沙子内容,前面我们已经让角色在指定区域留下痕迹,那么能否让区域移动起来,这样才能逐步满足角色走到哪里都能产生交互痕迹,满足更大的地图。 2.操作实现: 1.首先建立角色能产生…