.NET中的分布式锁定

using StackExchange.Redis;
using System;

public class DistributedLock
{
    private readonly ConnectionMultiplexer _redis;
    private readonly string _lockKey;
    private readonly TimeSpan _expirationTime;

    public DistributedLock(ConnectionMultiplexer redis, string lockKey, TimeSpan expirationTime)
    {
        _redis = redis;
        _lockKey = lockKey;
        _expirationTime = expirationTime;
    }

    public bool TryAcquireLock()
    {
        var db = _redis.GetDatabase();
        var result = db.StringSet(_lockKey, "locked", _expirationTime, When.NotExists);
        return result == 1;
    }

    public void ReleaseLock()
    {
        var db = _redis.GetDatabase();
        db.KeyDelete(_lockKey);
    }
}

// 使用示例
var redis = ConnectionMultiplexer.Connect("localhost");
var lockManager = new DistributedLock(redis, "myLockKey", TimeSpan.FromSeconds(30));

if (lockManager.TryAcquireLock())
{
    try
    {
        // 执行需要锁保护的操作
    }
    finally
    {
        lockManager.ReleaseLock();
    }
}
else
{
    Console.WriteLine("Failed to acquire lock.");
}