PHP和Mysql事務(wù)的特性以及常見的分布式事務(wù)解決方案

本篇內(nèi)容介紹了“PHP和Mysql事務(wù)的特性以及常見的分布式事務(wù)解決方案”的有關(guān)知識(shí)，在實(shí)際案例的操作過程中，不少人都會(huì)遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

事務(wù)的ACID特性

事務(wù)應(yīng)該具有4個(gè)屬性：原子性、一致性、隔離性、持續(xù)性

原子性（atomicity）。一個(gè)事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中包括的諸操作要么都做，要么都不做。 
一致性（consistency）。事務(wù)必須是使數(shù)據(jù)庫從一個(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ù)庫中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來的其他操作或故障不應(yīng)該對(duì)其有任何影響。

分布式事務(wù)：分布式事務(wù)的參與者、資源管理器、事務(wù)管理器等位于不用的節(jié)點(diǎn)上，這些不同的節(jié)點(diǎn)相互協(xié)作共同完成一個(gè)具有邏輯完整性的事務(wù)。

mysql從5.0開始支持XA DataSource。Connector/J 版本要使用5.0版本，5.0以下的不支持。

常見的分布式事務(wù)解決方案

基于XA協(xié)議的兩階段提交

XA協(xié)議由Tuxedo首先提出的，并交給X/Open組織，作為資源管理器（數(shù)據(jù)庫）與事務(wù)管理器的接口標(biāo)準(zhǔn)。目前，Oracle、Informix、DB2和Sybase等各大數(shù)據(jù)庫廠家都提供對(duì)XA的支持。XA協(xié)議采用兩階段提交方式來管理分布式事務(wù)。XA接口提供資源管理器與事務(wù)管理器之間進(jìn)行通信的標(biāo)準(zhǔn)接口。XA協(xié)議包括兩套函數(shù)，以xa_開頭的及以ax_開頭的。

以下的函數(shù)使事務(wù)管理器可以對(duì)資源管理器進(jìn)行的操作： 
1）xa_open,xa_close：建立和關(guān)閉與資源管理器的連接。 
2）xa_start,xa_end：開始和結(jié)束一個(gè)本地事務(wù)。 
3）xa_prepare,xa_commit,xa_rollback：預(yù)提交、提交和回滾一個(gè)本地事務(wù)。 
4）xa_recover：回滾一個(gè)已進(jìn)行預(yù)提交的事務(wù)。 
5）ax_開頭的函數(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ù)庫外部XA可以用在分布式數(shù)據(jù)庫代理層，實(shí)現(xiàn)對(duì)MySQL數(shù)據(jù)庫的分布式事務(wù)支持，例如開源的代理工具：網(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);
         }

    }
    //提交事務(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ù)庫的事務(wù)進(jìn)行統(tǒng)一控制，按照控制力度可以分為：不控制、部分控制和完全控制。不控制就是不引入分布式事務(wù)，部分控制就是各種變種的兩階段提交，包括上面提到的消息事務(wù)+最終一致性、TCC模式，而完全控制就是完全實(shí)現(xiàn)兩階段提交。部分控制的好處是并發(fā)量和性能很好，缺點(diǎn)是數(shù)據(jù)一致性減弱了，完全控制則是犧牲了性能，保障了一致性，具體用哪種方式，最終還是取決于業(yè)務(wù)場景。作為技術(shù)人員，一定不能忘了技術(shù)是為業(yè)務(wù)服務(wù)的，不要為了技術(shù)而技術(shù)，針對(duì)不同業(yè)務(wù)進(jìn)行技術(shù)選型也是一種很重要的能力

“PHP和Mysql事務(wù)的特性以及常見的分布式事務(wù)解決方案”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！