目录
- 概述
- 学习目标
- 普通事务
- 分布式锁使用场景-微服务
- 分布式事务
- XA
- php实战XA
- php7进阶到架构师相关阅读
概述
这是关于php进阶到架构之 PHP核心技术与实践 系列学习课程：PHP实战mysql分布式锁XA
学习目标 ：
了解什么是分布式锁XA，通过php实战实例了解XA使用场景
事务
某些业务要求，一系列操作必须全部执行，而不能仅执行一部分。例如，一个转账操作：
-- 从id=1的账户给id=2的账户转账100元
-- 第一步：将id=1的A账户余额减去100
UPDATE accounts SET balance = balance - 100 WHERE id = 1;
-- 第二步：将id=2的B账户余额加上100
UPDATE accounts SET balance = balance + 100 WHERE id = 2;
这两条SQL语句必须全部执行，或者，由于某些原因，如果第一条语句成功，第二条语句失败，就必须全部撤销。
这种把多条语句作为一个整体进行操作的功能，被称为数据库事务。数据库事务可以确保该事务范围内的所有操作都可以全部成功或者全部失败。如果事务失败，那么效果就和没有执行这些SQL一样，不会对数据库数据有任何改动。
微服务
如果一个事务涉及的所有操作能够放在一个服务内部，那么使用各门语言里事务相关的库，可以轻松的实现多个操作作为整体的事务操作。
但是有些服务，例如生成订单涉及做很多操作，包括库存、优惠券、赠送、账户余额等。当系统复杂程度增加时，想要把所有这些操作放到一个服务内实现，会导致耦合度太高，维护成本非常高。
针对复杂的系统，当前流行的微服务架构是非常好的解决方案，该架构能够把复杂系统进行拆分，拆分后形成了大量微服务，独立开发，独立维护。
虽然服务拆分了，但是订单本身的逻辑需要多个操作作为一个整体，要么全部成功，要么全部失败，这就带来了新的挑战。如何把散落在各个微服务中的本地事务，组成一个大的事务，保证他们作为一个整体，这就是分布式事务需要解决的问题。
分布式事务
分布式事务简单的说，就是一次大的操作由不同的小操作组成，这些小的操作分布在不同的服务器上，且属于不同的应用，分布式事务需要保证这些小操作要么全部成功，要么全部失败。本质上来说，分布式事务就是为了保证不同数据库的数据一致性。
XA
XA是由X/Open组织提出的分布式事务的规范，XA规范主要定义了(全局)事务管理器(TM)和(局部)资源管理器(RM)之间的接口。本地的数据库如mysql在XA中扮演的是RM角色
XA一共分为两阶段：
第一阶段（prepare）：
即所有的参与者RM准备执行事务并锁住需要的资源。参与者ready时，向TM报告已准备就绪。
第二阶段 (commit/rollback)：
当事务管理者(TM)确认所有参与者(RM)都ready后，向所有参与者发送commit命令。
目前主流的数据库基本都支持XA事务，包括mysql、oracle、sqlserver、postgre
我们看看本地数据库是如何支持XA的：
第一阶段 准备
XA start '4fPqCNTYeSG';
UPDATE `user_account` SET `balance`=balance + 30,`update_time`='2021-06-09 11:50:42.438' WHERE user_id = '1';
XA end '4fPqCNTYeSG';
XA prepare '4fPqCNTYeSG';
当所有的参与者完成了prepare，就进入第二阶段 提交
xa commit '4fPqCNTYeSG'
php实战XA
public function testAction()
{
$goodsId = 1;
$goodsName = "华为手机P20";
$num = 1;
//创建订单
$orderResult = $this->createOrder($goodsId, $goodsName, $num);
//扣减库存
$deductionResult = $this->deduction($goodsId, $num);
if ($orderResult['status'] == "success" && $deductionResult['status'] == "success") {
//订单数据库commit
$this->commitOrderDb($orderResult['XA']);
//库存数据库commit
$this->commitStockDb($deductionResult['XA']);
} else {
//只要有一个prepare失败，就全部回滚
//订单数据库回滚
$this->rollbackOrderDb($orderResult['XA']);
//库存数据库回滚
$this->rollbackStockDb($deductionResult['XA']);
}
}
public function createOrder($goodsId, $goodsName, $num)
{
$XA = uniqid("");
$this->orderDb->query("XA START '$XA'");
try {
$data = array();
$data['order_id'] = date("YmdHis").rand(10000,99999);
$data['goods_id'] = $goodsId;
$data['goods_name'] = $goodsName;
$data['goods_num'] = $num;
$this->orderDb->insert("order", $data);
$rs = $this->orderDb->lastInsertId();
if ($rs) {
$_rs = true;
} else {
$_rs = false;
}
} catch (Exception $e) {
$_rs = false;
}
$this->orderDb->query("XA END '$XA'");
if ($_rs) {
//1阶段提交
$this->orderDb->query("XA PREPARE '$XA'");
return array("status" => "success", "XA" => $XA);
} else {
return array("status" => "fail", "XA" => $XA);
}
}
public function deduction($id)
{
$XA = uniqid("");
$this->stockDb->query("XA START '$XA'");
try {
$sql = "select goods_num from goods where id = '$id' and goods_num>0";
$rs = $this->stockDb->fetchRow($sql);
if (!empty($rs)) {
$sql = "update goods set goods_num = goods_num-1 where id = '$id'";
$rd = $this->stockDb->query($sql);
if ($rd) {
$updateRs = true;
} else {
$updateRs = false;
}
} catch (Exception $e) {
$updateRs = false;;
}
$this->stockDb->query("XA END '$XA'");
if ($updateRs) {
$this->stockDb->query("XA PREPARE '$XA'");
return array("status" => "success", "XA" => $XA);
} else {
return array("status" => "fail", "XA" => $XA);
}
}
//提交事务
public function commitOrderDb($xa)
{
return $this->orderDb->query("XA COMMIT '$xa'");
}
//回滚事务
public function rollbackOrderDb($xa)
{
return $this->orderDb->query("XA ROLLBACK '$xa'");
}
//提交事务
public function commitStockDb($xa)
{
return $this->stockDb->query("XA COMMIT '$xa'");
}
//回滚事务
public function rollbackStockDb($xa)
{
return $this->stockDb->query("XA ROLLBACK '$xa'");
}
