英语| 简体中文
分布式交易管理器
什么是dtm
dtm是一个分布式交易框架，可提供交叉服务的最终数据一致性。它为各种应用程序方案提供了传奇，TCC，XA，2相消息，Outbox，工作流模式。它还支持多种语言和多个商店引擎，以形成以下交易：
谁在使用dtm （部分）
腾讯
兽
Ivydad
更多的
特征
- 支持多种事务模式：传奇，TCC，XA，工作流，发出框
- 多种语言支持：SDK for GO，Java，PHP，C＃，Python，nodejs
- 更好的发件箱：2相消息，比量框更优雅的解决方案，支持多数据库
- 多个数据库事务支持：MySQL/Mariadb，Redis，MongoDB，Postgres，TDSQL，等。
- 支持多个存储引擎：MySQL/Mariadb（普通），Redis（高性能），BoltdB（Dev＆Test），MongoDB（计划）
- 支持多个微服务架构：Go-Zero，Go-Kratos/Kratos，Polarismesh/Polaris
- 支持高可用性和易于水平缩放
应用程序方案。
dtm可以应用于大量场景中的数据一致性问题，这里有一些常见的情况
- 缓存管理：彻底保证缓存最终一致性和强大的一致性
- 扣除库存的闪光：在极端情况下，还可以确保REDIS中的精确清单与创建的最终顺序完全相同，而无需进行手动调整
- 非金石秩序系统：急剧简化体系结构
- 事件发布/订阅：更好的输出模式
烹饪书
快速开始
运行dtm
dtm
go run main.go">
git clone https://*g**ithub.com/dtm-labs/ dtm && cd dtm go run main.go
开始一个示例
假设我们要执行银行间转移。在（transin）中转移（transout）和转移的操作以单独的微服务进行编码。
这是一个示例来说明dtm解决此问题的解决方案：
git clone https://*g**ithub.com/dtm-labs/quick-start-sample.git && cd quick-start-sample/workflow-grpc
go run main.go代码
用法
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 * dtm cli.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)
">
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 * dtm cli. 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 * dtm cli. 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 )
当上述代码运行时，我们可以在控制台中看到Services TransOut ，已调用TransIn 。
失败时回滚
如果任何远程操作失败， dtm会调用每个子交易的相应补偿操作回滚，此后成功卷回去。
让我们故意触发第二个子交易的故障，然后观察发生的事情
// req := busi.BusiReq{Amount: 30, TransInResult: ""}
req := busi. BusiReq { Amount : 30 , TransInResult : "FAILURE" }
})我们可以在控制台中看到服务TransOut ， TransIn ， TransOutRevert已被调用
更多例子
如果您想要更多快速的启动示例，请参阅dtm -LABS/QUITIV-Start-sample
上面的示例主要证明了分布式交易的流动。有关此信息的更多信息，包括如何与实际数据库互动，如何进行补偿，如何进行回滚等。请参阅dtm -Examples以获取更多示例。
给星星！
如果您认为这个项目很有趣，或者对您有帮助，请给星星！
下载源码
通过命令行克隆项目:
git clone https://github.com/dtm-labs/dtm.git