背景:我正在使用 C# 编写一个将持久操作放入队列中的函数， 每个操作分为 3 个步骤:
1.数据库操作(更新/删除/添加数据)
2.使用web服务进行长时间计算
3. 数据库操作(保存步骤2的计算结果)对步骤1中的同一个db表，检查db表的一致性，例如步骤1中的items相同(具体例子请看下面)

为了避免脏数据或损坏，我使用了一个锁对象(一个静态单例对象)来确保这 3 个步骤作为一个整体事务来完成。因为当多个用户在调用该函数进行操作时，他们可能会在自己操作的不同步骤修改同一个db表而没有这个锁，例如user2在他的step1中删除了item A，而user1在检查A是否仍然存在他的第 3 步。(附加信息:与此同时，我正在使用 Entity 框架中的 TransactionScope 来确保每个数据库操作都作为事务处理，但重复可读。)

但是我需要把它放到一个使用负载均衡机制的云计算平台上，所以实际上我的锁对象是不会生效的，因为这个函数会部署在不同的服务器上。

问题:在上述情况下，我该怎么做才能使我的锁对象正常工作？

最佳答案

这是一个棘手的问题 - 您需要分布式锁或某种共享状态。

由于您已经拥有数据库，因此您可以将您的实现从“静态 C# 锁”更改为在整个“事务”期间为您管理锁的数据库。

你不用说你使用的是什么数据库，但是如果是SQL Server，那么你可以使用应用程序锁来实现这一点。这使您可以明确地“锁定”一个对象，所有其他客户端将等待该对象解锁。 checkout :

http://technet.microsoft.com/en-us/library/ms189823.aspx

我在下面编写了一个示例实现。启动两个实例进行测试。

using System;
using System.Data;
using System.Data.SqlClient;
using System.Transactions;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            var locker = new SqlApplicationLock("MyAceApplication",
                "Server=xxx;Database=scratch;User Id=xx;Password=xxx;");

            Console.WriteLine("Aquiring the lock");
            using (locker.TakeLock(TimeSpan.FromMinutes(2)))
            {
                Console.WriteLine("Lock Aquired, doing work which no one else can do. Press any key to release the lock.");
                Console.ReadKey();
            }
            Console.WriteLine("Lock Released"); 
        }

        class SqlApplicationLock : IDisposable
        {
            private readonly String _uniqueId;
            private readonly SqlConnection _sqlConnection;
            private Boolean _isLockTaken = false;

            public SqlApplicationLock(
                String uniqueId,                 
                String connectionString)
            {
                _uniqueId = uniqueId;
                _sqlConnection = new SqlConnection(connectionString);
                _sqlConnection.Open();
            }

            public IDisposable TakeLock(TimeSpan takeLockTimeout)
            {
                using (TransactionScope transactionScope = new TransactionScope(TransactionScopeOption.Suppress))
                {
                    SqlCommand sqlCommand = new SqlCommand("sp_getapplock", _sqlConnection);
                    sqlCommand.CommandType = CommandType.StoredProcedure;
                    sqlCommand.CommandTimeout = (int)takeLockTimeout.TotalSeconds;

                    sqlCommand.Parameters.AddWithValue("Resource", _uniqueId);
                    sqlCommand.Parameters.AddWithValue("LockOwner", "Session");
                    sqlCommand.Parameters.AddWithValue("LockMode", "Exclusive");
                    sqlCommand.Parameters.AddWithValue("LockTimeout", (Int32)takeLockTimeout.TotalMilliseconds);

                    SqlParameter returnValue = sqlCommand.Parameters.Add("ReturnValue", SqlDbType.Int);
                    returnValue.Direction = ParameterDirection.ReturnValue;
                    sqlCommand.ExecuteNonQuery();

                    if ((int)returnValue.Value < 0)
                    {
                        throw new Exception(String.Format("sp_getapplock failed with errorCode '{0}'",
                            returnValue.Value));
                    }

                    _isLockTaken = true;

                    transactionScope.Complete();
                }

                return this;
            }

            public void ReleaseLock()
            {
                using (TransactionScope transactionScope = new TransactionScope(TransactionScopeOption.Suppress))
                {
                    SqlCommand sqlCommand = new SqlCommand("sp_releaseapplock", _sqlConnection);
                    sqlCommand.CommandType = CommandType.StoredProcedure;

                    sqlCommand.Parameters.AddWithValue("Resource", _uniqueId);
                    sqlCommand.Parameters.AddWithValue("LockOwner", "Session");

                    sqlCommand.ExecuteNonQuery();
                    _isLockTaken = false;
                    transactionScope.Complete();
                }
            }

            public void Dispose()
            {
                if (_isLockTaken)
                {
                    ReleaseLock();
                }
                _sqlConnection.Close();
            }
        }
    }
}

关于c# - 使用负载平衡时如何锁定对象，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18737161/