电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

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

瀏覽:97日期:2022-09-08 15:59:46

事務(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等等。

示例

public function testAction(){ $goods_id=1; $goods_name = '關注PHP開源社區微信公眾號領取PHP大廠面試題'; $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分布式事務內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: PHP
相關文章:
主站蜘蛛池模板: 叉车电池-叉车电瓶-叉车蓄电池-铅酸蓄电池-电动叉车蓄电池生产厂家 | 云南外加剂,云南速凝剂,云南外加剂代加工-普洱澜湄新材料科技有限公司 | 武汉高低温试验箱_恒温恒湿试验箱厂家-武汉蓝锐环境科技有限公司 | 步进电机_agv电机_伺服马达-伺服轮毂电机-和利时电机 | 包塑丝_高铁绑丝_地暖绑丝_涂塑丝_塑料皮铁丝_河北创筹金属丝网制品有限公司 | 美国PARKER齿轮泵,美国PARKER柱塞泵,美国PARKER叶片泵,美国PARKER电磁阀,美国PARKER比例阀-上海维特锐实业发展有限公司二部 | 智能化的检漏仪_气密性测试仪_流量测试仪_流阻阻力测试仪_呼吸管快速检漏仪_连接器防水测试仪_车载镜头测试仪_奥图自动化科技 | 济南办公室装修-厂房装修-商铺装修-工装公司-山东鲁工装饰设计 | 云南外加剂,云南速凝剂,云南外加剂代加工-普洱澜湄新材料科技有限公司 | 桂林腻子粉_内墙外墙抗裂砂浆腻子粉推荐广西鑫达涂料厂家供应 | ?水马注水围挡_塑料注水围挡_防撞桶-常州瑞轩水马注水围挡有限公司 | WF2户外三防照明配电箱-BXD8050防爆防腐配电箱-浙江沃川防爆电气有限公司 | 伊卡洛斯软装首页-电动窗帘,别墅窗帘,定制窗帘,江浙沪1000+别墅窗帘案例 | 航空铝型材,7系铝型材挤压,硬质阳*氧化-余润铝制品 | 皮带机-带式输送机价格-固定式胶带机生产厂家-河南坤威机械 | TPE塑胶原料-PPA|杜邦pom工程塑料、PPSU|PCTG材料、PC/PBT价格-悦诚塑胶 | 恒湿机_除湿加湿一体机_恒湿净化消毒一体机厂家-杭州英腾电器有限公司 | 焊锡丝|焊锡条|无铅锡条|无铅锡丝|无铅焊锡线|低温锡膏-深圳市川崎锡业科技有限公司 | 在线PH计-氧化锆分析仪-在线浊度仪-在线溶氧仪- 无锡朝达 | 智慧旅游_智慧景区_微景通-智慧旅游景区解决方案提供商 | 广东泵阀展|阀门展-广东国际泵管阀展览会 | 无缝钢管-聊城无缝钢管-小口径无缝钢管-大口径无缝钢管 - 聊城宽达钢管有限公司 | 聚合氯化铝_喷雾聚氯化铝_聚合氯化铝铁厂家_郑州亿升化工有限公司 | 苹果售后维修点查询,苹果iPhone授权售后维修服务中心 – 修果网 拼装地板,悬浮地板厂家,悬浮式拼装运动地板-石家庄博超地板科技有限公司 | 真空搅拌机-行星搅拌机-双行星动力混合机-广州市番禺区源创化工设备厂 | 培训中心-翰香原香酥板栗饼加盟店总部-正宗板栗酥饼技术 | 长沙印刷厂-包装印刷-画册印刷厂家-湖南省日大彩色印务有限公司 青州搬家公司电话_青州搬家公司哪家好「鸿喜」青州搬家 | 移动厕所租赁|移动卫生间|上海移动厕所租赁-家瑞租赁 | 珠海白蚁防治_珠海灭鼠_珠海杀虫灭鼠_珠海灭蟑螂_珠海酒店消杀_珠海工厂杀虫灭鼠_立净虫控防治服务有限公司 | 冲击式破碎机-冲击式制砂机-移动碎石机厂家_青州市富康机械有限公司 | 河北中仪伟创试验仪器有限公司是专业生产沥青,土工,水泥,混凝土等试验仪器的厂家,咨询电话:13373070969 | 不锈钢反应釜,不锈钢反应釜厂家-价格-威海鑫泰化工机械有限公司 不干胶标签-不干胶贴纸-不干胶标签定制-不干胶标签印刷厂-弗雷曼纸业(苏州)有限公司 | 高中学习网-高考生信息学习必备平台| 网优资讯-为循环资源、大宗商品、工业服务提供资讯与行情分析的数据服务平台 | 浴室柜-浴室镜厂家-YINAISI · 意大利设计师品牌 | 咿耐斯 |-浙江台州市丰源卫浴有限公司 | 冷轧机|两肋冷轧机|扁钢冷轧机|倒立式拉丝机|钢筋拔丝机|收线机-巩义市华瑞重工机械制造有限公司 | 高温链条油|高温润滑脂|轴承润滑脂|机器人保养用油|干膜润滑剂-东莞卓越化学 | 书法培训-高考书法艺考培训班-山东艺霖书法培训凭实力挺进央美 | 圆形振动筛_圆筛_旋振筛_三次元振动筛-河南新乡德诚生产厂家 | 翰墨AI智能写作助手官网_人工智能问答在线AI写作免费一键生成 | 动库网动库商城-体育用品专卖店:羽毛球,乒乓球拍,网球,户外装备,运动鞋,运动包,运动服饰专卖店-正品运动品网上商城动库商城网 - 动库商城 |