Goを使用してXA分散トランザクションを簡単に完了する、ナニーレベルのチュートリアル

[[423848]]

取引

一部のビジネス要件では、一連の操作の一部ではなく、すべてを実行する必要があります。たとえば、転送操作は次のようになります。

 -- ID= 1のアカウントから ID= 2のアカウントに100元を送金する
-- ステップ 1: ID = 1のアカウント A の残高から100 を減算します。
アカウントを更新します。SET balance = balance - 100 WHERE id = 1 ;
 -- ステップ 2: ID = 2のアカウント B の残高に100 を追加します。
アカウントを更新します。set balance = balance + 100 WHERE id = 2 ;

これら 2 つの SQL ステートメントは、すべて実行する必要があります。何らかの理由で最初のステートメントが成功し、2 番目のステートメントが失敗した場合は、すべてを元に戻す必要があります。

複数のステートメントをまとめて操作するこの機能は、データベーストランザクションと呼ばれます。データベーストランザクションにより、トランザクションのスコープ内のすべての操作が成功または失敗することを保証できます。トランザクションが失敗した場合、SQL ステートメントが実行されなかった場合と同じ結果となり、データベースデータは変更されません。

マイクロサービス

トランザクションに関係するすべての操作をサービス内に配置できる場合、さまざまな言語のトランザクション関連ライブラリを使用して、複数の操作をトランザクション操作全体として簡単に実装できます。

しかし、注文の生成などの一部のサービスでは、在庫、クーポン、ギフト、口座残高など、多くの操作を実行する必要があります。システムの複雑さが増すと、これらすべての操作を 1 つのサービスに実装しようとすると、結合度が高くなりすぎて、メンテナンスコストが非常に高くなります。

複雑なシステムの場合、現在普及しているマイクロサービスアーキテクチャは非常に優れたソリューションです。このアーキテクチャでは、複雑なシステムを、独立して開発および保守される多数のマイクロサービスに分割できます。

サービスは分割されていますが、注文自体のロジックでは全体として複数の操作が必要であり、すべてが成功するかすべてが失敗するかのいずれかになるため、新たな課題が生じます。さまざまなマイクロサービスに分散しているローカルトランザクションを 1 つの大きなトランザクションに結合して、全体として動作するようにする方法は、分散トランザクションが解決する必要がある問題です。

分散トランザクション

簡単に言えば、分散トランザクションは、さまざまな小さな操作で構成された大規模な操作です。これらの小さな操作は異なるサーバーに分散され、異なるアプリケーションに属します。分散トランザクションでは、これらの小さな操作がすべて成功するか、すべて失敗するかを保証する必要があります。本質的に、分散トランザクションは、異なるデータベース間でのデータの一貫性を確保するように設計されています。

分散トランザクションソリューションには以下が含まれます。

x
tcc
サガ
信頼できるニュース

最も単純なものを見てみましょう

1000

XA は、X/Open 組織によって提案された分散トランザクション仕様です。 XA 仕様は主に、(グローバル) トランザクションマネージャー (TM) と (ローカル) リソースマネージャー (RM) 間のインターフェイスを定義します。 MySQLなどのローカルデータベースはXAのRMの役割を果たす

XA は 2 つの段階に分かれています。

最初のフェーズ (準備): 参加しているすべての RM がトランザクションの実行を準備し、必要なリソースをロックします。参加者の準備ができたら、TM に準備ができたことを報告します。フェーズ 2 (コミット/ロールバック): トランザクションマネージャー (TM) は、すべての参加者 (RM) の準備ができていることを確認すると、すべての参加者にコミットコマンドを送信します。

現在、MySQL、Oracle、SQL Server、PostgreSQL など、ほとんどの主流データベースは XA トランザクションをサポートしています。

ローカルデータベースが XA をどのようにサポートしているかを見てみましょう。

ステージ 1 準備

XA 開始'4fPqCNTYeSG'
 `user_account` を更新し、`balance`=balance + 30 、`update_time`= '2021-06-09 11:50:42.438'を設定します。ここで、user_id = '1'です。
 XA 終了'4fPqCNTYeSG'
 XA は'4fPqCNTYeSG'を準備します
-- 参加者全員が準備を完了すると、提出の第2段階に入ります。
 xa コミット'4fPqCNTYeSG'

練習する

ここまで紹介したので、分散トランザクションの理解を深めるために、マイクロサービスで XA トランザクションを完了する練習をしてみましょう。ここでは、分散トランザクションのマネージャーとして DTM を使用して、XA デモの 1 つを実行します。

goをインストールする mysqlをインストールする

dtmを入手

gitクローンhttps://github.com/yedf/dtm.git
 CDDTM

MySQLの設定

conf.sample.yml conf.yml をコピーします。
 vi conf.yml

例を実行する

go run app/main.go xa

ログから XA 部分の出力を見つけることができ、最終的にトランザクションを正常に送信できます。

 # サービス1出力
XA 開始'4fPqCNTYeSG'
 `user_account` を更新し、`balance`=balance - 30 、`update_time`= '2021-06-09 11:50:42.438'を設定します。ここで、user_id = '1'です。
 XA 終了'4fPqCNTYeSG'
 XA は'4fPqCNTYeSG'を準備します
# サービス2の出力
XA 開始'4fPqCPijxyC'
 `user_account` を更新し、`balance`=balance + 30 、`update_time`= '2021-06-09 11:50:42.493'を設定します。ここで、user_id = '2'です。
 XA 終了'4fPqCPijxyC'
 XA は'4fPqCPijxyC'を準備します
# サービス1出力
xa コミット'4fPqCNTYeSG'
 #サービス2出力
xa コミット'4fPqCPijxyC'

全体のやり取りのタイミングの詳細は次のとおりです。

コードは次のとおりです。

 // マイクロサービス処理関数:
 app.POST(BusiAPI+ "/TransInXa"、common.WrapHandler(func(c *gin.Context) (インターフェース{}、エラー){
 XaClient.XaLocalTransaction(c.Request.URL.Query(), func(db *sql.DB, xa *dtmcli.Xa) (インターフェース{}, error)を返します{
        _, err := dtmcli.DBExec(db, "dtm_busi.user_account を更新し、残高をbalance+? に設定し、user_id=?" 、reqFrom(c).Amount、 2 )
 dtmcli.MapSuccess、エラーを返します
    })
 }))
 app.POST(BusiAPI+ "/TransOutXa"、common.WrapHandler(func(c *gin.Context) (インターフェース{}、エラー){
 XaClient.XaLocalTransaction(c.Request.URL.Query(), func(db *sql.DB, xa *dtmcli.Xa) (インターフェース{}, error)を返します{
        _, err := dtmcli.DBExec(db, "dtm_busi.user_account を更新し、残高をbalance-? に設定し、user_id=?" 、reqFrom(c).Amount、 1 )
 dtmcli.MapSuccess、エラーを返します
    })
 }))
 // XAトランザクションを開始する
err := XaClient.XaGlobalTransaction(gid, func(xa *dtmcli.Xa) (*resty.Response, error) {
    応答、エラー:= xa.CallBranch(&TransReq{金額: 30 }, Busi+ "/TransOutXa" )
 err != nil の場合{
応答を返す、エラー
    }
 xa.CallBranch(&TransReq{金額: 30 }, Busi+ "/TransInXa" )を返します。
 })