seata-golang 一周年回顾

刺骨的言语ヽ痛彻心扉 2023-01-17 13:54 127阅读 0赞

作者 | 刘晓敏  
来源 | [阿里巴巴云原生公众号][Link 1]

Seata 是一款简单易用，高性能、开源的一站式分布式事务解决方案。Seata 从2019 年 1 月开源后就受到了大家的追捧，目前已经有几百家企业在生产环境进行了技术的落地。

2020 年 4 月，我们开始基于 Seata 着手做多语言 golang 项目，经过一年时间的开发，很高兴 seata-golang 发布了 1.0.0 版本。

今年 4 月 17 号，有幸在成都 gopher meetup 上将 seata-golang 介绍给热衷于 golang 的 gopher。

![1.png][]

![2.png][]

会上我们向大家演示了如何利用 seata-golang 来接入到微服务中保证服务间的数据一致性，另外还向大家介绍了 Seata 的核心原理、MySQL driver 原理和接入、seata-golang 的未来规划，最后就大家关注的 Seata 相关的问题做了 QA。

![3.png][]

## Seata 原理 ##

活动上，我们结合 seata-golang 的demo 和大家分享了 seata 的工作原理。如下图所示，是一个 seata at 模式的简单工作流程。

![4.png][]

*  TC（即图中右半部分）：Transaction coordinator，它是一个分布式事务协调器。
 *  TM：Transaction manager，它是一个事务管理器，负责全局事务的开启、提交和回滚。
 *  RM：Resource Manager，它是管理分支事务资源的，它加入全局事务组后，向 TC 报告分支事务的执行状态。
 *  XID：TM 开启全局事务时，会在 TC 创建一个 GlobalSession，GlobalSession 的全局唯一标识即为 XID。
 *  BranchID：RM 向 TC 注册分支事务后，在 TC 侧生成一个 BranchSession，BranchID 全局唯一标识这个 BranchSession。

当 RM 向 TC 报告分支执行失败时，TC 会标记这个 BranchSession 的状态为失败，然后 TM 发起回滚时，TC 根据 XID 找到所有成功执行的事务分支，通知他们进行回滚。

## MySQL Driver ##

最近研发开源出来的mysql driver 项目，基于 go-sql-driver/mysql 1.5.0 版本开发，天然集成了 seata-golang 的分布式事务能力，完全支持 database/sql 库这层抽象，由于很多 orm 框架都基于 database/sql 做了封装，所以对 database/sql 的支持意味着 seata-golang 可以完美无缝地接入各种 orm 框架。

![5.png][]

driver 的 mysqlTx 对象执行 Commit 或者 Rollback 时，会根据 mysqlConn 的 connCtx 是否有值来决定是否和 tc 交互，报告分支事务的执行状态。如果执行 Commit，connCtx 有值则把 sqlUndoItemsBuffer 中的 undoLog 和业务数据一起提交到数据库，然后报告 tc 事务分支提交的状态（成功还是失败），否则执行正常的提交。如果执行 Rollback，connCtx 有值则回滚然后向 tc 报告分支执行失败，tc 会根据这个状态回滚整个全局事务，connCtx 没有值则只需正常回滚。

![6.png][]

上图是 undoLog json 序列化后的结构数据，我们可以看到这条数据修改之前，它的 name 是 “TXC”，修改之后它的 name 是 “GTS”，如果对它进行回滚，则生成一个反向的补偿语句：update product set name = ‘TXC’ since = 2014 where id = 1。如果是 insert 操作，则反向补偿操作为 delete，如果是一个 delete 操作则方向补偿操作为 insert。

## 未来规划 ##

社区已经有小伙伴将 mysql driver集成到 gorm，并将 seata-golang 用到生产环境。目前 seata-golang 只支持 mysql，小伙伴们可根据 mysql driver 的思路，实现 pgsql 和 oracle 的 driver 。这也是未来 seata-golang 将要规划做的事情之一。

![7.png][]

随着 go 语言微服务开发的兴起，分布式事务问题会越来越受到关注，希望社区的朋友可以更多参与进来完善这个框架，让它发挥生命力、服务社区、创造价值。

如果你有任何疑问，欢迎搜索钉钉群号 33069364 加入交流群。

## 作者简介 ##

**刘晓敏**(GitHubID dk-lockdown)，目前就职于 h3c 成都分公司，擅长使用 Java/Go 语言，在云原生和微服务相关技术方向均有涉猎，目前专攻分布式事务。

## 参考资料 ##

*  seata 官方：[*https://seata.io*][https_seata.io]
 *  java 版 seata：[*https://github.com/seata/seata*][https_github.com_seata_seata]
 *  seata-golang 项目地址：[*https://github.com/opentrx/seata-golang*][https_github.com_opentrx_seata-golang]
 *  driver 地址：[*https://github.com/opentrx/mysql*][https_github.com_opentrx_mysql]
 *  seata-golang go 夜读 b 站分享：[*https://www.bilibili.com/video/BV1oz411e72T*][https_www.bilibili.com_video_BV1oz411e72T]
 *  基于 getty 的 seata-golang 通信模型详解：[*http://seata.io/zh-cn/blog/seata-golang-communication-mode.html*][http_seata.io_zh-cn_blog_seata-golang-communication-mode.html]
 *  [seata-golang 接入指南][seata-golang]
 *  [Go Mysql Driver 集成 Seata-Golang 解决分布式事务问题][Go Mysql Driver _ Seata-Golang]

[Link 1]: https://mp.weixin.qq.com/s/LHcg0DkqQvhMW7YNX76rSQ
[1.png]: /images/20221021/56671ec488c4471ba433dfa80ac02e1e.png
[2.png]: /images/20221021/adf2544b2dbf4529ad934d18a6a481ba.png
[3.png]: /images/20221021/a32b53fabbfe478f91434c82317bf93a.png
[4.png]: /images/20221021/2601dd13b9b04af6afc77104495b1be7.png
[5.png]: /images/20221021/86120bf3855741d5b3f777e7c906bb20.png
[6.png]: /images/20221021/e3097674887241aaa39f60e6492e55c3.png
[7.png]: /images/20221021/04f09ef8c7754385b87f98c5c106546f.png
[https_seata.io]: https://seata.io
[https_github.com_seata_seata]: https://github.com/seata/seata
[https_github.com_opentrx_seata-golang]: https://github.com/opentrx/seata-golang
[https_github.com_opentrx_mysql]: https://github.com/opentrx/mysql
[https_www.bilibili.com_video_BV1oz411e72T]: https://www.bilibili.com/video/BV1oz411e72T
[http_seata.io_zh-cn_blog_seata-golang-communication-mode.html]: http://seata.io/zh-cn/blog/seata-golang-communication-mode.html
[seata-golang]: http://mp.weixin.qq.com/s?__biz=MzUzNzYxNjAzMg==&mid=2247500996&idx=1&sn=b6de9068d72fe8b75ca8182fd784eebd&chksm=fae6cf0bcd91461d6bb7df55c9c13d5ecd28adc3c136f91e9aa4e1af94faf9d3e5c8d6f3bf60&scene=21#wechat_redirect
[Go Mysql Driver _ Seata-Golang]: http://mp.weixin.qq.com/s?__biz=MzUzNzYxNjAzMg==&mid=2247502784&idx=1&sn=6d2a90ba50b3bb025bf0f4f4fea7a848&chksm=fae6c00fcd91491924525f152ab388bf94a01c5e945292063ab218eec9419eff7443cfd0dde5&scene=21#wechat_redirect