事務(Transaction)是訪問并可能更新數(shù)據(jù)庫中各種數(shù)據(jù)項的一個程序執(zhí)行單元;
事務的ACID特性
事務應該具有4個屬性:原子性、一致性、隔離性、持續(xù)性
原子性(atomicity)。一個事務是一個不可分割的工作單位,事務中包括的諸操作要么都做,要么都不做。
一致性(consistency)。事務必須是使數(shù)據(jù)庫從一個一致性狀態(tài)變到另一個一致性狀態(tài)。一致性與原子性是密切相關的。
隔離性(isolation)。一個事務的執(zhí)行不能被其他事務干擾。即一個事務內(nèi)部的操作及使用的數(shù)據(jù)對并發(fā)的其他事務是隔離的,并發(fā)執(zhí)行的各個事務之間不能互相干擾。
持久性(durability)。持續(xù)性也稱永久性(permanence),指一個事務一旦提交,它對數(shù)據(jù)庫中數(shù)據(jù)的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。
分布式事務:分布式事務的參與者、資源管理器、事務管理器等位于不用的節(jié)點上,這些不同的節(jié)點相互協(xié)作共同完成一個具有邏輯完整性的事務。
mysql從5.0開始支持XA DataSource。Connector/J 版本要使用5.0版本,5.0以下的不支持。
常見的分布式事務解決方案
基于XA協(xié)議的兩階段提交
XA協(xié)議由Tuxedo首先提出的,并交給X/Open組織,作為資源管理器(數(shù)據(jù)庫)與事務管理器的接口標準。目前,Oracle、Informix、DB2和Sybase等各大數(shù)據(jù)庫廠家都提供對XA的支持。XA協(xié)議采用兩階段提交方式來管理分布式事務。XA接口提供資源管理器與事務管理器之間進行通信的標準接口。XA協(xié)議包括兩套函數(shù),以xa_開頭的及以ax_開頭的。
以下的函數(shù)使事務管理器可以對資源管理器進行的操作:
1)xa_open,xa_close:建立和關閉與資源管理器的連接。
2)xa_start,xa_end:開始和結束一個本地事務。
3)xa_prepare,xa_commit,xa_rollback:預提交、提交和回滾一個本地事務。
4)xa_recover:回滾一個已進行預提交的事務。
5)ax_開頭的函數(shù)使資源管理器可以動態(tài)地在事務管理器中進行注冊,并可以對XID(TRANSACTION IDS)進行操作。
6)ax_reg,ax_unreg;允許一個資源管理器在一個TMS(TRANSACTION MANAGER SERVER)中動態(tài)注冊或撤消注冊。
XA實現(xiàn)分布式事務的原理如下:
MySQL XA分為兩類,內(nèi)部XA與外部XA;內(nèi)部XA用于同一實例下跨多個引擎的事務,由大家熟悉的Binlog作為協(xié)調(diào)者;外部XA用于跨多MySQL實例的分 布式事務,需要應用層介入作為協(xié)調(diào)者(崩潰時的懸掛事務,全局提交還是回滾,需要由應用層決定,對應用層的實現(xiàn)要求較高);
Binlog作為內(nèi)部XA的協(xié)調(diào)者,在binlog中出現(xiàn)的內(nèi)部xid,在crash recover時,由binlog負責提交。(這是因為,binlog不進行prepare, 只進行commit,因此在binlog中出現(xiàn)的內(nèi)部xid,一定能夠保證其在底層各存儲引擎中已經(jīng)完成prepare)。
MySQL數(shù)據(jù)庫外部XA可以用在分布式數(shù)據(jù)庫代理層,實現(xiàn)對MySQL數(shù)據(jù)庫的分布式事務支持,例如開源的代理工具:網(wǎng)易的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,$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'");
}
總結
分布式事務,本質(zhì)上是對多個數(shù)據(jù)庫的事務進行統(tǒng)一控制,按照控制力度可以分為:不控制、部分控制和完全控制。不控制就是不引入分布式事務,部分控制就是各種變種的兩階段提交,包括上面提到的消息事務+最終一致性、TCC模式,而完全控制就是完全實現(xiàn)兩階段提交。部分控制的好處是并發(fā)量和性能很好,缺點是數(shù)據(jù)一致性減弱了,完全控制則是犧牲了性能,保障了一致性,具體用哪種方式,最終還是取決于業(yè)務場景。作為技術人員,一定不能忘了技術是為業(yè)務服務的,不要為了技術而技術,針對不同業(yè)務進行技術選型也是一種很重要的能力
到此這篇關于PHP+Mysql分布式事務與解決方案深入理解的文章就介紹到這了,更多相關PHP+Mysql分布式事務與解決方案內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
您可能感興趣的文章: Android和PHP MYSQL交互開發(fā)實例 Mac M1安裝mnmp(Mac+Nginx+MySQL+PHP)開發(fā)環(huán)境 PHP加MySQL消息隊列深入理解 PHP連接MySQL數(shù)據(jù)庫三種實現(xiàn)方法 深入理解PHP+Mysql分布式事務與解決方案 Aliyun Linux 編譯安裝 php7.3 tengine2.3.2 mysql8.0 redis5的過程詳解 php7連接MySQL實現(xiàn)簡易查詢程序的方法 PHP之mysql位運算案例講解