PHP+Mysql分散式事務與解決方案深入理解
事務(Transaction)是訪問並可能更新資料庫中各種資料項的一個程式執行單元；
事務的ACID特性
事務應該具有4個屬性：原子性、一致性、隔離性、持續性
原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。
一致性（consistency）。事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的資料對併發的其他事務是隔離的，併發執行的各個事務之間不能互相干擾。
永續性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對資料庫中資料的改變就應該是永久性的。接下來的其他操作或故障www.cppcns.com
分散式事務：分散式事務的參與者、資源管理器、事務管理器等位於不用的節點上，這些不同的節點相互協作共同完成一個具有邏輯完整性的事務。
mysql從5.0開始支援XA DataSource。Connector/J 版本要使用5.0版本，5.0以下的不支援。
常見的分散式事務解決方案
基於XA協議的兩階段提交
XA協議由Tuxedo首先提出的，並交給X/Open組織，作為資源管理器（資料庫）與事務管理器的介面標準。目前，Oracle、Informix、DB2和Sybase等各大資料庫廠家都提供對XA的支援。XA協議採用兩階段提交方式來管理分散式事務。XA介面提供資源管理器與事務管理器之間進行通訊的標準介面。XA協議包括兩套函式，以xa_開頭的及以ax_開頭的。
以下的函式使事務管理器可以對資源管理器進行的操作：
1）xa_open,xa_close：建立和關閉與資源管理器的連線。
2）xa_start,xa_end：開始和結束一個本地事務。
3）xa_prepare,xa_commit,xa_rollback：預提交、提交和回滾一個本地事務。
4）xa_recover：回滾一個已進行預提交的事務。
5）ax_開頭的函式使資源管理器可以動態地在事務管理器中進行註冊，並可以對XID(TRANSACTION IDS)進行操作。
6）ax_reg,ax_unreg；允許一個資源管理器在一個TMS(TRANSACTION MANAGER SERVER)中動態註冊或撤消註冊。
XA實現分散式事務的原理如下：
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等等。
示例
public function testAction(){
$goods_id=1;
$goods_name = "我們";
$num = 1;
$rs_order = $this->test->createorder($goods_id,$goods_name,$num);
$rs_goods = $this->test->deduction($goods_id,$num);
if($rs_order['status'] =="success" && $rs_goods['status']=="success"){
$this->test->commitdb($rs_order['XA']);
$this->test->commitdb1($rs_goods['XA']);
}else{
$this->test->rollbackdb($rs_order['XA']);
$this->test->rollbackdb1($rs_goods['XA']);
}
print_r($rs_order);
echo "<br />";
print_r($rs_goods);
die("dddd");
}
public function createorder($goods_id,$num){
$XA = uniqid("");
$this->_db->query("XA START '$XA'");
$_rs = true;
try {
$data = array();
$data['order_id'] = "V".date("YmdHis");
$data['goods_name'] = $goods_name;
$data['goods_num'] = $num;
$this->_db->insert("temp_orders",$data);
$rs = $this->_db->lastInsertId();
if($rs){
$_rs = true;
}else{
$_rs = false;
}
} catch (Exception $e) {
$_rs = false;
}
$this->_db->query("XA END '$XA'");
if($_rs){
$this->_db->query("XA PREPARE '$XA'");程式設計客棧
return array("status"=>"success","XA"=>$XA);
}else{
return array("status"=>"nosuccess","XA"=>$XA);
}
}
public function de程式設計客棧duction($id){
$XA = uniqid("");
$this->db1->query("XA START '$XA'");
$last_rs = true;
try {
$sql = "select * from temp_goods where id = '$id' and goods_num>0";
$rs = $this->db1->fetchRow($sql);
if(!empty($rs)){
$sql = "update temp_goods set goods_num = goods_num-1 where id = '$id'";
$rd = $this->db1->query($sql);
if($rd){
$last_rs = true;
}else{
$last_rs = false;
}
}else{
$last_rs = false;;
}
} catch (Exception $e) {
$last_rs = false;;
}
$this->db1->query("XA END '$XA'");
if($last_rs){
$this->db1->query("XA PREPARE '$XA'");
return array("status"=>"success","XA"=>$XA);
}
}
//提交事務！
public function commitdb($xa){
return $this->_db->query("XA COMMIT '$xa'");
}
//回滾事務
public function rollbackdb($xa){
return $this->_db->query("XA ROLLBACwww.cppcns.comK '$xa'");
}
//提交事務！
public function commitdb1($xa){
return $this->db1->query("XA COMMIT '$xa'");
}
//回滾事務
public function rollbackdb1($xa){
return $this->db1->query("XA ROLLBACK '$xa'");
}
總結
分散式事務，本質上是對多個數據庫的事務進行統一控制，按照控制力度可以分為：不控制、部分控制和完全控制。不控制就是不引入分散式事務，部www.cppcns.com分控制就是各種變種的兩階段提交，包括上面提到的訊息事務+最終一致性、TCC模式，而完全控制就是完全實現兩階段提交。部分控制的好處是併發量和效能很好，缺點是資料一致性減弱了，完全控制則是犧牲了效能，保障了一致性，具體用哪種方式，最終還是取決於業務場景。作為技術人員，一定不能忘了技術是為業務服務的，不要為了技術而技術，針對不同業務進行技術選型也是一種很重要的能力
到此這篇關於php+Mysql分散式事務與解決方案深入理解的文章就介紹到這了,更多相關PHP+Mysql分散式事務與解決方案內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！