PHP分佈式事務-兩段式提交 2PC

事務(Transaction)是訪問並可能更新數據庫中各類數據項的一個程序執行單元

事務應該具備4個屬性：****原子性、一致性、隔離性、持續性、原子性（atomicity）
    一個事務是一個不可分割的工做單位，事務中包括的諸操做要麼都作，要麼都不。
原子性（atomicity）
    一個事務是一個不可分割的工做單位，事務中包括的諸操做要麼都作，要麼都不作。
一致性（consistency）
    事務必須是使數據庫從一個一致性狀態變到另外一個一致性狀態。一致性與原子性是密切相關的。
隔離性（isolation）
    一個事務的執行不能被其餘事務干擾。即一個事務內部的操做及使用的數據對併發的其餘事務是隔離的，併發執行的各個事務之間不能互相干擾。
持久性（durability）
    持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其餘操做或故障不該該對其有任何影響。

分佈式事務：分佈式事務的參與者、資源管理器、事務管理器等位於不用的節點上，這些不一樣的節點相互協做共同完成一個具備邏輯完整性的事務。

mysql從5.0開始支持XA DataSource。Connector/J 版本要使用5.0版本，5.0如下的不支持。
XA協議由Tuxedo首先提出的，並交給X/Open組織，做爲資源管理器（數據庫）與事務管理器的接口標準。目前，Oracle、Informix、DB2和Sybase等各大數據庫廠家都提供對XA的支持。XA協議採用兩階段提交方式來管理分佈式事務。XA接口提供資源管理器與事務管理器之間進行通訊的標準接口。XA協議包括兩套函數，以xa_開頭的及以ax_開頭的。

如下的函數使事務管理器能夠對資源管理器進行的操做：
xa_open,xa_close：創建和關閉與資源管理器的鏈接。
xa_start,xa_end：開始和結束一個本地事務。
xa_prepare,xa_commit,xa_rollback：預提交、提交和回滾一個本地事務。
xa_recover：回滾一個已進行預提交的事務。
ax_開頭的函數使資源管理器能夠動態地在事務管理器中進行註冊，並能夠對XID(TRANSACTION IDS)進行操做。
ax_reg,ax_unreg；容許一個資源管理器在一個TMS(TRANSACTION MANAGER SERVER)中動態註冊或撤消註冊。

MySQL XA分爲兩類，內部XA與外部XA;內部XA用於同一實例下跨多個引擎的事務，由你們熟悉的Binlog做爲協調者;外部XA用於跨多MySQL實例的分 布式事務，須要應用層介入做爲協調者(崩潰時的懸掛事務，全局提交仍是回滾，須要由應用層決定，對應用層的實現要求較高);
Binlog做爲內部XA的協調者，在binlog中出現的內部xid，在crash recover時，由binlog負責提交。(這是由於，binlog不進行prepare， 只進行commit，所以在binlog中出現的內部xid，必定可以保證其在底層各存儲引擎中已經完成prepare)。
MySQL數據庫外部XA能夠用在分佈式數據庫代理層，實現對MySQL數據庫的分佈式事務支持，例如開源的代理工具：網易的DDB，淘寶的TDDL，B2B的Cobar等等。

PHP簡單2PC示例：

數據庫

order數據庫
CREATE TABLE `order` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`order_no` varchar(32) DEFAULT NULL,
`goods_id` int(11) DEFAULT NULL,
`goods_name` varchar(255) DEFAULT NULL,
`goods_num` int(11) DEFAULT NULL,
`create_time` int(10) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=20 DEFAULT CHARSET=utf8mb4
goods數據庫
CREATE TABLE `goods` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(255) DEFAULT NULL,
`num` int(11) unsigned DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4

PHP代碼

/**
* 分佈式事務測試
*/
//order
$dns_order = new PDO('mysql:host=10.211.55.100;dbname=order', 'orders', '123456aA!');
//goods
$dns_goods = new PDO('mysql:host=10.211.55.101;dbname=goods', 'goods', '123456aA!');
var_dump($dns_order);
echo '
';
var_dump($dns_goods);
echo '
';
$_grid = uniqid("");
$_o = false;
$_g = false;
//1.準備事務
$dns_order->query('XA START \''.$_grid.'\'');
$dns_goods->query('XA START \''.$_grid.'\'');
try {
//2.更新order表
$sql = 'INSERT INTO `order` (order_no, goods_id, goods_name, goods_num, create_time) VALUES (\''.time().'\', 1, \'test\', 1, \''.time().'\')';
$resultOrder = $dns_order->query($sql);
if ($resultOrder === false) {
echo 'order更新失敗';
} else {
if ($resultOrder->rowCount() > 0) {
//4.成功通知準備提交
var_dump($dns_order->query('XA END \''.$_grid.'\''));
var_dump($dns_order->query('XA PREPARE \''.$_grid.'\''));
var_dump($resultOrder->rowCount());
$_o = true;
}
}
if($_o == true) {
echo '
';
//3.更新goods表
$sql = "UPDATE `goods` SET `num` = `num` - 1 WHERE `id` = 2";
$resultGoods = $dns_goods->query($sql);
if ($resultGoods === false) {
echo 'goods更新失敗';
} else {
if ($resultGoods->rowCount() > 0) {
//4.成功通知準備提交
var_dump($dns_goods->query('XA END \''.$_grid.'\''));
var_dump($dns_goods->query('XA PREPARE \''.$_grid.'\''));
var_dump($resultGoods->rowCount());
$_g = true;
} else {
echo 'goods未更新記錄';
}
}
}
echo '
'.'-----狀態------';
var_dump($_grid);
var_dump($_o);
var_dump($_g);
echo '-----狀態------';
if ($_o == true && $_g == true) {
//5.提交SQL
var_dump($dns_order->query('XA COMMIT \''.$_grid.'\''));
var_dump($dns_goods->query('XA COMMIT \''.$_grid.'\''));
echo '
'.'成功!!!!!!';
} else {
//4.失敗回滾
echo '
'.'失敗回滾';
$dns_order->query('XA ROLLBACK \''.$_grid.'\'');
$dns_goods->query('XA ROLLBACK \''.$_grid.'\'');
}
} catch (Exception $e) {
//4.失敗回滾
$dns_order->query('XA ROLLBACK \''.$_grid.'\'');
$dns_goods->query('XA ROLLBACK \''.$_grid.'\'');
throw new Exception('執行失敗');
}