C# Transaction 事务处理 -环境事务

一、TransactionScope 环境事务

    static async Task TransactionScopeAsync()

         {

             using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))

             {

                 Transaction.Current.TransactionCompleted += OnTransactionCompleted;

                 Utilities.DisplayTransactionInformation("Ambient TX created",

                       Transaction.Current.TransactionInformation);

                 var s1 = new Student

                 {

                     FirstName = "Angela",

                     LastName = "Nagel",

                     Company = "Kantine M101"

                 };

                 var db = new StudentData();

                 await db.AddStudentAsync(s1);

                 if (!Utilities.AbortTx())

                     scope.Complete();

                 else

                     Console.WriteLine("transaction will be aborted");

             } // scope.Dispose()

         }

二、嵌套事务

  static void NestedScopes()

         {

             using (var scope = new TransactionScope())

             {

                 Transaction.Current.TransactionCompleted += OnTransactionCompleted;

                 Utilities.DisplayTransactionInformation("Ambient TX created",

                       Transaction.Current.TransactionInformation);

                 using (var scope2 =

                       new TransactionScope(TransactionScopeOption.RequiresNew))

                 {

                     Transaction.Current.TransactionCompleted += OnTransactionCompleted;

                     Utilities.DisplayTransactionInformation(

                            "Inner Transaction Scope",

                            Transaction.Current.TransactionInformation);

                     scope2.Complete();

                 }

                 scope.Complete();

             }

         }

事务完成代码

   static void OnTransactionCompleted(object sender, TransactionEventArgs e)

         {

             Utilities.DisplayTransactionInformation("TX completed",

                   e.Transaction.TransactionInformation);

         }

你可能不知道这一点，在 .NET Framework 4.5.0 版本中包含有一个关于 System.Transactions.TransactionScope 在与 async/await 一起工作时会产生的一个严重的 bug 。由于这个错误，TransactionScope 不能在异步代码中正常操作，它可能更改事务的线程上下文，导致在处理事务作用域时抛出异常。

这是一个很大的问题，因为它使得涉及事务的异步代码极易出错。

好消息是，在 .NET Framework 4.5.1 版本中，微软发布了这个 "异步连接" 错误的修复程序。作为开发者的我们需要明确的做到以下两点：

如果说你在 TransactionScope 代码中使用 async/await，你需要将框架升级到 .NET 4.5.1 或以上版本。
在有包装异步代码的 TransactionScope 的构造函数中指定 TransactionScopeAsyncFlowOption.Enabled .

TransactionScopeAsyncFlowOption

在 .NET 4.5.1中，TransactionScope 有一个名为 TransactionScopeAsyncFlowOption 的新枚举，可以在构造函数中提供。您必须通过指定，明确地选择跨线程连续的事务流，如下：

 using (var tx = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))

 {

     await SomeMethodInTheCallStackAsync()

         .ConfigureAwait(false);

     tx.Complete();

 }

你可能很好奇，默认的 TransactionScopeAsyncFlowOption 是 Suppress（阻止的），因为微软想避免破坏 .NET 4.5.0 版本中代码库中行为。

最后

使用 TransactionScope 结合 async / await 时，你应该更新所有使用 TransactionScope 的代码路径以启用 TransactionScopeAsyncFlowOption.Enabled 。这样才能使事务能够正确地流入异步代码，防止在TransactionScope下使用时业务逻辑不正常。

巴特西

C# Transaction 事务处理 -环境事务

TransactionScopeAsyncFlowOption

最后

最新文章

热门文章