多线程 linq2sql 应用程序 TransactionScope 困难

Question

我创建了一个文件处理服务，它从特定目录读取并导入 xml 文件。

该服务启动多个工作程序，这些工作程序将轮询文件队列以查找新文件，并使用 linq2sql 进行数据访问。每个工作线程都有自己的数据上下文。

正在处理的文件包含多个订单，每个订单包含多个地址（客户/承包商/分包商）

我已经围绕每个文件的处理定义了一个事务范围。这样我想确保整个文件得到正确处理，或者在发生异常时回滚整个文件：

        try
        {
            using (var tx = new TransactionScope(TransactionScopeOption.RequiresNew))
            {
                foreach (var order in orders)
                {
                    HandleType1Order(order);
                }
                tx.Complete();
            }
        }
        catch (SqlException ex)
        {
            if (ex.Number == SqlErrorNumbers.Deadlock)
            {
                throw new FileHandlerException("File Caused a Deadlock, retrying later", ex, true);
            }
            else
                throw;
        }

该服务的要求之一是创建或更新在 xml 文件中找到的地址。所以我创建了一个地址服务来负责地址管理。针对 xml 导入文件中的每个订单（在方法 HandleType1Order() 内）执行以下代码段（因此是整个文件的 TransactionScope 的一部分）。

 using (var tx = new TransactionScope())
            {

                address = GetAddressByReference(number);
                if (address != null) //address is already known
                {
                    Log.Debug("Found address {0} - {1}. Updating...", address.Code, address.Name);
                    UpdateAddress(address, name, number, isContractor, isSubContractor, isCustomer);
                }
                else
                {
                    //address not known, so create it
                    Log.Debug("Address {0} not known, creating address", number);
                    address = CreateAddress(name, number, sourceSystemId, isContractor, isSubContractor,
                                            isCustomer);
                    _addressRepository.Save(address);

                }

                _addressRepository.Flush();
                tx.Complete();
            }

我在这里想做的是创建或更新一个地址，并且该地址的编号是唯一的。

方法 GetAddressByReference(string number) 返回已知地址，如果未找到地址，则返回 null。

 public virtual Address GetAddressByReference(string reference)
 {
     return _addressRepository.GetAll().SingleOrDefault(a=>a.Code==reference);
 }

然而，当我运行该服务时，它会创建多个具有相同号码的地址。方法 GetAddressByReference() get 被并发调用，当第二个线程使用相同的地址号执行该方法时，它应该返回一个已知地址，但它返回 null。我的事务边界或隔离级别可能有问题，但我似乎无法让它工作。

有人能指出我正确的方向吗？非常感谢帮助！

ps 我对事务死锁并导致回滚没有问题，当发生死锁时，文件将被重试。

---

编辑 1 线程代码：

        public void Work()
    {
        _isRunning = true;
        while (true)
        {
            ImportFileTask task = _queue.Dequeue(); //dequeue blocks on empty queue               
            if (task == null)
                break; //Shutdown worker when a null task is read from the queue

            IFileImporter importer = null;
            try
            {
                using (new LockFile(task.FilePath).Acquire()) //create a filelock to sync access accross all processes to the file
                {
                    importer = _kernel.Resolve<IFileImporter>();
                    Log.DebugFormat("Processing file {0}", task.FilePath);
                    importer.Import(task.FilePath);
                    Log.DebugFormat("Done Processing file {0}", task.FilePath);
                }
            }
            catch(Exception ex)
            {
                Log.Fatal(
                    "A Fatal exception occured while handling {0} --> {1}".FormatWith(task.FilePath, ex.Message), ex);
            }
            finally
            {
                if (importer != null)
                    _kernel.ReleaseComponent(importer);
            }

        }

        _isRunning = false;
    }

上述方法在我们所有的工作线程中运行。它使用 Castle Windsor 来解析 FileImporter，该 FileImporter 具有短暂的生活方式（因此不跨线程共享）。

Answer 1

您没有发布线程代码，因此很难说出问题是什么。我假设您已经启动了 DTC（分布式事务协调器）？

你使用线程池吗？您使用“lock”关键字吗？

http://msdn.microsoft.com/en-us/library/c5kehkcz.aspx