关于关系型数据库:Go-Mysql-Driver-集成-SeataGolang-解决分布式事务问题

简介：2020 年 4 月，咱们开始尝试实现 go 语言的分布式事务框架 Seata-Golang。家喻户晓，Seata AT 模式以无业务代码侵入的特点，被宽广开发者推崇。Java 版 Seata AT 模式通过对 DataSource 数据源进行代理，在 sql 语句执行时，对 sql 拦挡解析，获取数据库对应数据在 sql 语句执行前后的正本，序列化后保存起来，在 TC 协调回滚时用来回滚对应数据。实现 go 版本 client 的 AT 模式时，怎么对业务开发者更敌对，入侵更少，成了首要思考的指标。

作者 | 刘晓敏 GitHub ID：dk-lockdown
起源 | 阿里巴巴云原生公众号

2020 年 4 月，咱们开始尝试实现 go 语言的分布式事务框架 Seata-Golang。家喻户晓，Seata AT 模式以无业务代码侵入的特点，被宽广开发者推崇。Java 版 Seata AT 模式通过对 DataSource 数据源进行代理，在 sql 语句执行时，对 sql 拦挡解析，获取数据库对应数据在 sql 语句执行前后的正本，序列化后保存起来，在 TC 协调回滚时用来回滚对应数据。实现 go 版本 client 的 AT 模式时，怎么对业务开发者更敌对，入侵更少，成了首要思考的指标。

应用 go 操作数据库时，咱们会应用到 go 语言的官网库 database/sql，通过 sql.Open("mysql", ${dsn}) 获取一个数据源操作对象 db。开启事务时，应用 db.Begin() 或 db.BeginTx(ctx, &sql.TxOptions{}) 取得事务操作对象 tx，执行 sql 查问应用 tx.Query；执行 sql 新增、批改、删除，应用 tx.Exec；最初应用 tx.Commit() 提交或应用 tx.Rollback() 回滚。

go 语言官网库 database/sql 提供了一个规范形象层，通过实现不同的 driver 一套规范的形象 API 能够操作不同的数据库。开发 Go 版本的 AT 模式，必然要兼容 database/sql。通过钻研 database/sql 的 api，创立数据源操作对象，数据库无关的配置必须通过 Data Source Name (DSN) 形象传递进去，上面是 DSN 的定义：

[username[:password]@][protocol[(address)]]/dbname[?param1=value1&...&paramN=valueN]

实现 AT 模式对数据源代理是须要和事务协调器 TC 进行交互的，如果将 AT 模式实现在 driver 层，那么和 TC 交互的一些参数必须要通过 DSN 传递到 driver，这样有些毁坏它的设计。所以，最初采取了一种折中计划，在 database/sql 层之上实现 AT 模式，代理 database/sql 创立进去的数据源操作对象。数据源代理对象实现 database/sql 库定义的 Tx 接口，另外再提供一个开启事务的办法：Begin()，尽管没有齐全兼容 database/sql 的 api，然而要害接口和它的定义成一样，勉强还能承受。到此，Seata-Golang 我的项目外围性能的开发已实现。

type Tx interface {Commit() error
    Rollback() error}

Seata-Golang 开源后，逐步被一些开发者理解和接触，社区也对 Seata-Golang 收回了一些反馈的声音，不少开发者并不习惯写原生 sql，他们心愿将 Seata-Golang 集成到 ORM 框架，因为过后的设计没有齐全兼容 database/sql 导致集成上遇到一些艰难。随着社区的热切召唤，且得益于后期对 driver 的一些钻研，朝思暮想必有回响，往年 3 月忽然灵感爆发：为什么参数肯定要通过 DSN 传递？Seata-Golang Client 初始化后，在须要时通过 Client 端的 API config.GetATConfig() 间接获取应用不就能够了。

于是工作之余，历时 2 周开发，第一个集成 Seata-Golang 的齐全兼容 database/sql 的 mysql driver 被开发进去，我的项目开源在 https://github.com/opentrx/mysql，现处于 beta 状态，心愿社区开发者应用后能有一些反馈，可通过例子：https://github.com/opentrx/seata-go-samples，查看应用形式并进行测试。

应用该 driver 进行分布式事务操作时，不能在 dsn 中设置 interpolateParams 参数为 true。

这波及到 mysql 的两个协定：Text 协定和 Binary 协定。无关两个协定的区别，能够在文末参考文档找到材料。实现该 driver 只对 binary 协定进行了解决，开启 interpolateParams 会应用 text 协定执行 sql。

应用该 driver 在须要退出全局事务组和 tc 进行交互时，须要应用 db.BeginTx(ctx context.Context, opts driver.TxOptions) 办法，并在 ctx 中退出 XID 全局事务 id 的值 。

ctx := context.WithValue(context.Background(), mysql.XID, c.Request.Header.Get("XID"))
tx, err := dao.BeginTx(ctx, &sql.TxOptions{
        Isolation: sql.LevelDefault,
        ReadOnly:  false,
    })

XID 传递到 driver 层，会保留在 &mysqlConn 连贯对象中，在和 TC 交互时用到。

应用该 driver 的分布式事务性能前须要先初始化 seata-golang client 和 mysql driver：

  config.InitConf(configPath)
  client.NewRpcClient()
  mysql.InitDataResourceManager()
  mysql.RegisterResource(config.GetATConfig().DSN)

具体可参考 seata-go-samples。

此我的项目开源到往年 4 月即满一年，通过本文中的 mysql driver，心愿能升高应用门槛，让大家真正用起来，大家在抉择微服务开发技术栈时也不必放心 go 语言没有分布式事务处理计划。另外，此我的项目还很年老，仍有许多须要欠缺的中央，心愿感兴趣的敌人一起参加到社区来对它进行欠缺！心愿听到社区更多用户的反馈！
如果你有任何疑难，欢送钉钉扫码退出交换群【钉钉群号 33069364】：

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

seata 官网
java 版 seata
seata-golang 我的项目地址
driver 地址
seata-golang go 夜读 b 站分享
基于 getty 的 seata-golang 通信模型详解
seata-golang 接入指南
mysql protocol

版权申明： 本文内容由阿里云实名注册用户自发奉献，版权归原作者所有，阿里云开发者社区不领有其著作权，亦不承当相应法律责任。具体规定请查看《阿里云开发者社区用户服务协定》和《阿里云开发者社区知识产权爱护指引》。如果您发现本社区中有涉嫌剽窃的内容，填写侵权投诉表单进行举报，一经查实，本社区将立即删除涉嫌侵权内容。

关于关系型数据库:Go-Mysql-Driver-集成-SeataGolang-解决分布式事务问题

背景

转折

driver 的一些细节

寄语

作者简介

参考资料