PHP分布式事务-两段式提交 2PC(一)

内容简介：PHP分布式事务-两段式提交 2PC(一)

事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元

事务应该具有4个属性：****原子性、一致性、隔离性、持续性、原子性（atomicity）     一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不。 原子性（atomicity）     一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。 一致性（consistency）     事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。 隔离性（isolation）     一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。 持久性（durability）     持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

分布式事务：分布式事务的参与者、资源管理器、事务管理器等位于不用的节点上，这些不同的节点相互协作共同完成一个具有逻辑完整性的事务。

mysql从5.0开始支持XA DataSource。Connector/J 版本要使用5.0版本，5.0以下的不支持。 XA协议由Tuxedo首先提出的，并交给X/Open组织，作为资源管理器（数据库）与事务管理器的接口标准。目前，Oracle、Informix、DB2和Sybase等各大数据库厂家都提供对XA的支持。XA协议采用两阶段提交方式来管理分布式事务。XA接口提供资源管理器与事务管理器之间进行通信的标准接口。XA协议包括两套函数，以xa_开头的及以ax_开头的。

以下的函数使事务管理器可以对资源管理器进行的操作： xa_open,xa_close：建立和关闭与资源管理器的连接。 xa_start,xa_end：开始和结束一个本地事务。 xa_prepare,xa_commit,xa_rollback：预提交、提交和回滚一个本地事务。 xa_recover：回滚一个已进行预提交的事务。 ax_开头的函数使资源管理器可以动态地在事务管理器中进行注册，并可以对XID(TRANSACTION IDS)进行操作。 ax_reg,ax_unreg；允许一个资源管理器在一个TMS(TRANSACTION MANAGER SERVER)中动态注册或撤消注册。

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

PHP简单2PC示例：

数据库

order数据库 CREATE TABLE `order` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `order_no` varchar(32) DEFAULT NULL, `goods_id` int(11) DEFAULT NULL, `goods_name` varchar(255) DEFAULT NULL, `goods_num` int(11) DEFAULT NULL, `create_time` int(10) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=20 DEFAULT CHARSET=utf8mb4 goods数据库 CREATE TABLE `goods` ( `id` int(10) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) DEFAULT NULL, `num` int(11) unsigned DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4

PHP 代码

/** * 分布式事务测试 */ //order $dns_order = new PDO('mysql:host=10.211.55.100;dbname=order', 'orders', '123456aA!'); //goods $dns_goods = new PDO('mysql:host=10.211.55.101;dbname=goods', 'goods', '123456aA!'); var_dump($dns_order); echo ' '; var_dump($dns_goods); echo ' '; $_grid = uniqid(""); $_o = false; $_g = false; //1.准备事务 $dns_order->query('XA START /''.$_grid.'/''); $dns_goods->query('XA START /''.$_grid.'/''); try { //2.更新order表 $sql = 'INSERT INTO `order` (order_no, goods_id, goods_name, goods_num, create_time) VALUES (/''.time().'/', 1, /'test/', 1, /''.time().'/')'; $resultOrder = $dns_order->query($sql); if ($resultOrder === false) { echo 'order更新失败'; } else { if ($resultOrder->rowCount() > 0) { //4.成功通知准备提交 var_dump($dns_order->query('XA END /''.$_grid.'/'')); var_dump($dns_order->query('XA PREPARE /''.$_grid.'/'')); var_dump($resultOrder->rowCount()); $_o = true; } } if($_o == true) { echo ' '; //3.更新goods表 $sql = "UPDATE `goods` SET `num` = `num` - 1 WHERE `id` = 2"; $resultGoods = $dns_goods->query($sql); if ($resultGoods === false) { echo 'goods更新失败'; } else { if ($resultGoods->rowCount() > 0) { //4.成功通知准备提交 var_dump($dns_goods->query('XA END /''.$_grid.'/'')); var_dump($dns_goods->query('XA PREPARE /''.$_grid.'/'')); var_dump($resultGoods->rowCount()); $_g = true; } else { echo 'goods未更新记录'; } } } echo ' '.'-----状态------'; var_dump($_grid); var_dump($_o); var_dump($_g); echo '-----状态------'; if ($_o == true && $_g == true) { //5.提交SQL var_dump($dns_order->query('XA COMMIT /''.$_grid.'/'')); var_dump($dns_goods->query('XA COMMIT /''.$_grid.'/'')); echo ' '.'成功!!!!!!'; } else { //4.失败回滚 echo ' '.'失败回滚'; $dns_order->query('XA ROLLBACK /''.$_grid.'/''); $dns_goods->query('XA ROLLBACK /''.$_grid.'/''); } } catch (Exception $e) { //4.失败回滚 $dns_order->query('XA ROLLBACK /''.$_grid.'/''); $dns_goods->query('XA ROLLBACK /''.$_grid.'/''); throw new Exception('执行失败'); }

代码下载：GitHub – jingyanlei/PHP-2PC https://github.com/jingyanlei/PHP-2PC

下一篇讲解下结合hprose实现分布式事务

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

• 分布式系统 - 两段式提交（2PC）和三段式提交（3PC）
• 领域驱动实战思考（三）：DDD的分段式协作设计
• 面试官：为什么Mysql innoDB是两段式提交？
• 分布式锁原理——redis分布式锁，zookeeper分布式锁
• 漫谈分布式系统（十）：初探分布式事务
• 漫谈分布式系统（十）：初探分布式事务

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。