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文库