主頁 > 知識(shí)庫 > PHP+Mysql分布式事務(wù)與解決方案深入理解

PHP+Mysql分布式事務(wù)與解決方案深入理解

熱門標(biāo)簽:衡水外呼系統(tǒng)平臺(tái) 百度商鋪地圖標(biāo)注 安裝電銷外呼系統(tǒng) 地圖標(biāo)注平臺(tái)怎么給錢注冊(cè) 注冊(cè)400電話申請(qǐng) 釘釘打卡地圖標(biāo)注 福州人工外呼系統(tǒng)哪家強(qiáng) 新河科技智能外呼系統(tǒng)怎么樣 常州地圖標(biāo)注服務(wù)商

事務(wù)(Transaction)是訪問并可能更新數(shù)據(jù)庫中各種數(shù)據(jù)項(xiàng)的一個(gè)程序執(zhí)行單元;

事務(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ù)場(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)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

您可能感興趣的文章:
  • Android和PHP MYSQL交互開發(fā)實(shí)例
  • Mac M1安裝mnmp(Mac+Nginx+MySQL+PHP)開發(fā)環(huán)境
  • PHP加MySQL消息隊(duì)列深入理解
  • PHP連接MySQL數(shù)據(jù)庫三種實(shí)現(xiàn)方法
  • 深入理解PHP+Mysql分布式事務(wù)與解決方案
  • Aliyun Linux 編譯安裝 php7.3 tengine2.3.2 mysql8.0 redis5的過程詳解
  • php7連接MySQL實(shí)現(xiàn)簡(jiǎn)易查詢程序的方法
  • PHP之mysql位運(yùn)算案例講解

標(biāo)簽:白城 六安 克拉瑪依 唐山 鶴崗 鷹潭 柳州 遼陽

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《PHP+Mysql分布式事務(wù)與解決方案深入理解》,本文關(guān)鍵詞  PHP+Mysql,分布式,事務(wù),與,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《PHP+Mysql分布式事務(wù)與解決方案深入理解》相關(guān)的同類信息!
  • 本頁收集關(guān)于PHP+Mysql分布式事務(wù)與解決方案深入理解的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章