用Go轻松完成一个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的： 第一阶段 准备 ``` sql XA start '4fPqCNTYeSG' -- 开启一个 xa 事务 UPDATE `user_account` SET `balance`=balance + 30,`update_time`='2021-06-09 11:50:42.438' WHERE user_id = '1' XA end '4fPqCNTYeSG' XA prepare '4fPqCNTYeSG' -- 此调用之前，连接断开，那么事务会自动回滚 -- 当所有的参与者完成了prepare，就进入第二阶段 提交 xa commit '4fPqCNTYeSG' ``` ## XA实战 我们来完成一个完整的XA，我们先看一个成功的XA时序图：  ### HTTP接入 我们来看看如何用使用HTTP接入一个基于[dtm-labs/dtm](https://github.com/dtm-labs/dtm)的XA事务 ``` go gid := dtmcli.MustGenGid(dtmutil.DefaultHTTPServer) err := dtmcli.XaGlobalTransaction(dtmutil.DefaultHTTPServer, gid, func(xa *dtmcli.Xa) (*resty.Response, error) { resp, err := xa.CallBranch(&busi.TransReq{Amount: 30}, busi.Busi+"/TransOutXa") if err != nil { return resp, err } return xa.CallBranch(&busi.TransReq{Amount: 30}, busi.Busi+"/TransInXa") }) app.POST(BusiAPI+"/TransInXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} { return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error { return AdjustBalance(db, TransInUID, reqFrom(c).Amount, reqFrom(c).TransInResult) }) })) app.POST(BusiAPI+"/TransOutXa", dtmutil.WrapHandler2(func(c *gin.Context) interface{} { return dtmcli.XaLocalTransaction(c.Request.URL.Query(), BusiConf, func(db *sql.DB, xa *dtmcli.Xa) error { return AdjustBalance(db, TransOutUID, reqFrom(c).Amount, reqFrom(c).TransOutResult) }) })) ``` 详细例子代码参考[dtm-examples](https://github.com/dtm-labs/dtm-examples)：可以通过以下命令运行这个示例： ``` go run main.go http_xa ``` 上面的代码首先注册了一个全局XA事务，然后添加了两个子事务TransOut、TransIn。子事务全部执行成功之后，提交给dtm。dtm收到提交的xa全局事务后，会调用所有子事务的xa commit，完成整个xa事务。 ### 失败回滚 如果有一阶段prepare操作失败，那么dtm会调用各子事务的xa rollback，进行回滚，最后事务成功回滚。 我们在上述XaFireRequest的请求负荷中，传递TransInResult=FAILURE，让他失败 ``` go req := &busi.TransReq{Amount: 30, TransInResult: "FAILURE"} ``` 失败的时序图如下：  ### 注意点 - dtm的XA事务接口在 v1.13.0 做了一次变更，大幅简化了XA事务的使用，整体上与TCC的接口保持一致，更易于上手。 - XA事务的第二阶段处理，即分支的最终提交或回滚，也会发往 API `BusiAPI+"/TransOutXa"`，在这个服务的内部，`dtmcli.XaLocalTransaction`会自动做`xa commit | xa rollback`， 此时请求的body为nil，因此解析body之类的操作，如前面的`reqFrom`需要放在`XaLocalTransaction`内部，否则会解析body出错. ### 小结 XA事务的特点是： - 简单易理解 - 开发较容易，回滚之类的操作，由底层数据库自动完成 - 对资源进行了长时间的锁定，并发度低，不适合高并发的业务