dtm-labs / dtm Goto Github PK

应该是不同markdown解析渲染器的问题

文档站的demo镜像版本是latest，如下

dockerhub镜像版本是lastest, 如下

当存储引擎配置为mysql|postgres时，详细校验相关的参数，并给出详细的错误提示

相比mysql, postgresql在很多方面有着更大的优势

安装好后，执行：
go run app/main.go quick_start
提示：
----panic unknown response: {"code":500,"message":"Error 1146: Table 'dtm_busi.user_account' doesn't exist"}, will be retried handlered

看数据库里，只有三张表：

我看到python的示例里面的SAGA模式回退是使用的手动写的补偿函数，该项目支持像SAGA那种sql解析逆向回退吗

Using BusiRequest and BusiReply in gRPC method definition as in and out looks intrusive.

How about using gRPC context Incoming and Outgoing to transfer this payload?

首次将dtm所有文档（含dtm的README和dtm.pub）翻译为流畅的英文，三千元
后续同步维护每月一千元

我看到python的客户端是http服务，请问可以接入grpc服务吗？

In your example, I can see code
saga.WaitResult = true
or

saga.SetOptions(&dtmcli.TransOptions{WaitResult: true})

But both of them seem not work, when I call err := saga.Submit(), It return nil before excute grpc function. My code

var DtmGrpcServer = fmt.Sprintf("localhost:%d", 36790)
fmt.Println(DtmGrpcServer)

gid := dtmgrpc.MustGenGid(DtmGrpcServer)
fmt.Println(gid)
fmt.Println("before init")

sagaServer := dtmgrpc.NewSagaGrpc(DtmGrpcServer, gid)
saga := sagaServer.
Add("localhost:50051"+"/api.account.v1.User/CreateUser", "localhost:50051"+"/api.account.v1.User/CreateUserRevert", req)
// saga.WaitResult = true
// saga.WaitResult = true
saga.SetOptions(&dtmcli.TransOptions{WaitResult: true, TimeoutToFail: 0, RetryInterval: 0})

fmt.Println("before submit")
err := saga.Submit()
dtmimp.FatalIfError(err)
fmt.Println("after submit")
return nil, err

So I config wrong or something else ? . Tks

目前可以用于生产环境吗？

版本v 0.5 以后即可，目前已有多家大厂多个业务在使用

支持高可用吗？

支持，DTM可以部署多个无状态的应用节点，连接到数据库，只要数据库是高可用的，那么整个DTM就是高可用的

如何设计订票业务

参考文章深度剖析saga分布式事务

TCC/SAGA的回滚失败怎么办

参考不允许失败

请问新版本的发布有什么规则吗？感觉有点随意呢，v1.5.x和v1.6.x发布的间隔怎么短，而且更新的内容也不多，也不是那种重大的功能和bug修改，给人一个不是很稳定，还在快速迭代但是每次的更新内容又很少的错觉。虽然官方在v1.0有说明已经很稳定了，但是给人的信心不够。

当配置的存储引擎为Redis时，对配置进行详细的校验，给出详细的错误提示

是不是写成
func (t *TransBranch) changeStatus(db *common.DB, status string) *gorm.DB {
writeTransLog(t.Gid, "branch change", status, t.BranchID, "")
dbr := db.Must().Model(t).Where("gid=?", t.Gid).Where("branch_id=?", t.BranchID).Where("status=?", t.Status).Updates(M{
"status": status,
"finish_time": time.Now(),
})
checkAffected(dbr)
t.Status = status
return dbr
}

比如在 dtmsvr/utils.go 文件中
var p2e = dtmcli.P2E
p2e 作用是什么? 是编译的时候会优化吗?

Currently in mariadb/mysql, session A prepare an xa transaction, session B cannot commit it unless session A exit it.

Postgres can commit it in B without the exit of A. And dtm need this feature to improve xa performance.

Can anyone help to tell why? Can anyone make a PR to mariadb/mysql for this feature?

1、场景：用户1扣30元（成功），用户2扣30元（失败），事务没有补偿

2、具体步骤，把用户1余额设置为30元，用户2余额设置为0元，数据表字段设置为unsigned无符号

3、调用：go run app/main.go saga_barrier

4、报错：----panic unknown response: {"code":500,"message":"Error 1690: BIGINT UNSIGNED value is out of range in '(dtm_busi.user_account.balance + ?)'"}, will be retried handlered

5、重试了两次之后就没有重试了，并且事务没有回滚，用户1依然被扣了30元

6、global表数据，截图时间已超过next_cron_time的时间

I am willing to contribute to dtm. How can I begin to learn the dtm?

调用正向和补偿操作的接口都需要鉴权，鉴权是通过读取header头里面的鉴权token来实现的
是否可以支持在注册的时候把鉴权信息放在header头带上呢。

当存储引擎为boltdb时，根据配置中的Store.DataExpire，在boltdb第一次打开时，清理已过期的数据

这个难度较高，需要对dtm如何在boltdb存储事务的方式有了解

当前DTM是利用gorm包在服务运行中动态的进行数据库表的创建和维护。但是在生产中这可能会带来不可预期的锁库时间，如某个表数据量很大，现在需要在表中增加一列，或者调整索引。

因此建议，是否考虑使用类似github.com/rubenv/sql-migrate， 这样的数据库表创建和维护包，把对数据库的维护独立出来。这样可以在运维时间单独进行数据库的维护。保证生产环境下的性能。

可以参考最新的子事务屏障描述 https://dtm.pub/exception/barrier.html

按照上面描述的算法，优化子事务屏障的实现，可以让读者更容易理解

具体业务开发要在dtm框架里面实现？

dtm 里 orm 相关代码可能无法做到db上的分布式，db层分布式怎么实现？上 db proxy 实现？

https://github.com/viticis/dtmcli-java

https://github.com/viticis/dtmcli-java-examples

Add子事务的时候Add(payfsm.provider+"/TransOut", payfsm.provider+"/TransOutCompensate", req)
req这个参数在执行transout时被传入，那么发生逆向操作时，是不是也会把这个req传入？

update_time的值一直与子事务注册时的create_time一样，不会变，哪怕状态status变了，update_time还是保持与create_time一样

如果您想要参与dtm项目，贡献您的力量，您可以参考以下内容，逐步上手参与dtm。

熟悉PR流程

您的贡献是通过PR流程进行的，简单的PR教程可以参考这个链接：https://juejin.cn/post/6844903821521469448

下面问题仅为了练手，请您做一个文件的修改即可，而不要将所有文件都进行修改

• dtmsvr/trans_* 文件，加上开源版权注释，每个文件作为一个任务，发一个PR

简单问题

您可以通过这个链接 easy issue，搜索出简单问题的issue，然后在issue的评论中，说明自己已经在解决。当您解决之后，提交完PR，然后将issue链接到PR（这步可以让review人员方便的看到这个PR是解决什么问题的）。

dtm的人员将会review您的PR和issue，没有大的问题，会合并您的PR

这类问题也仅仅为了练手，请您做1~2个issue即可，将更多其他的功能，留给其他新手练习

解决实际问题

您可以通过这个链接 medium issue，搜索出实际问题的issue，可能为bug，也可能为dtm需要的新功能，步骤和简单问题相同。

这类问题不是为了练手，如果您有较多精力，可以多帮忙解决问题

这类问题需要您搭建dtm的开发测试环境，搭建指南参考：https://dtm.pub/other/develop

挑战核心功能

您可以通过这个链接core issue，搜索出核心功能相关的issue，这类问题或功能，涉及dtm的深入理解，对代码质量要求也高，我们的review也会更严格。希望您提供高质量的PR。如果您在这方面的贡献大，未来dtm会很愿意将您发展为PMC。

如题

简单的验证步骤为：

• 安装docker 20.04+
• docker-compose -f helper/compose.qs.yml up

查看日志是否都正常

如果遇见问题帮忙反馈，提PR。
如果有已经在windows上面对dtm做了各种测试的同学，帮忙加一下微信yedf2008，沟通一下使用情况

能否提供一个简单的GO实例呢？
我查看了一个您现有的go例子，还没有看懂怎么用。能否出一个连接数据库的操作实例来。这样比较容易知道怎么去操作了。

我看官方提供的sdk里面，只提到了HTTP SDK，GRPC的还没有是吗

dtm开源至今，受到了大量用户的青睐，现征求大家最想要的功能和特性，希望大家多给好的意见

需要熟悉grpc的开发，每周能够投入一定的时间

var MapSuccess = dtmimp.MapSuccess

// MapFailure HTTP result of FAILURE
var MapFailure = dtmimp.MapFailure

？？？？

Who is using dtm

If you are using dtm, please submit a comment in this issue like this:

• Company: Ivydad
• Website: www.ivydad.com
• Contact: [email protected]

谁在使用 dtm

如果您正在使用dtm，我们期待您能在此提交一条评论, 您可以参考下面的样例来提供您的信息：

• 公司：常青藤爸爸
• 官网：www.ivydad.com
• 联系方式：[email protected]

当申请事务调用，会有API鉴权，怎么解决

如果将CommonRes里面的Code和Message去掉DTM回调就正常处理

Note that the common/types.go file includes two types of logical code: database and config related operations. Is it possible to consider that

• Split common/types.go to two files, common/config.go and common/db.go.
• Make the init code in common/types.go file explicit with the singleton pattern.
• Make hard coded port in dtmsvr/dtmsvr.go configured in config.yaml.
• Remove RetryLimit, which is not used anywhere.