使用SQL Server创建跨计算机互斥体

Question

我有几台计算机使用相同的数据库（SQL Server 2008）

我正在尝试使用数据库在所有这些计算机之间同步任务。

每个任务都由一个锁ID的guid表示（如果与Mutex进行比较，则为Mutex名称）。

我有一些想法，但是我认为它们是一种hack，并且希望这里的人能够有更好的解决方案：

1. 创建一个新表“ Locks”，每行包含一个GUID，将表行锁定在事务中，并在完成后完成/还原事务。
2. sp_getapplock在锁名称为lock-id guid的事务中使用

我认为保持事务运行不是很好...我认为也许有一种解决方案不需要我保持开放的事务或会话？

Answer 1

我已经整理了一个小班将测试和反馈

public class GlobalMutex
{
    private SqlCommand _sqlCommand;
    private SqlConnection _sqlConnection;

    string sqlCommandText = @"

        declare @result int
        exec @result =sp_getapplock @Resource=@ResourceName, @LockMode='Exclusive', @LockOwner='Transaction', @LockTimeout = @LockTimeout

    ";

    public GlobalMutex(SqlConnection sqlConnection, string unqiueName, TimeSpan lockTimeout)
    {
        _sqlConnection = sqlConnection;
        _sqlCommand = new SqlCommand(sqlCommandText, sqlConnection);
        _sqlCommand.Parameters.AddWithValue("@ResourceName", unqiueName);
        _sqlCommand.Parameters.AddWithValue("@LockTimeout", lockTimeout.TotalMilliseconds);
    }

    private readonly object _lockObject = new object();
    private Locker _lock = null;
    public Locker Lock
    {
        get
        {
            lock(_lockObject)
            {
                if (_lock != null)
                {
                    throw new InvalidOperationException("Unable to call Lock twice"); // dont know why
                }
                _lock = new Locker(_sqlConnection, _sqlCommand);
            }
            return _lock;
        }
    }

    public class Locker : IDisposable
    {
        private SqlTransaction _sqlTransaction;
        private SqlCommand _sqlCommand;

        internal Locker(SqlConnection sqlConnection, SqlCommand sqlCommand)
        {
            _sqlCommand = sqlCommand;
            _sqlTransaction = sqlConnection.BeginTransaction();
            _sqlCommand.Transaction = _sqlTransaction;
            int result = sqlCommand.ExecuteNonQuery();
        }

        public void Dispose()
        {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

        protected virtual void Dispose(bool disposing)
        {
            if (disposing) 
            {
                _sqlTransaction.Commit(); // maybe _sqlTransaction.Rollback() might be slower
            }
        }
    }
}

用法是：

GlobalMutex globalMutex = new GlobalMutex(
    new SqlConnection(""),
    "myGlobalUniqueLockName",
    new TimeSpan(0, 1, 0)
);


using (globalMutex.Lock)
{
    // do work.
}

Answer 2

我会推荐一些完全不同的东西：使用队列。不要显式锁定任务，而是将任务添加到处理队列并让队列处理程序使任务出队并执行工作。额外的解耦也将有助于可扩展性和吞吐量。