dtm

英语 | 简体中文

分布式事务管理器

什么是DTM

DTM是一个分布式事务框架，提供跨服务最终数据一致性。它提供了saga、tcc、xa、2-phase message、outbox、workflow模式，适合多种应用场景。它还支持多种语言和多种存储引擎来形成交易，如下所示：

谁在使用 DTM（部分）

腾讯

字节跳动

艾维达德

更多的

特征

• 支持多种交易模式：SAGA、TCC、XA、Workflow、Outbox
• 多语言支持：Go、Java、PHP、C#、Python、Nodejs 的 SDK
• Better Outbox：2阶段消息，比Outbox更优雅的解决方案，支持多数据库
• 多种数据库事务支持：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会调用每个子事务对应的补偿操作进行回滚，之后事务成功回滚。

让我们故意触发第二个子事务的失败，看看会发生什么

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

我们可以在控制台中看到TransOut 、 TransIn 、 TransOutRevert服务已被调用

更多示例

如果您需要更多快速入门示例，请参阅 dtm-labs/quick-start-sample

上面的例子主要演示了分布式事务的流程。更多内容，包括如何与实际数据库交互、如何进行补偿、如何进行回滚等实际示例，请参阅 dtm-examples 了解更多示例。

给一颗星吧！

如果您觉得这个项目有趣，或者对您有帮助，请给个star！