用Go轻松完成一个XA事务 (重构版)

yedf · · 1486 次点击 · 开始浏览    置顶
这是一个创建于 的主题,其中的信息可能已经有所发展或是发生改变。

## 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时序图: ![image.png](https://static.golangjob.cn/220406/1a2b57c36b122d65d7af70914f609b79.png) ### 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"} ``` 失败的时序图如下: ![image.png](https://static.golangjob.cn/220406/82bbceec7b168b00eb89e18ddd57aefe.png) ### 注意点 - dtm的XA事务接口在 v1.13.0 做了一次变更,大幅简化了XA事务的使用,整体上与TCC的接口保持一致,更易于上手。 - XA事务的第二阶段处理,即分支的最终提交或回滚,也会发往 API `BusiAPI+"/TransOutXa"`,在这个服务的内部,`dtmcli.XaLocalTransaction`会自动做`xa commit | xa rollback`, 此时请求的body为nil,因此解析body之类的操作,如前面的`reqFrom`需要放在`XaLocalTransaction`内部,否则会解析body出错. ### 小结 XA事务的特点是: - 简单易理解 - 开发较容易,回滚之类的操作,由底层数据库自动完成 - 对资源进行了长时间的锁定,并发度低,不适合高并发的业务

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1486 次点击  ∙  1 赞  
加入收藏 微博
2 回复  |  直到 2022-04-11 09:42:59
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传