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.     })
  10. app.POST(BusiAPI+"/TransInXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} {
  11.     return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
  12.         return AdjustBalance(db, TransInUID, reqFrom(c).Amount, reqFrom(c).TransInResult)
  13.     })
  14. }))
  15. app.POST(BusiAPI+"/TransOutXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} {
  16.     return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error {
  17.         return AdjustBalance(db, TransOutUID, reqFrom(c).Amount, reqFrom(c).TransOutResult)
  18.     })
  19. }))

详细例子代码参考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事务的特点是：

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