Laravel5.5+基于reset机制实现分布式事务，了解一下laravel-reset-transaction

Laravel  /  管理员 发布于 3年前   1166

之前想了解一下这方面功能包，在git上看到了laravel-reset-transaction包，感觉很好，

所以记录一下；后面有项目在实践一下

准备软件依赖包

laravel：5.5 - 8.0之间
composer：2.0

安装composer包 - laravel-reset-transaction

#必须使用composer2版本
composer require windawake/laravel-reset-transaction dev-master

首先创建 控制器/模型/数据库表

ResetProductController.php 控制器，
创建 ResetProductModel.php 模型，
创建 reset_transaction 和 reset_product 两张数据库表。

这些操作只需要执行下面命令全部完成

php artisan resetTransact:create-examples  

phpunit.xml 增加 testsuite Transaction

<?xml version="1.0" encoding="UTF-8"?>
<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="./vendor/phpunit/phpunit/phpunit.xsd"
         bootstrap="vendor/autoload.php"
         colors="true">
    <testsuites>
        ......
        <testsuite name="Transaction">
            <directory>./vendor/windawake/laravel-reset-transaction/tests</directory>
        </testsuite>
    </testsuites>
    ......
</phpunit>

然后启动web服务器

php artisan serve --host=0.0.0.0 --port=8000

最后运行测试命令 

./vendor/bin/phpunit --testsuite=Transaction

运行结果如下所示，5 个例子测试通过。

oot@DESKTOP-VQOELJ5:/web/linux/php/laravel/laravel62# ./vendor/bin/phpunit --testsuite=Transaction
PHPUnit 8.5.20 by Sebastian Bergmann and contributors.
.....                                                               5 / 5 (100%)
Time: 219 ms, Memory: 22.00 MB
OK (5 tests, 5 assertions)

功能特性：

开箱即用，不需要重构原有项目的代码，与 mysql 事务写法一致，简单易用。

遵守两段提交协议，属于强一致性事务，高并发下，支持读已提交的事务隔离级别。

由于事务拆分成多个，变成了几个小事务，压测发现比 mysql 普通事务更少发生死锁。

支持事务嵌套，与 savepoint 一致效果。

支持避免不同业务代码并发造成脏数据的问题。

默认支持 http 协议的服务化接口，想要支持其它协议则需要重写中间件。

解决了哪些并发场景：

1.一个待发货订单，用户同时操作发货和取消订单，只有一个成功
2.积分换取优惠券，只要出现积分不够扣减或者优惠券的库存不够扣减，就会全部失败。

原理解析

Reset Transaction，中文名为重置型分布式事务，又命名为 RT 模式，

与 seata AT 模式都是属于二段提交。

看过《明日边缘》电影就会知道，存档和读档的操作。

这个分布式事务组件仿造《明日边缘》电影的原理，

reset 是重置的意思，即每次请求基础服务一开始时读档，

然后继续后面的操作，

结束时所有操作全部回滚并且存档，

最后一步 commit 把存档全部执行成功。

整个过程是遵守两段提交协议，先 prepare，最后 commit。

以用户 A 用招行卡转账 100 元给用户 B 招行账号的场景为例子，画了以下流程图。

右图开启 reset 分布式事务后，

比左图多了请求 4。

请求 4 所做的事情，都是请求 1-3 之前做过的东西，又回来原点重新再来，

最终提交事务，结束这转账的流程。

如何使用

以 vendor/windawake/laravel-reset-transaction/tests/TransactionTest.php 文件为例子

<?php
namespace Tests\Feature;
use Tests\TestCase;
use Illuminate\Support\Facades\DB;
class TransactionTest extends TestCase
{
    public function testCreateWithCommit()
    {
        $num = rand(1, 10000);
        $productName = 'php ' . $num;
        $data = [
            'store_id' => 1,
            'product_name' => $productName,
        ];
        // 开启分布式事务，其实是生成全局唯一id
        $transactId = $this->beginDistributedTransaction();
        $header = [
           在header 'transact_id' => $transactId,
        ];
        // 分布式事务内，请求都需要在request header带上transact_id
        $response = $this->post('api/resetProduct', $data, $header);
        $product = $response->json();
        // 分布式事务提交，也是接口请求，把之前的存档记录全部处理
        $this->commitDistributedTransaction($transactId);
        $response = $this->get('/api/resetProduct/' . $product['pid']);
        $product = $response->json();
        $this->assertEquals($productName, $product['product_name']);
    }
    private function beginDistributedTransaction()
    {
        return session_create_id();
    }
    private function commitDistributedTransaction($transactId)
    {
        $response = $this->post('/api/resetTransaction/commit', [], ['transact_id' => $transactId]);
        return $response->getStatusCode();
    }
    private function rollbackDistributedTransaction($transactId)
    {
        $response = $this->post('/api/resetTransaction/rollback', [], ['transact_id' => $transactId]);
        return $response->getStatusCode();
    }
}

git地址：实现laravel、hyperf

https://github.com/windawake/laravel-reset-transaction
https://github.com/windawake/hyperf-reset-transaction