TransactionScope事務處理方法介紹及.NET Core中的注意事項


作者:依樂祝

原文鏈接:https://www.cnblogs.com/yilezhu/p/10170712.html

今天在寫CzarCms的UnitOfWork的使用使用到了這個TransactionScope事務,因此對它進行了相關資料的查閱並記錄如下,希望對大伙在.NET Core中使用有所幫助。

寫在前面

您是否曾嘗試使用C#代碼來實現事務?通常,我們在SQL中一次執行多個Insert / Update語句的話可能就會使用到事務。事務遵循ACID(原子性,一致性,隔離性,持久性)規則,這樣所有的語句要么全部執行成功要么全部被取消並執行回滾操作。 而我們今天要講的TransactionScope則可以允許我們在應用程序級別實現這個過程。在某些情況下,您可能需要在同一個數據庫甚至多個數據庫(分布式事務)中執行不同的操作,或者由於某些其他約束,它無法在數據庫級別來完成,或者應用程序的開發人員對數據庫的接觸較少,那么這時候TransactionScope將會讓你游刃有余。

什么是TransactionScope呢?

TransactionScope作為System.Transactions的一部分被引入到.NET 2.0。同時SqlClient for .NET Core 從 2.1 及以上版本開始提供對System.Transactions的支持 。 它是一個類,它提供了一種簡單的方法,可以將一組操作作為事務的一部分來進行處理,而不必擔心場景背后的復雜性。如果某個操作在執行的過程中失敗的話,則整個事務將失敗並執行回滾操作,從而撤消已完成的所有操作。所有這些都將由框架處理,從而確保數據的一致性。

如何使用TransactionScope呢?

要使用它,您需要添加System.Transactions的引用,如果你使用的是.net core的話。這個引用被包含在netcoreapp2.2\System.Transactions.Local.dll 中, 該引用是框架庫的一部分(通常默認情況下不會自動添加)。添加后,在我們想要使用它的地方添加名稱空間 System.Transactions即可。代碼如下所示:

try
{
    using (TransactionScope scope = new TransactionScope())
    {
        // Do Operation 1
        // Do Operation 2
        //...
 
        // 如果所有的操作都執行成功,則Complete()會被調用來提交事務
        // 如果發生異常,則不會調用它並回滾事務
        scope.Complete();
    }
}
catch (ThreadAbortException ex)
{
    // 處理異常
}

在上面的代碼中我們可以看到我們在創建TransactionScope實例時使用了using 語句塊及Disposable塊,它確保了當dispose離開塊並結束事務范圍時調用dispose來進行資源的釋放。
在一個Transaction范圍中,我們可以做多個連接甚至鏈接到不同數據庫的操作的,如下所示:

using (TransactionScope scope = new TransactionScope())
{
    using (con = new SqlConnection(conString1))
    {
        con.Open();
 
        // 執行操作 1
        // 執行操作 2
        //...
    }
 
    using (con = new SqlConnection(conString2))
    {
        con.Open();
 
        // 執行操作 1
        // 執行操作 2
        //...
 
    }
 
    scope.Complete();
}

下面我們使用兩個不同的數據庫連接字符串來連接不同的數據庫。當然我們也可以根據我們的業務要求使用盡可能多數據庫。我們也可以再事務中嵌套事務。如下代碼所示:

public void DoMultipleTransaction()
{       
    try
    {
        using (TransactionScope scope = new TransactionScope())
        {
            using (con = new SqlConnection(conString1))
            {
                con.Open();
                // 執行操作1
            }
 
            OtherTransaction();
            scope.Complete();
        }
    }
    catch (ThreadAbortException ex)
    {
        // 處理異常
    }
}
 
private void OtherTransaction()
{
    using (TransactionScope scope = new TransactionScope())
    {
        using (con = new SqlConnection(conString2))
        {
            con.Open();
            // 執行操作
        }
        scope.Complete();
    }
}

這里最頂層的事務范圍稱為根范圍。另外這里需要注意的是即使通過調用scope.Complete()完成內部事務(上面的OtherTransaction ,如果由於各種原因無法調用rootscope complete,那么整個事務也將被回滾包括內部的事務。

*注意:執行分布式trsanctions時,您可能會收到以下異常之一*

  1. 服務器上的MSDTC不可用
  2. 已禁用分布式事務管理器(MSDTC)的網絡訪問。

這兩個錯誤都是由於同樣的原因,第一個是在數據庫和應用程序是同一個服務器時發生的,而在另一個則是服務跟數據庫分別部署在兩台服務器上。對於同一台服務器,請轉到run-> cmd-> services.msc。運行名為Distributed Transaction Coordinator的服務並自動啟動啟動類型,以便在系統重新啟動時再次啟動它。對於2,你可能需要參照這個鏈接的內容進行相應的設置

TransactionScope 類提供了多個重載構造函數,它們接受 TransactionScopeOption 類型的枚舉,而該枚舉定義事務范圍行為。

TransactionScope對象有以下三個選項:

  • Required:聯接環境事務,或者在環境事務不存在的情況下創建新的環境事務。
  • RequiresNew:成為新的根范圍,也就是說,啟動一個新事務並使該事務成為其自己范圍中的新環境事務。
  • Suppress:根本不參與事務。 因此沒有環境事務。

如果用 Required] 實例化范圍並且存在環境事務,則該范圍會聯接該事務。 相反,如果不存在環境事務,該范圍就會創建新的事務並成為根范圍。 這是默認值。 在使用 Required時,無論范圍是根范圍還是僅聯接環境事務,該范圍中的代碼都不需要有不同的行為。 該代碼在這兩種情況下的行為應相同。

如果用 RequiresNew 實例化范圍,則它始終為根范圍。 它會啟動一個新事務,並且其事務成為該范圍中的新環境事務。

如果用 Suppress 實例化范圍,則無論是否存在環境事務,范圍都從不參與事務。 始終使用此值實例化的作用域具有null作為其環境事務。

下面來讓我們看一組實例代碼:

using (TransactionScope scope = new TransactionScope())
{
    // 聯接環境事務,或者在環境事務不存在的情況下創建新的環境事務。
    using (TransactionScope scope1 = new TransactionScope(TransactionScopeOption.Required))
    {
        // Do Operation
        scope1.Complete();
    }
    //成為新的根范圍,也就是說,啟動一個新事務並使該事務成為其自己范圍中的新環境事務。
    using (TransactionScope scope2 = new TransactionScope(TransactionScopeOption.RequiresNew))
    {
        // Do Operation
        scope2.Complete();
    }
    //根本不參與事務。 因此沒有環境事務。
    using (TransactionScope scope3 = new TransactionScope(TransactionScopeOption.Suppress))
    {
        // Do Operation
        scope3.Complete();
    }
 
    scope.Complet

在這里,我們使用不同的TransactionScopeOptions在父事務下創建了三個事務。默認情況下,范圍是required ,這里父事務就是采用的這個默認參數進行創建的。它是一個創建新事務的根范圍,並將其標記為環境事務。scope1也是使用required創建的,因為我們已經有了一個環境事務(范圍),所以它加入到父事務中。scope2是使用RequiresNew選項創建的,這意味着它是一個獨立於環境事務處理的新事務。scope3是用suppress創建的選項,這意味着它不參與任何環境事務。無論環境事務是否成功執行,它都會被執行。父(全局)范圍完成后,將提交所有環境事務。

注意點

  1. EF Core 依賴數據庫提供程序以實現對 System.Transactions 的支持。 雖然支持在 .NET Framework 的 ADO.NET 提供程序之間十分常見,但最近才將 API 添加到 .NET Core,因此支持並未得到廣泛應用。 如果提供程序未實現對 System.Transactions 的支持,則可能會完全忽略對這些 API 的調用。 SqlClient for .NET Core 從 2.1 及以上版本開始支持 System.Transactions。如果嘗試在低版本中 如.NET Core 2.0中嘗試使用該功能將引發異常。

  2. 自版本 2.1 起,.NET Core 中的 System.Transactions 實現將不包括對分布式事務的支持,因此不能使用 TransactionScopeCommittableTransaction 來跨多個資源管理器協調事務。主要是不依賴windows中的mstsc功能。

  3. 異步方法使用時需要注意:

    在下面的例子中,我們在TransactionScope內部使用await

    using(var scope = new TransactionScope())
    { 
      var groups = await Context.ProductGroups.ToListAsync()。ConfigureAwait(false); 
    }
    

    看起來沒有問題,但它會拋出一個 System.InvalidOperationException:``A TransactionScope must be disposed on the same thread that it was created.

    原因是默認情況下TransactionScope不會從一個線程切換到另一個線程。為了解決這個問題,我們必須使用 TransactionScopeAsyncFlowOption.Enabled

    using(var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
    { 
      var groups = await Context.ProductGroups.ToListAsync()。ConfigureAwait(false); 
    }
    

    現在應該可以了吧?這取決於下面的情況。

    如果我們使用和不使用TransactionScopeAsyncFlowOption這個選項的時候都使用了相同的數據庫連接,並且第一次執行的時候沒有使用這個選項,那么我們會得到另一個異常: System.InvalidOperationException:``Connection currently has transaction enlisted. Finish current transaction and retry.

    換句話說,由於第一個訪問的原因,第二個會話將會失敗。如下代碼所示:

    try
    {
      using (var scope = new TransactionScope())
      {
        // We know this one - System.InvalidOperationException: 
        // TransactionScope必須放在與創建它相同的線程上。
        var groups = await Context.ProductGroups.ToListAsync().ConfigureAwait(false);
     }
    }
    catch (Exception e)
    {
      // error handling
    }
    
    using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
    {
      // Implemented correctly but throws anyways
      // System.InvalidOperationException:
      // 當前連接已經被記錄。完成當前事務並重試。
      var groups = await Context.ProductGroups.ToListAsync().ConfigureAwait(false);
    }
    

    想象一下,如果第一個調用是在第三方庫或您正在使用的框架中完成的,二您不了解其中的代碼 - 如果您之前沒有看到此錯誤,那么你講無從下手來解決這個問題。

    總結

    本文帶着大家熟悉了一遍TransactionScope並對其使用進行了介紹!同時介紹了在.NET Core中使用TransactionScope的一些注意事項!希望對大家有所幫助。另附上.NET Core實戰項目交流群:637326624


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM