XA事务模式

XA是什么

XA是由X/Open组织提出的分布式事务的规范,XA规范主要定义了(全局)事务管理器(TM)和(局部)资源管理器(RM)之间的接口。本地的数据库如mysql在XA中扮演的是RM角色

XA一共分为两阶段:

第一阶段(prepare):即所有的参与者RM准备执行事务并锁住需要的资源。参与者ready时,向TM报告已准备就绪。 第二阶段 (commit/rollback):当事务管理者(TM)确认所有参与者(RM)都ready后,向所有参与者发送commit命令。

目前主流的数据库基本都支持XA事务,包括mysql、oracle、sqlserver、postgre

我们看看本地数据库是如何支持XA的:

第一阶段 准备

  1. XA start '4fPqCNTYeSG' -- 开启一个 xa 事务
  2. UPDATE `user_account` SET `balance`=balance + 30,`update_time`='2021-06-09 11:50:42.438' WHERE user_id = '1'
  3. XA end '4fPqCNTYeSG'
  4. XA prepare '4fPqCNTYeSG' -- 此调用之前,连接断开,那么事务会自动回滚
  5. -- 当所有的参与者完成了prepare,就进入第二阶段 提交
  6. xa commit '4fPqCNTYeSG'

XA实战

我们来完成一个完整的XA,我们先看一个成功的XA时序图:

xa_normal

HTTP接入

我们来看看如何用使用HTTP接入一个基于dtm-labs/dtm的XA事务

  1. gid := dtmcli.MustGenGid(dtmutil.DefaultHTTPServer)
  2. err := dtmcli.XaGlobalTransaction(dtmutil.DefaultHTTPServer, gid, func(xa *dtmcli.Xa) (*resty.Response, error) {
  3. resp, err := xa.CallBranch(&busi.TransReq{Amount: 30}, busi.Busi+"/TransOutXa")
  4. if err != nil {
  5. return resp, err
  6. }
  7. return xa.CallBranch(&busi.TransReq{Amount: 30}, busi.Busi+"/TransInXa")
  8. })
  9. app.POST(BusiAPI+"/TransInXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} {
  10. return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
  11. return AdjustBalance(db, TransInUID, reqFrom(c).Amount, reqFrom(c).TransInResult)
  12. })
  13. }))
  14. app.POST(BusiAPI+"/TransOutXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} {
  15. return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
  16. return AdjustBalance(db, TransOutUID, reqFrom(c).Amount, reqFrom(c).TransOutResult)
  17. })
  18. }))

详细例子代码参考dtm-examples:可以通过以下命令运行这个示例:

  1. go run main.go http_xa

上面的代码首先注册了一个全局XA事务,然后添加了两个子事务TransOut、TransIn。子事务全部执行成功之后,提交给dtm。dtm收到提交的xa全局事务后,会调用所有子事务的xa commit,完成整个xa事务。

失败回滚

如果有一阶段prepare操作失败,那么dtm会调用各子事务的xa rollback,进行回滚,最后事务成功回滚。

我们在上述XaFireRequest的请求负荷中,传递TransInResult=FAILURE,让他失败

  1. req := &busi.TransReq{Amount: 30, TransInResult: "FAILURE"}

失败的时序图如下:

xa_rollback

注意点

  • dtm的XA事务接口在 v1.13.0 做了一次变更,大幅简化了XA事务的使用,整体上与TCC的接口保持一致,更易于上手。
  • XA事务的第二阶段处理,即分支的最终提交或回滚,也会发往 API BusiAPI+"/TransOutXa",在这个服务的内部,dtmcli.XaLocalTransaction会自动做xa commit | xa rollback, 此时请求的body为nil,因此解析body之类的操作,如前面的reqFrom需要放在XaLocalTransaction内部,否则会解析body出错.

小结

XA事务的特点是:

  • 简单易理解
  • 开发较容易,回滚之类的操作,由底层数据库自动完成
  • 对资源进行了长时间的锁定,并发度低,不适合高并发的业务