Nodeを使用して分散トランザクションを簡単に完了するTCC、乳母レベルのチュートリアル

[[428021]]

TCCとは何ですか? TCC は Try、Confirm、Cancel の略です。これは、2007 年に発表された「分散トランザクションを超えた生活: 背教者の意見」と題された論文の中で、パット ヘランドによって初めて提案されました。

TCC構成

TCCは3つの段階に分かれています

• 試行フェーズ: 実行を試行し、すべてのビジネス チェックを完了し (一貫性)、必要なビジネス リソースを予約します (準分離)

• 確認フェーズ: すべてのブランチの試行が成功した場合は、確認フェーズに進みます。 Confirmは、ビジネスチェックなしで実際にビジネスを実行し、Tryステージで予約されたビジネスリソースのみを使用します。

• キャンセル ステージ: すべてのブランチの Try 操作のいずれかが失敗した場合、プロセスはキャンセル ステージに進みます。キャンセルは、試行フェーズで予約されたビジネス リソースを解放します。

TCC 分散トランザクションには、従来の XA 分散トランザクションと同じように、次の 3 つの役割があります。

• AP/アプリケーションは、グローバルトランザクションを開始し、どのトランザクションブランチがグローバルトランザクションに含まれるかを定義します。

• 支店業務のさまざまなリソースの管理を担当するRM/リソースマネージャー

• TM/トランザクション マネージャーは、確認とキャンセルの実行、ネットワーク例外の処理など、グローバル トランザクションの正しい実行の調整を担当します。

銀行間送金に似た業務を行う場合、送金 (TransOut) と入金 (TransIn) は異なるマイクロサービスに存在します。正常に完了した TCC トランザクションの一般的なシーケンス図は次のとおりです。

TCCネットワーク異常

グローバル トランザクション プロセス全体を通じて、TCC ではさまざまなネットワーク異常が発生する可能性があります。通常は、空のロールバック、べき等性、中断などです。 TCC の異常は SAGA や信頼性の高いメッセージングなどのトランザクション モードに似ているため、この記事「分散トランザクションの 7 つの古典的なソリューション」のサブトランザクション バリアのセクションで、異常に対するすべてのソリューションについて説明します。

TCC実践

次に、TCC取引の具体的な開発を行います。

現在 TCC で利用できるオープン ソース フレームワークは主に Java 言語であり、seata が最も代表的です。この例では nodejs を使用し、使用される分散トランザクション フレームワークは dtm です。これは分散トランザクションを非常にエレガントにサポートします。 TCCの構成について詳しく説明します。

次に、具体的なTry/Confirm/Cancel処理関数を書いてみましょう。

 router.post( '/api/TransOutTry' , (ctx, next) => {
  console.log( "TransOutTry" )
  ctx.body = { 結果: "成功" }
 }).post( '/api/TransOutConfirm' , (ctx, next) => {
  console.log( "TransOutConfirm" )
  ctx.body = { 結果: "成功" }
 }).post( '/api/TransOutCancel' , (ctx, next) => {
  console.log( "TransOutCancel" )
  ctx.body = { 結果: "成功" }
 }).post( '/api/TransInTry' , (ctx, next) => {
  console.log( "TransInTry" )
  ctx.body = { 結果: "成功" }
 }).post( '/api/TransInConfirm' , (ctx, next) => {
  console.log( "TransInConfirm" )
  ctx.body = { 結果: "成功" }
 }).post( '/api/TransInCancel' , (ctx, next) => {
  console.log( "TransInCancel" )
  ctx.body = { 結果: "成功" }
 })

この時点で、各サブトランザクションの処理機能は正常であり、TCCトランザクションが開かれて分岐呼び出しが行われます。

非同期関数 FireTcc() {
  let dtm = "http://localhost:8080/api/dtmsvr" // dtm サービス アドレス
  let svc = "http://localhost:4005/api" // ローカルサービスプレフィックス
// tcc トランザクションを開きます。 2番目のパラメータにグローバルトランザクションのロジックを記述します 
  dtmcli.tccGlobalTransaction(dtm, async (t) => {を待機します。
    let req = { amount: 30 } // サブトランザクションに必要なペイロードの量 
    console.log( "trans out を呼び出しています" )
 // トランザクションブランチを登録し、ブランチ内のTryメソッドを呼び出します 
    t.callBranch(req、svc + "/TransOutTry" 、svc + "/TransOutConfirm" 、svc + "/TransOutCancel" )を待機します。
    console.log( "trans in を呼び出しています" )
 // トランザクションブランチを登録し、ブランチ内のTryメソッドを呼び出します 
    t.callBranch(req、svc + "/TransInTry" 、svc + "/TransInConfirm" 、svc + "/TransInCancel" )を待機します。
  })
 }

この時点で、完全な TCC 分散トランザクションが書き込まれました。

完全な成功例を実行したい場合は、この例yedf/dtmcli-node-sampleを参照してください。実行は非常に簡単です。

 # dtmを展開して起動する
# docker バージョン18以上が必要です
gitクローンhttps://github.com/yedf/dtm  
 CDDTM
 docker-compose を起動する
 
 # 別のコマンドラインを開始する
gitクローンhttps://github.com/yedf/dtmcli-node-sample  
 cd dtmcli-node-sample
 npmインストール
ノード。

TCC ロールバック

銀行がユーザー2に金額を振り込む準備をしているときに、ユーザー2の口座に異常を発見し、失敗を返した場合はどうなりますか？トランザクション失敗の相互作用のタイミング図を示します。

これと成功した TCC の違いは、サブトランザクションが失敗を返すと、その後グローバル トランザクションがロールバックされ、各サブトランザクションのキャンセル操作が呼び出されて、グローバル トランザクションが完全にロールバックされるようになることです。

まとめ

この記事では、TCC の理論的知識を紹介し、通常の正常な完了と正常なロールバックを含む、TCC トランザクションの記述プロセスの完全な例を示しました。この記事を通じて読者の皆様にはTCCについて深く理解して頂けたのではないかと思います。

分散トランザクションに関するより包括的な知識については、「分散トランザクションの最も古典的な 7 つのソリューション」を参照してください。

この記事で使用されている例は、yedf/dtm から抜粋したものです。複数のトランザクション モード (TCC、SAGA、XA) と、トランザクション メッセージのクロス言語サポートをサポートします。 golang、python、Java、PHP、nodejs などの言語のクライアントをサポートしています。各言語のSDKをご参照ください。サブトランザクション バリア機能を提供して、べき等性、中断、空の補償などの問題をエレガントに解決します。

この記事を読んだ後は、https://github.com/yedf/dtm プロジェクトにアクセスし、スターを付けてサポートしてください。