dtm

英語 | 简体中文

分散トランザクションマネージャー

DTMとは

DTM は、サービス間の最終的なデータ整合性を提供する分散トランザクション フレームワークです。さまざまなアプリケーション シナリオに対応する、saga、tcc、xa、2 フェーズ メッセージ、送信ボックス、ワークフロー パターンを提供します。また、次のようにトランザクションを形成するための複数の言語と複数のストア エンジンもサポートしています。

DTMを使っている人（一部）

テンセント

バイトダンス

イビダッド

もっと

特徴

• 複数のトランザクション モードのサポート: SAGA、TCC、XA、ワークフロー、送信ボックス
• 複数言語のサポート: Go、Java、PHP、C#、Python、Nodejs 用の SDK
• より優れた送信トレイ: 送信トレイよりも洗練されたソリューションである 2 フェーズ メッセージは、マルチデータベースをサポートします。
• 複数のデータベース トランザクションのサポート: MySQL/MariaDB、Redis、MongoDB、Postgres、TDSQL など。
• 複数のストレージ エンジンのサポート: MySQL/MariaDB (共通)、Redis (高パフォーマンス)、BoltDB (開発&テスト)、MongoDB (計画中)
• 複数のマイクロサービス アーキテクチャのサポート: go-zero、go-kratos/kratos、polarismesh/polaris
• 高可用性と簡単な水平スケーリングのサポート

アプリケーションシナリオ。

DTM は、多くのシナリオにおけるデータ整合性の問題に適用できます。ここでは、一般的なシナリオをいくつか紹介します。

• キャッシュ管理: キャッシュの最終的な一貫性と強力な一貫性を徹底的に保証します。
• 在庫を差し引くフラッシュセール: 極端な場合には、手動調整を必要とせずに、Redis の正確な在庫が作成された最終注文とまったく同じであることを確認することもできます。
• 非モノリシックな注文システム: アーキテクチャを大幅に簡素化します
• イベント発行/サブスクリプション: より良い送信トレイ パターン

料理本

クイックスタート

DTMを実行する

git clone https://github.com/dtm-labs/dtm && cd dtm
go run main.go

例を開始する

銀行間送金を実行したいとします。転送出力 (TransOut) と転送入力 (TransIn) の操作は、別個のマイクロサービスでコーディングされます。

この問題に対する dtm の解決策を示す例を次に示します。

git clone https://github.com/dtm-labs/quick-start-sample.git && cd quick-start-sample/workflow-grpc
go run main.go

コード

使用法

 wfName := "workflow-grpc"
err = workflow . Register ( wfName , func ( wf * workflow. Workflow , data [] byte ) error {
  // ...
  // Define a transaction branch for TransOut
  wf . NewBranch (). OnRollback ( func ( bb * dtmcli. BranchBarrier ) error {
    // compensation for TransOut
    _ , err := busiCli . TransOutRevert ( wf . Context , & req )
    return err
  })
  _ , err = busiCli . TransOut ( wf . Context , & req )
  // check error

  // Define another transaction branch for TransIn
  wf . NewBranch (). OnRollback ( func ( bb * dtmcli. BranchBarrier ) error {
    _ , err := busiCli . TransInRevert ( wf . Context , & req )
    return err
  })
  _ , err = busiCli . TransIn ( wf . Context , & req )
  return err
}

// ...
req := busi . BusiReq { Amount : 30 , TransInResult : "" }
data , err := proto. Marshal ( & req )

// Execute workflow
_ , err = workflow . ExecuteCtx ( wfName , shortuuid . New (), data )
logger . Infof ( "result of workflow.Execute is: %v" , err )

上記のコードを実行すると、サービスTransOut 、 TransInが呼び出されたことがコンソールに表示されます。

失敗時のロールバック

転送操作が失敗した場合、DTM は各サブトランザクションの対応する補償操作を呼び出してロールバックし、その後トランザクションは正常にロールバックされます。

2 番目のサブトランザクションの失敗を意図的にトリガーして、何が起こるかを見てみましょう

 // req := busi.BusiReq{Amount: 30, TransInResult: ""}
req := busi. BusiReq { Amount : 30 , TransInResult : "FAILURE" }
})

コンソールでは、サービスTransOut 、 TransIn 、 TransOutRevertが呼び出されていることがわかります。

他の例

さらにクイック スタートの例が必要な場合は、dtm-labs/quick-start-sample を参照してください。

上記の例は、主に分散トランザクションの流れを示しています。実際のデータベースと対話する方法、補償を行う方法、ロールバックを行う方法などの実践的な例を含む詳細については、dtm-examples を参照してください。

星を付けてください！

このプロジェクトが面白い、または役に立つと思われた場合は、スターを付けてください。