国产片侵犯亲女视频播放_亚洲精品二区_在线免费国产视频_欧美精品一区二区三区在线_少妇久久久_在线观看av不卡

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - PHP教程 - PHP+Mysql分布式事務與解決方案深入理解

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

2021-11-08 15:00newname PHP教程

這篇文章主要介紹了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實現分布式事務的原理如下:

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

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等等。

示例

?
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 = "服務器之家";
    $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分布式事務與解決方案內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家!

原文鏈接:https://blog.csdn.net/liuxingjiaoyuC/article/details/110132660

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 国产精品亚洲第一区在线暖暖韩国 | 五月婷婷香蕉 | 好看的国产精彩视频 | 一本大的之伊人 | 日韩欧美精品一区二区三区 | 日韩一区二区三区在线视频 | 久久久久久久久成人 | 亚洲精品视 | 精品美女一区 | 亚洲成人日韩在线 | 国产精品免费久久久久久久久久中文 | 激情综合在线 | 久久久久成人精品免费播放动漫 | 九色av | 亚洲三区在线观看 | 免费观看在线午夜影视 | 精品动漫一区 | 性色av一区二区三区红粉影视 | 久久久激情| 亚洲精品片 | 福利一区二区 | 成人激情在线播放 | 久久九| 色135综合网 | 毛片免费电影 | 成人激情免费视频 | 国产精品久久久爽爽爽麻豆色哟哟 | www.久久99| 日韩欧美视频观看 | 日日干天天干 | 亚洲欧美另类久久久精品2019 | 日韩一区二区在线观看 | 日韩在线视频在线观看 | 欧美黑人一级爽快片淫片高清 | 性做久久 | 亚洲一区二区视频在线观看 | 国内在线精品 | 亚洲乱码国产乱码精品精98午夜 | 国产中文字幕观看 | 天天射天天干 | 一级片在线播放 |