.NET 中的分布式锁定

Question

我正在寻找可跨多台机器工作的锁定机制的建议。就我而言，我基本上只是希望能够在两台机器上启动一项服务，并在另一台机器完成之前阻止一个服务，这是一种简单的方法，可以在服务机器出现故障时确保冗余。

与分布式锁服务有点类似，但专门寻找人们已成功集成的项目。网。

Answer 1

我们使用 SqlServer 的应用程序锁功能进行分布式锁定。如果 SqlServer 已经是您的堆栈的一部分，这尤其方便。

为了使其更容易在 .NET 中使用，我创建了一个 NuGet 包，这使得使用它变得容易功能。该库还支持其他后端，例如 Postgres、Azure blob 存储和 Redis。

使用这个库，代码如下所示：

var @lock = new SqlDistributedLock("my_lock_name", connectionString);
using (@lock.Acquire())
{
   // critical region
}

因为底层 SqlServer 功能非常灵活，所以还有支持 TryAcquire 语义、超时和异步锁定的重载。

Answer 2

如果您使用的是 Windows Server 版 AppFabric，则可以使用 此 DataCache 扩展。您还可以将 Redis 锁与 ServiceStack 的 redis 客户端结合使用。

两者都是 .NET 实现，但需要服务器组件。我一直在修改分布式锁的 PeerChannel 实现，它使用点对点通信并且不需要任何服务器基础设施。如果您对此感兴趣，请告诉我。

Answer 3

您可以使用 NCache 对这个特定用例使用悲观锁定。
当您处理读取密集型应用程序时，乐观锁定非常有用，

NCache 可以帮助您实现这一目标。
http://blogs.alachisoft.com/ncache/distributed-locking/

// Instance of the object used to lock and unlock cache items in NCache
LockHandle lockHandle = new LockHandle();

// Specify time span of 10 sec for which the item remains locked
// NCache will auto release the lock after 10 seconds.
TimeSpan lockSpan = new TimeSpan(0, 0, 10); 

try
{
    // If item fetch is successful, lockHandle object will be populated
    // The lockHandle object will be used to unlock the cache item
    // acquireLock should be true if you want to acquire to the lock.
    // If item does not exists, account will be null
    BankAccount account = cache.Get(key, lockSpan, 
    ref lockHandle, acquireLock) as BankAccount;
    // Lock acquired otherwise it will throw LockingException exception

    if(account != null &&; account.IsActive)
    {
        // Withdraw money or Deposit
        account.Balance += withdrawAmount;
        // account.Balance -= depositAmount;

        // Insert the data in the cache and release the lock simultaneously 
        // LockHandle initially used to lock the item must be provided
        // releaseLock should be true to release the lock, otherwise false
        cache.Insert("Key", account, lockHandle, releaseLock); 
    }
    else
    {
        // Either does not exist or unable to cast
        // Explicitly release the lock in case of errors
        cache.Unlock("Key", lockHandle);
    } 
}
catch(LockingException lockException)
{
    // Lock couldn't be acquired
    // Wait and try again
}