事務(wù)(Transaction)是訪問(wèn)并可能更新數(shù)據(jù)庫(kù)中各種數(shù)據(jù)項(xiàng)的一個(gè)程序執(zhí)行單元；
事務(wù)的ACID特性
事務(wù)應(yīng)該具有4個(gè)屬性：原子性、一致性、隔離性、持續(xù)性
原子性（atomicity）。一個(gè)事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中包括的諸操作要么都做，要么都不做。
一致性（consistency）。事務(wù)必須是使數(shù)據(jù)庫(kù)從一個(gè)一致性狀態(tài)變到另一個(gè)一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
隔離性（isolation）。一個(gè)事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個(gè)事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對(duì)并發(fā)的其他事務(wù)是隔離的，并發(fā)執(zhí)行的各個(gè)事務(wù)之間不能互相干擾。
持久性（durability）。持續(xù)性也稱永久性（permanence），指一個(gè)事務(wù)一旦提交，它對(duì)數(shù)據(jù)庫(kù)中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來(lái)的其他操作或故障不應(yīng)該對(duì)其有任何影響。
分布式事務(wù)：分布式事務(wù)的參與者、資源管理器、事務(wù)管理器等位于不用的節(jié)點(diǎn)上，這些不同的節(jié)點(diǎn)相互協(xié)作共同完成一個(gè)具有邏輯完整性的事務(wù)。
mysql從5.0開(kāi)始支持XA DataSource。Connector/J 版本要使用5.0版本，5.0以下的不支持。
常見(jiàn)的分布式事務(wù)解決方案
基于XA協(xié)議的兩階段提交
XA協(xié)議由Tuxedo首先提出的，并交給X/Open組織，作為資源管理器（數(shù)據(jù)庫(kù)）與事務(wù)管理器的接口標(biāo)準(zhǔn)。目前，Oracle、Informix、DB2和Sybase等各大數(shù)據(jù)庫(kù)廠家都提供對(duì)XA的支持。XA協(xié)議采用兩階段提交方式來(lái)管理分布式事務(wù)。XA接口提供資源管理器與事務(wù)管理器之間進(jìn)行通信的標(biāo)準(zhǔn)接口。XA協(xié)議包括兩套函數(shù)，以xa_開(kāi)頭的及以ax_開(kāi)頭的。
以下的函數(shù)使事務(wù)管理器可以對(duì)資源管理器進(jìn)行的操作：
1）xa_open,xa_close：建立和關(guān)閉與資源管理器的連接。
2）xa_start,xa_end：開(kāi)始和結(jié)束一個(gè)本地事務(wù)。
3）xa_prepare,xa_commit,xa_rollback：預(yù)提交、提交和回滾一個(gè)本地事務(wù)。
4）xa_recover：回滾一個(gè)已進(jìn)行預(yù)提交的事務(wù)。
5）ax_開(kāi)頭的函數(shù)使資源管理器可以動(dòng)態(tài)地在事務(wù)管理器中進(jìn)行注冊(cè)，并可以對(duì)XID(TRANSACTION IDS)進(jìn)行操作。
6）ax_reg,ax_unreg；允許一個(gè)資源管理器在一個(gè)TMS(TRANSACTION MANAGER SERVER)中動(dòng)態(tài)注冊(cè)或撤消注冊(cè)。
XA實(shí)現(xiàn)分布式事務(wù)的原理如下：
MySQL XA分為兩類，內(nèi)部XA與外部XA;內(nèi)部XA用于同一實(shí)例下跨多個(gè)引擎的事務(wù)，由大家熟悉的Binlog作為協(xié)調(diào)者;外部XA用于跨多MySQL實(shí)例的分 布式事務(wù)，需要應(yīng)用層介入作為協(xié)調(diào)者(崩潰時(shí)的懸掛事務(wù)，全局提交還是回滾，需要由應(yīng)用層決定，對(duì)應(yīng)用層的實(shí)現(xiàn)要求較高);
Binlog作為內(nèi)部XA的協(xié)調(diào)者，在binlog中出現(xiàn)的內(nèi)部xid，在crash recover時(shí)，由binlog負(fù)責(zé)提交。(這是因?yàn)椋琤inlog不進(jìn)行prepare， 只進(jìn)行commit，因此在binlog中出現(xiàn)的內(nèi)部xid，一定能夠保證其在底層各存儲(chǔ)引擎中已經(jīng)完成prepare)。
MySQL數(shù)據(jù)庫(kù)外部XA可以用在分布式數(shù)據(jù)庫(kù)代理層，實(shí)現(xiàn)對(duì)MySQL數(shù)據(jù)庫(kù)的分布式事務(wù)支持，例如開(kāi)源的代理工具：網(wǎng)易的DDB，淘寶的TDDL，B2B的Cobar等等。
示例
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
public function testAction(){ $goods_id=1; $goods_name = "服務(wù)器之家"; $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); } } //提交事務(wù)！ public function commitdb($xa){ return $this->_db->query("XA COMMIT '$xa'"); } //回滾事務(wù) public function rollbackdb($xa){ return $this->_db->query("XA ROLLBACK '$xa'"); } //提交事務(wù)！ public function commitdb1($xa){ return $this->db1->query("XA COMMIT '$xa'"); } //回滾事務(wù) public function rollbackdb1($xa){ return $this->db1->query("XA ROLLBACK '$xa'"); } |
總結(jié)
分布式事務(wù)，本質(zhì)上是對(duì)多個(gè)數(shù)據(jù)庫(kù)的事務(wù)進(jìn)行統(tǒng)一控制，按照控制力度可以分為：不控制、部分控制和完全控制。不控制就是不引入分布式事務(wù)，部分控制就是各種變種的兩階段提交，包括上面提到的消息事務(wù)+最終一致性、TCC模式，而完全控制就是完全實(shí)現(xiàn)兩階段提交。部分控制的好處是并發(fā)量和性能很好，缺點(diǎn)是數(shù)據(jù)一致性減弱了，完全控制則是犧牲了性能，保障了一致性，具體用哪種方式，最終還是取決于業(yè)務(wù)場(chǎng)景。作為技術(shù)人員，一定不能忘了技術(shù)是為業(yè)務(wù)服務(wù)的，不要為了技術(shù)而技術(shù)，針對(duì)不同業(yè)務(wù)進(jìn)行技術(shù)選型也是一種很重要的能力
到此這篇關(guān)于PHP+Mysql分布式事務(wù)與解決方案深入理解的文章就介紹到這了,更多相關(guān)PHP+Mysql分布式事務(wù)與解決方案內(nèi)容請(qǐng)搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家！
原文鏈接：https://blog.csdn.net/liuxingjiaoyuC/article/details/110132660
