.NET CORE使用Redis分布式锁续命(续期)问题

2024-04-02 18:44

本文主要是介绍.NET CORE使用Redis分布式锁续命(续期)问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

结合上一期 .NET CORE 分布式事务(三) DTM实现Saga及高并发下的解决方案(.NET CORE 分布式事务(三) DTM实现Saga及高并发下的解决方案-CSDN博客)。有的小伙伴私信说如果锁内锁定的程序或者资源未在上锁时间内执行完,造成的使用资源冲突,需要如何解决。本来打算之后在发博文说明这个问题。那就先简短的说明一下。

这是一个Redis分布式锁续命或者称之为续期的问题。废话不多说,直接上代码。

using Microsoft.AspNetCore.DataProtection.KeyManagement;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Redlock.CSharp;
using StackExchange.Redis;
using System.Diagnostics;
using System.Globalization;
using System.Net.Sockets;
using System.Runtime.CompilerServices;
using System.Threading;public class RedisService
{private readonly ConnectionMultiplexer _redis;private readonly IDatabase _database;/// <summary>/// 初始化 <see cref="RedisService"/> 类的新实例。/// </summary>/// <param name="connectionMultiplexer">连接多路复用器。</param>public RedisService(string connectionString){_redis = ConnectionMultiplexer.Connect(connectionString);_database = _redis.GetDatabase();}#region 分布式锁#region 阻塞锁/// <summary>/// 阻塞锁--加锁/// </summary>/// <param name="key">阻塞锁的键</param>/// <param name="expireSeconds">阻塞锁的缓存时间</param>/// <param name="timeout">加锁超时时间</param>/// <returns></returns>public bool AcquireLock(string key, int expireSeconds, int timeout){var script = @"local isNX = redis.call('SETNX', KEYS[1], ARGV[1])if isNX == 1 thenredis.call('PEXPIRE', KEYS[1], ARGV[2])return 1endreturn 0";RedisKey[] scriptkey = { key };RedisValue[] scriptvalues = { key, expireSeconds * 1000 };var stopwatch = Stopwatch.StartNew();while (stopwatch.Elapsed.TotalSeconds < timeout){if (_database.ScriptEvaluate(script, scriptkey, scriptvalues).ToString() == "1"){stopwatch.Stop();return true;}}Console.WriteLine($"[{DateTime.Now}]{key}--阻塞锁超时");stopwatch.Stop();return false;}Action<string, int, int, IDatabase> postponeAction = (string key, int expireSeconds, int postponetime, IDatabase database) =>{var stopwatchpostpone = Stopwatch.StartNew();while (true){//记录时钟大于锁的设置时间说明这个锁已经自动释放了,没必要再用lua脚本去判断了,直接提前退出if (stopwatchpostpone.Elapsed.TotalSeconds > expireSeconds) return;//提前三分之一时间续命,必须提前。要不真释放了if (stopwatchpostpone.Elapsed.TotalSeconds > expireSeconds * 0.66){var scriptpostpone = @"local isNX = redis.call('EXISTS', KEYS[1])if isNX == 1 thenredis.call('PEXPIRE', KEYS[1], ARGV[2])return 1endreturn 0";RedisKey[] scriptkey = { key };RedisValue[] scriptvalues = { key, postponetime * 1000 };if (database.ScriptEvaluate(scriptpostpone, scriptkey, scriptvalues).ToString() == "1")Console.WriteLine($"[{DateTime.Now}]{key}--阻塞锁续命成功");elseConsole.WriteLine($"[{DateTime.Now}]{key}--阻塞锁续命失败");return;}}};/// <summary>/// 阻塞续命锁/// </summary>/// <param name="key">阻塞锁的键</param>/// <param name="expireSeconds">阻塞锁的缓存时间</param>/// <param name="timeout">加锁超时时间</param>/// <param name="postponetime">续命时间</param>/// <returns></returns>public bool AcquireLock(string key, int expireSeconds, int timeout, int postponetime){var script = @"local isNX = redis.call('SETNX', KEYS[1], ARGV[1])if isNX == 1 thenredis.call('PEXPIRE', KEYS[1], ARGV[2])return 1endreturn 0";RedisKey[] scriptkey = { key };RedisValue[] scriptvalues = { key, expireSeconds * 1000 };var stopwatch = Stopwatch.StartNew();while (stopwatch.Elapsed.TotalSeconds < timeout){if (_database.ScriptEvaluate(script, scriptkey, scriptvalues).ToString() == "1"){stopwatch.Stop();//锁续命Thread postponeThread = new Thread(() =>{postponeAction.Invoke(key, expireSeconds, postponetime, _database);});postponeThread.Start();return true;}}Console.WriteLine($"[{DateTime.Now}]{key}--阻塞锁超时");stopwatch.Stop();return false;}/// <summary>/// 阻塞锁--释放锁/// </summary>/// <param name="key"></param>/// <returns></returns>public bool UnAcquireLock(string key){var script = @"local getLock = redis.call('GET', KEYS[1])if getLock == ARGV[1] thenredis.call('DEL', KEYS[1])return 1endreturn 0";RedisKey[] scriptkey = { key };RedisValue[] scriptvalues = { key };return _database.ScriptEvaluate(script, scriptkey, scriptvalues).ToString() == "1";}#endregion#endregion
}

.NET CORE中是没有现成的Redis锁续命的api,只能自己造轮子。续命同样使用了Redis的Lua脚本来实现,确保了原子性。获取了Redis锁之后,直接开启了一个新的线程,在设置时间还剩三分之一的时候进行了续命,这在程序中是有必要使用的,比如说因为网络原因造成的延时,本来我的这个接口执行完毕只需要3秒钟,但是有于网络延时造成了我的这个接口执行超过了3秒,这时候就需要Redis锁续命。以上代码就可以完美结局这个问题。

    [HttpGet("AcquireLockPostpone")]public void AcquireLockPostpone(){string key = Guid.NewGuid().ToString();if (_redisService.AcquireLock("AcquireLockPostpone", 3, 100, 3)){Thread.Sleep(5000);_redisService.UnAcquireLock("AcquireLockPostpone");Console.WriteLine($"AcquireLockPostpone--释放锁");}}

控制器API,调用可以续命的阻塞锁,缓存时间设置为3秒 续命时间也是延长3秒。我们走个100阻塞锁的并发试一下。

这100个阻塞锁均续命完成。也都正常执行完毕。

为什么不用Task进行循环监视?

因为Task是对ThreadPool线程池进行的封装。ASP.NET CORE 后端开发基本上所有的方法都在用Task。续命Redis还是一个耗时的操作,需要在一定时间内一直占用线程池里的线程。所有用了Thread。

为什么一个Redis阻塞锁一个Thread监视?

最开始也想着的是使用一个线程,这个线程贯穿整个进程,然后用线程安全数据类型ConcurrentDictionary<锁的key,时间>进行存储,线程监视ConcurrentDictionary里的数据然后进行续命。但是并发多的时候较短的Redis锁有于循环次数过多就导致续不上时间了,就是还没续上时间,就释放了...............(这就比较尴尬了)。所以一个锁起来了一个线程监视。

为什么需要续命?反正都要解锁,为什么不直接设置一个较长的时间?

我写了一个接口,正常情况下,比如是3秒执行完毕。但是有于网络超时或者服务宕机等原因,执行超过了3秒。5秒才执行完。这时候就需要对Redis锁进行续命。但是程序执行流程反正都要给Redis锁进行释放,为什么不直接设置一个长时间呢?因为如果这个服务还没对锁进行释放就宕机了,Redis锁还在,相同的服务实例在次执行这个接口就拿不到锁了,需要锁释放结束之后才能拿到。

这篇关于.NET CORE使用Redis分布式锁续命(续期)问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/870760

相关文章

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

好题——hdu2522(小数问题:求1/n的第一个循环节)

好喜欢这题,第一次做小数问题,一开始真心没思路,然后参考了网上的一些资料。 知识点***********************************无限不循环小数即无理数,不能写作两整数之比*****************************(一开始没想到,小学没学好) 此题1/n肯定是一个有限循环小数,了解这些后就能做此题了。 按照除法的机制,用一个函数表示出来就可以了,代码如下

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

使用opencv优化图片(画面变清晰)

文章目录 需求影响照片清晰度的因素 实现降噪测试代码 锐化空间锐化Unsharp Masking频率域锐化对比测试 对比度增强常用算法对比测试 需求 对图像进行优化,使其看起来更清晰,同时保持尺寸不变,通常涉及到图像处理技术如锐化、降噪、对比度增强等 影响照片清晰度的因素 影响照片清晰度的因素有很多,主要可以从以下几个方面来分析 1. 拍摄设备 相机传感器:相机传

pdfmake生成pdf的使用

实际项目中有时会有根据填写的表单数据或者其他格式的数据,将数据自动填充到pdf文件中根据固定模板生成pdf文件的需求 文章目录 利用pdfmake生成pdf文件1.下载安装pdfmake第三方包2.封装生成pdf文件的共用配置3.生成pdf文件的文件模板内容4.调用方法生成pdf 利用pdfmake生成pdf文件 1.下载安装pdfmake第三方包 npm i pdfma

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合,内部除了存储元素外,还会存储一个score,存储在zset中的元素会按照score的大小升序排列,不同元素的score可以重复,score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]

购买磨轮平衡机时应该注意什么问题和技巧

在购买磨轮平衡机时,您应该注意以下几个关键点: 平衡精度 平衡精度是衡量平衡机性能的核心指标,直接影响到不平衡量的检测与校准的准确性,从而决定磨轮的振动和噪声水平。高精度的平衡机能显著减少振动和噪声,提高磨削加工的精度。 转速范围 宽广的转速范围意味着平衡机能够处理更多种类的磨轮,适应不同的工作条件和规格要求。 振动监测能力 振动监测能力是评估平衡机性能的重要因素。通过传感器实时监