本篇內(nèi)容介紹了“如何解決MySQL分布式事務(wù)問題”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

創(chuàng)新互聯(lián)公司是創(chuàng)新、創(chuàng)意、研發(fā)型一體的綜合型網(wǎng)站建設(shè)公司，自成立以來公司不斷探索創(chuàng)新，始終堅持為客戶提供滿意周到的服務(wù)，在本地打下了良好的口碑，在過去的十載時間我們累計服務(wù)了上千家以及全國政企客戶，如玻璃隔斷等企業(yè)單位，完善的項目管理流程，嚴(yán)格把控項目進(jìn)度與質(zhì)量監(jiān)控加上過硬的技術(shù)實力獲得客戶的一致贊美。

背景

2020 年 4 月，我們開始嘗試實現(xiàn) go 語言的分布式事務(wù)框架 Seata-Golang。眾所周知，Seata AT 模式以無業(yè)務(wù)代碼侵入的特點，被廣大開發(fā)者推崇。Java 版 Seata AT 模式通過對 DataSource 數(shù)據(jù)源進(jìn)行代理，在 sql 語句執(zhí)行時，對 sql 攔截解析，獲取數(shù)據(jù)庫對應(yīng)數(shù)據(jù)在 sql 語句執(zhí)行前后的副本，序列化后保存起來，在 TC 協(xié)調(diào)回滾時用來回滾對應(yīng)數(shù)據(jù)。實現(xiàn) go 版本 client 的 AT 模式時，怎樣對業(yè)務(wù)開發(fā)者更友好，入侵更少，成了首要考慮的目標(biāo)。

使用 go 操作數(shù)據(jù)庫時，我們會使用到 go 語言的官方庫 database/sql，通過 sql.Open("mysql", ${dsn}) 獲取一個數(shù)據(jù)源操作對象 db。開啟事務(wù)時，使用 db.Begin() 或 db.BeginTx(ctx, &sql.TxOptions{}) 獲得事務(wù)操作對象 tx，執(zhí)行 sql 查詢使用 tx.Query；執(zhí)行 sql 新增、修改、刪除，使用 tx.Exec；最后使用 tx.Commit() 提交或使用 tx.Rollback() 回滾。

go 語言官方庫 database/sql 提供了一個標(biāo)準(zhǔn)抽象層，通過實現(xiàn)不同的 driver 一套標(biāo)準(zhǔn)的抽象 API 可以操作不同的數(shù)據(jù)庫。開發(fā) Go 版本的 AT 模式，必然要兼容 database/sql。通過研究 database/sql 的 api，創(chuàng)建數(shù)據(jù)源操作對象，數(shù)據(jù)庫有關(guān)的配置必須通過 Data Source Name (DSN) 抽象傳遞進(jìn)去，下面是 DSN 的定義：

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

實現(xiàn) AT 模式對數(shù)據(jù)源代理是需要和事務(wù)協(xié)調(diào)器 TC 進(jìn)行交互的，如果將 AT 模式實現(xiàn)在 driver 層，那么和 TC 交互的一些參數(shù)必須要通過 DSN 傳遞到 driver，這樣有些破壞它的設(shè)計。所以，最后采取了一種折中方案，在 database/sql 層之上實現(xiàn) AT 模式，代理 database/sql 創(chuàng)建出來的數(shù)據(jù)源操作對象。數(shù)據(jù)源代理對象實現(xiàn) database/sql 庫定義的 Tx 接口，另外再提供一個開啟事務(wù)的方法：Begin()，雖然沒有完全兼容 database/sql 的 api，但是關(guān)鍵接口和它的定義成一樣，勉強(qiáng)還能接受。到此，Seata-Golang 項目核心功能的開發(fā)已完成。

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

轉(zhuǎn)折

Seata-Golang 開源后，逐漸被一些開發(fā)者了解和接觸，社區(qū)也對 Seata-Golang 發(fā)出了一些反饋的聲音，不少開發(fā)者并不習(xí)慣寫原生 sql，他們希望將 Seata-Golang 集成到 ORM 框架，因為當(dāng)時的設(shè)計沒有完全兼容 database/sql 導(dǎo)致集成上遇到一些困難。隨著社區(qū)的熱切呼喚，且得益于前期對 driver 的一些研究，念念不忘必有回響，今年 3 月突然靈感迸發(fā)：為什么參數(shù)一定要通過 DSN 傳遞？Seata-Golang Client 初始化后，在需要時通過 Client 端的 API config.GetATConfig() 直接獲取使用不就可以了。

于是工作之余，歷時 2 周開發(fā)，第一個集成 Seata-Golang 的完全兼容 database/sql 的 mysql driver 被開發(fā)出來

driver 的一些細(xì)節(jié)

• 使用該 driver 進(jìn)行分布式事務(wù)操作時，不能在 dsn 中設(shè)置 interpolateParams 參數(shù)為 true。

這涉及到 mysql 的兩個協(xié)議：Text 協(xié)議和 Binary 協(xié)議。有關(guān)兩個協(xié)議的區(qū)別，可以在文末參考文檔找到資料。實現(xiàn)該 driver 只對 binary 協(xié)議進(jìn)行了處理，開啟 interpolateParams 會使用 text 協(xié)議執(zhí)行 sql。

• 使用該 driver 在需要加入全局事務(wù)組和 tc 進(jìn)行交互時，需要使用 db.BeginTx(ctx context.Context, opts driver.TxOptions) 方法，并在 ctx 中加入 XID 全局事務(wù) 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 的分布式事務(wù)功能前需要先初始化 seata-golang client 和 mysql driver：

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

“如何解決Mysql分布式事務(wù)問題”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！