MyRedis分布式加锁解锁

在C#中使用MyRedis实现分布式锁通常涉及到SET命令配合选项NX（唯一性）和PX（过期时间）。以下是一个简单的示例，展示了如何使用StackExchange.Redis客户端在C#中实现分布式锁和解锁。

首先，确保已经安装了StackExchange.Redis库

Install-Package StackExchange.Redis

简单示例代码 

using StackExchange.Redis;
using System;
using System.Threading.Tasks;public class RedisDistributedLock
{private readonly ConnectionMultiplexer _redisConnection;private readonly IDatabase _database;public RedisDistributedLock(string configuration){_redisConnection = ConnectionMultiplexer.Connect(configuration);_database = _redisConnection.GetDatabase();}public async Task<bool> AcquireLock(string lockKey, string value, int expireTime){// 使用SET命令加锁，条件是键不存在，并设置过期时间return await _database.StringSetAsync(lockKey, value, expireTime, When.NotExists);}public async Task<bool> ReleaseLock(string lockKey, string value){// 获取键对应的值，并且比较是否与传入的值相同，相同则删除键以释放锁var currentValue = await _database.StringGetAsync(lockKey);if (currentValue.ToString() == value){return await _database.KeyDeleteAsync(lockKey);}return false;}
}// 使用示例
var lockClient = new RedisDistributedLock("localhost:6379");
string lockKey = "my_lock";
string lockValue = Guid.NewGuid().ToString(); // 生成唯一值
int lockExpireTime = 5000; // 锁的过期时间，单位毫秒// 尝试获取锁
bool isLockAcquired = await lockClient.AcquireLock(lockKey, lockValue, lockExpireTime);if (isLockAcquired)
{try{// 业务逻辑Console.WriteLine("Lock acquired. Exclusive access to the resource.");}finally{// 释放锁bool isLockReleased = await lockClient.ReleaseLock(lockKey, lockValue);if (isLockReleased){Console.WriteLine("Lock released.");}else{Console.WriteLine("Unable to release the lock.");}}
}
else
{Console.WriteLine("Unable to acquire lock.");
}

完整示例项目下载地址：MyRedis分布式加锁解锁.rar_myredis资源-CSDN文库