在開發中，為了降低單點壓力，通常會根據業務情況進行分表分庫，將表分佈在不同的庫中（庫可能分佈在不同的機器上）。在這種場景下，事務的提交會變得相對複雜，因為多個節點（庫）的存在，可能存在部分節點提交失敗的情況，即事務的ACID特性需要在各個不同的資料庫例項中保證。比如更新db1庫的A表時，必須同步更新db2庫的B表，兩個更新形成一個事務，要麼都成功，要麼都失敗。
那麼我們如何利用mysql實現分散式資料庫的事務呢？

• 資源管理器（resource manager）：用來管理系統資源，是通向事務資源的途徑。資料庫就是一種資源管理器。資源管理還應該具有管理事務提交或回滾的能力。
• 事務管理器（transaction manager）：
  事務管理器是分散式事務的核心管理者。事務管理器與每個資源管理器（resource
  manager）進行通訊，協調並完成事務的處理。事務的各個分支由唯一命名進行標識。

mysql在執行分散式事務（外部XA）的時候，mysql伺服器相當於xa事務資源管理器，與mysql連結的客戶端相當於事務管理器。

分散式事務原理：分段式提交

分散式事務通常採用2PC協議，全稱Two Phase Commitment Protocol。該協議主要為了解決在分散式資料庫場景下，所有節點間資料一致性的問題。分散式事務通過2PC協議將提交分成兩個階段：

• prepare；
• commit/rollback

階段一為準備（prepare）階段

事務協調者transaction manager

因為XA 事務是基於兩階段提交協議的，所以需要有一個事務協調者（transaction manager）來保證所有的事務參與者都完成了準備工作(第一階段)。如果事務協調者（transaction manager）收到所有參與者都準備好的訊息，就會通知所有的事務都可以提交了（第二階段）。MySQL 在這個XA事務中扮演的是參與者的角色，而不是事務協調者（transaction manager）。

Mysql的XA事務分為外部XA和內部XA

• 外部XA用於跨多MySQL例項的分散式事務，需要應用層作為協調者，通俗的說就是比如我們在PHP中寫程式碼，那麼PHP書寫的邏輯就是協調者。應用層負責決定提交還是回滾，崩潰時的懸掛事務。MySQL資料庫外部XA可以用在分散式資料庫代理層，實現對MySQL資料庫的分散式事務支援，例如開源的代理工具：網易的DDB，淘寶的TDDL等等。
• 內部XA事務用於同一例項下跨多引擎事務，由Binlog作為協調者，比如在一個儲存引擎提交時，需要將提交資訊寫入二進位制日誌，這就是一個分散式內部XA事務，只不過二進位制日誌的參與者是MySQL本身。Binlog作為內部XA的協調者，在binlog中出現的內部xid，在crash recover時，由binlog負責提交。(這是因為，binlog不進行prepare，只進行commit，因此在binlog中出現的內部xid，一定能夠保證其在底層各儲存引擎中已經完成prepare)。

MySQL XA事務基本語法

XA {START|BEGIN} xid [JOIN|RESUME] 啟動xid事務 (xid 必須是一個唯一值; 不支援[JOIN|RESUME]子句)
XA END xid [SUSPEND [FOR MIGRATE]] 結束xid事務 ( 不支援[SUSPEND [FOR MIGRATE]] 子句)
XA PREPARE xid 準備、預提交xid事務
XA COMMIT xid [ONE PHASE] 提交xid事務
XA ROLLBACK xid 回滾xid事務
XA RECOVER 檢視處於PREPARE 階段的所有事務

PHP呼叫MYSQL XA事務示例

1、首先要確保mysql開啟XA事務支援

SHOW VARIABLES LIKE '%xa%'

如果innodb_support_xa的值是ON就說明mysql已經開啟對XA事務的支援了。
如果不是就執行：

SET innodb_support_xa = ON

開啟

2、程式碼如下：

<?PHP
$dbtest1 = new mysqli("172.20.101.17","public","public","dbtest1")or die("dbtest1 連線失敗");
$dbtest2     = new mysqli("172.20.101.18","public","public","dbtest2")or die("dbtest2 連線失敗");

//為XA事務指定一個id，xid 必須是一個唯一值。
$xid = uniqid("");

//兩個庫指定同一個事務id，表明這兩個庫的操作處於同一事務中
$dbtest1->query("XA START '$xid'");//準備事務1
$dbtest2->query("XA START '$xid'");//準備事務2

try {
    //$dbtest1
    $return = $dbtest1->query("UPDATE member SET name='唐大麥' WHERE id=1") ;
    if($return == false) {
       throw new Exception("庫[email protected]執行update member操作失敗！");
    }

    //$dbtest2
    $return = $dbtest2->query("UPDATE memberpoints SET point=point+10 WHERE memberid=1") ;
    if($return == false) {
       throw new Exception("庫[email protected]執行update memberpoints操作失敗！");
    }

    //階段1：$dbtest1提交準備就緒
    $dbtest1->query("XA END '$xid'");
    $dbtest1->query("XA PREPARE '$xid'");
    //階段1：$dbtest2提交準備就緒
    $dbtest2->query("XA END '$xid'");
    $dbtest2->query("XA PREPARE '$xid'");

    //階段2：提交兩個庫
    $dbtest1->query("XA COMMIT '$xid'");
    $dbtest2->query("XA COMMIT '$xid'");
} 
catch (Exception $e) {
    //階段2：回滾
    $dbtest1->query("XA ROLLBACK '$xid'");
    $dbtest2->query("XA ROLLBACK '$xid'");
    die($e->getMessage());
}

$dbtest1->close();
$dbtest2->close();

?>

XA的效能問題

XA的效能很低。一個數據庫的事務和多個數據庫間的XA事務效能對比可發現，效能差10倍左右。因此要儘量避免XA事務，例如可以將資料寫入本地，用高效能的訊息系統分發資料。或使用資料庫複製等技術。只有在這些都無法實現，且效能不是瓶頸時才應該使用XA。