Распределенная блокировка в.NET

Question

Я ищу рекомендации для механизма блокировки, который будет работать на нескольких машинах. В моем случае я просто хочу иметь возможность запускать службу на 2 машинах и иметь один блок до тех пор, пока другой не завершит работу, как простой способ обеспечения избыточности в случае отказа обслуживающей машины.

Вроде того же, что и служба распределенной блокировки, но специально для поиска проектов, которые люди успешно интегрировали с.NET.

Answer 1

Мы используем функциональность блокировки приложений SqlServer для распределенной блокировки. Это особенно удобно, если SqlServer уже является частью вашего стека.

Чтобы облегчить работу с.NET, я создал пакет NuGet, который облегчает использование этой функциональности.

С этой библиотекой код выглядит так:

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

Поскольку базовая функциональность SqlServer очень гибкая, существуют также перегрузки, поддерживающие семантику TryAcquire, тайм-ауты, асинхронную блокировку.

Answer 2

Если вы используете AppFabric для Windows Server, вы можете использовать это расширение DataCache. Вы также можете использовать блокировки Redis с Redis-клиентом ServiceStack.

Оба являются реализациями.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
}