头图.png

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

背景

2020 年 4 月，我们开始尝试实现 go 语言的分布式事务框架 Seata-Golang。众所周知，Seata AT 模式以无业务代码侵入的特点，被广大开发者推崇。Java 版 Seata AT 模式通过对 DataSource 数据源进行代理，在 sql 语句执行时，对 sql 拦截解析，获取数据库对应数据在 sql 语句执行前后的副本，序列化后保存起来，在 TC 协调回滚时用来回滚对应数据。实现 go 版本 client 的 AT 模式时，怎样对业务开发者更友好，入侵更少，成了首要考虑的目标。

1.png

database/sqlsql.Open("mysql", ${dsn})db.Begin()db.BeginTx(ctx, &sql.TxOptions{})tx.Querytx.Exectx.Commit()tx.Rollback()
database/sqldatabase/sqldatabase/sql
[username[:password]@][protocol[(address)]]/dbname[?param1=value1&...¶mN=valueN]
database/sqldatabase/sqldatabase/sqlBegin()database/sql
type Tx interface {
	Commit() error
	Rollback() error
}
转折 
database/sqlconfig.GetATConfig()

2.png

database/sql
driver 的一些细节
  • 使用该 driver 进行分布式事务操作时，不能在 dsn 中设置 interpolateParams 参数为 true。

这涉及到 mysql 的两个协议：Text 协议和 Binary 协议。有关两个协议的区别，可以在文末参考文档找到资料。实现该 driver 只对 binary 协议进行了处理，开启 interpolateParams 会使用 text 协议执行 sql。

db.BeginTx(ctx context.Context, opts driver.TxOptions)XID
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 语言，在云原生和微服务相关技术方向均有涉猎，目前专攻分布式事务。

参考资料