dtm

英语| 简体中文

分布式交易管理器

什么是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以获取更多示例。

给星星！

如果您认为这个项目很有趣，或者对您有帮助，请给星星！