背景

前面寫了兩篇如何用 C# 基於 DTM 輕鬆實現 SAGA 和 TCC 的分散式事務，其中有一個子事務屏障的功能，很好的處理了空補償、懸掛、重複請求等異常問題。

https://dtm.pub/practice/barrier.html

不過前面的例子都是基於 mysql 的，有人問是否還支援其他資料庫。

很明顯這個是支援的，關係型資料庫這一塊，除了 mysql，還支援 pgsql 和 sql server 。

現存的一些系統，肯定還有不少是基於 sql server 開發的，如果這一批系統想接入 DTM，就不需要先遷庫再接入了。

那麼接下來，老黃就帶大家體驗一下基於 sql server 版本的 DTM 子事務屏障功能。

例子會基於前面 SAGA 的例子進行改造。

子事務屏障表

要先使用子事務屏障，必不可少的是要準備一個子事務屏障表，那麼這個子事務屏障表要放在那個例項的那個庫下面呢？

這裡只需要保證，要操作的業務資料和子事務屏障能在同一個本地事務裡面即可。

下面是針對 SQL Server 的建表 SQL。

IF EXISTS (SELECT * FROM sysobjects WHERE id = object_id(N’[dbo].[barrier]’) and OBJECTPROPERTY(id, N’IsUserTable’) = 1)  
BEGIN
  DROP TABLE [dbo].[barrier]
END

GO

CREATE TABLE [dbo].[barrier]
(
    [id] bigint NOT NULL IDENTITY(1,1) PRIMARY KEY,
    [trans_type] varchar(45) NOT NULL DEFAULT(''),
    [gid] varchar(128) NOT NULL DEFAULT(''),
    [branch_id] varchar(128) NOT NULL DEFAULT(''),
    [op] varchar(45) NOT NULL DEFAULT(''),
    [barrier_id] varchar(45) NOT NULL DEFAULT(''),
    [reason] varchar(45) NOT NULL DEFAULT(''),
    [create_time] datetime NOT NULL DEFAULT(getdate()) ,
    [update_time] datetime NOT NULL DEFAULT(getdate())
)

GO

CREATE UNIQUE INDEX[ix_uniq_barrier] ON[dbo].[barrier]
        ([gid] ASC, [branch_id] ASC, [op] ASC, [barrier_id] ASC)
WITH(IGNORE_DUP_KEY = ON)

GO
 

這裡比較關鍵的是那個唯一索引，有一個 IGNORE_DUP_KEY = ON。這個其實就是為了等價 mysql 的 insert ignore。

到這裡其實準備工作就已經七七八八了。

下面就來改造後例子吧，要做的東西不多，就是切換一些配置。

切換配置

要在 InApi 裡面指定子事務屏障的資料庫型別和自定義的表名。

在啟動前進行下面的配置

// 指定 子事務屏障 資料庫型別為 sql server
Dtmcli.DtmImp.DbSpecialDelegate.Instance.SetCurrentDBType("sqlserver");

// 指定 子事務屏障表的表名
Dtmcli.BranchBarrier.SetBarrierTableName("[test].[dbo].[barrier]");
 

對於表名這一塊，老黃是建議把庫名也加上的。

PS: 這個設定後續應該會放到配置檔案中，現階段基本是保持和 go 版本類似的寫法。

最後不可以少的就是要改一下連線字串和 SqlConnection 了。

public class Db
{
    private static readonly string _conn = "Data Source=127.0.0.1, 1433;Initial Catalog=test;user id=dev;password=123456;TrustServerCertificate=True;";

    public static DbConnection GeConn() => new Microsoft.Data.SqlClient.SqlConnection(_conn);
}

到這裡，所有的改造就已經完成了。下面來看具體的例子演示吧。

例子演示

這裡演示的是 聊一聊如何用C#輕鬆完成一個SAGA分散式事務 裡面的空補償和冪等兩個問題。

先來看空補償的。

再來看看冪等的

日誌輸出和行為效果基本都是一致的。

最後看看資料庫裡面的資料

寫在最後

在這篇文章裡，介紹瞭如何在子事務屏障中使用 SQL Server 作為底層儲存。希望對研究分散式事務的您有所幫助。

本文示例程式碼： DtmMsSqlSample

參考資料

• 子事務屏障原理章節
• dtm-labs/dtmcli-csharp