PHP+Mysql分佈式事務與解決方案深入理解
事務(Transaction)是訪問並可能更新數據庫中各種數據項的一個程序執行單元;
事務的ACID特性
事務應該具有4個屬性:原子性、一致性、隔離性、持續性
原子性(atomicity)。一個事務是一個不可分割的工作單位,事務中包括的諸操作要麼都做,要麼都不做。
一致性(consistency)。事務必須是使數據庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
隔離性(isolation)。一個事務的執行不能被其他事務幹擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的,並發執行的各個事務之間不能互相幹擾。
持久性(durability)。持續性也稱永久性(permanence),指一個事務一旦提交,它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。
分佈式事務:分佈式事務的參與者、資源管理器、事務管理器等位於不用的節點上,這些不同的節點相互協作共同完成一個具有邏輯完整性的事務。
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 = "WalkonNet"; $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,$goods_name,$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 deduction($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); }else{ return array("status"=>"nosuccess","XA"=>$XA); } } //提交事務! public function commitdb($xa){ return $this->_db->query("XA COMMIT '$xa'"); } //回滾事務 public function rollbackdb($xa){ return $this->_db->query("XA ROLLBACK '$xa'"); } //提交事務! public function commitdb1($xa){ return $this->db1->query("XA COMMIT '$xa'"); } //回滾事務 public function rollbackdb1($xa){ return $this->db1->query("XA ROLLBACK '$xa'"); }
總結
分佈式事務,本質上是對多個數據庫的事務進行統一控制,按照控制力度可以分為:不控制、部分控制和完全控制。不控制就是不引入分佈式事務,部分控制就是各種變種的兩階段提交,包括上面提到的消息事務+最終一致性、TCC模式,而完全控制就是完全實現兩階段提交。部分控制的好處是並發量和性能很好,缺點是數據一致性減弱瞭,完全控制則是犧牲瞭性能,保障瞭一致性,具體用哪種方式,最終還是取決於業務場景。作為技術人員,一定不能忘瞭技術是為業務服務的,不要為瞭技術而技術,針對不同業務進行技術選型也是一種很重要的能力
到此這篇關於PHP+Mysql分佈式事務與解決方案深入理解的文章就介紹到這瞭,更多相關PHP+Mysql分佈式事務與解決方案內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- PHP隊列場景以及實現代碼實例詳解
- Mysql中undo、redo與binlog的區別淺析
- MySQL配置瞭雙主,是如何避免出現數據回環沖突的
- MySQL組提交group commit詳解
- MySQL悲觀鎖與樂觀鎖的實現方案