|
|
|
@ -80,7 +80,7 @@ DTM是首款golang的开源分布式事务管理器，优雅的解决了幂等 |
|
|
|
saga := dtmcli.NewSaga(DtmServer, dtmcli.MustGenGid(DtmServer)). |
|
|
|
// 添加一个TransOut的子事务，正向操作为url: qsBusi+"/TransOut"， 补偿操作为url: qsBusi+"/TransOutCompensate" |
|
|
|
Add(qsBusi+"/TransOut", qsBusi+"/TransOutCompensate", req). |
|
|
|
// 添加一个TransIn的子事务，正向操作为url: qsBusi+"/TransOut"， 补偿操作为url: qsBusi+"/TransInCompensate" |
|
|
|
// 添加一个TransIn的子事务，正向操作为url: qsBusi+"/TransIn"， 补偿操作为url: qsBusi+"/TransInCompensate" |
|
|
|
Add(qsBusi+"/TransIn", qsBusi+"/TransInCompensate", req) |
|
|
|
// 提交saga事务，dtm会完成所有的子事务/回滚所有的子事务 |
|
|
|
err := saga.Submit() |
|
|
|
|
yedf2
5 years ago