
快速预览
安装laravel5.5 - laravel8之间的版本,然后安装快速服务化的package
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>
最后运行测试命令 ./vendor/bin/PHPunit --testsuite=Transaction
运行结果如下所示,5个例子测试通过。
oot@DESKtop-VQOELJ5:/web/linux/PHP/laravel/laravel62# ./vendor/bin/PHPunit --testsuite=TransactionPHPUnit 8.5.20 by Sebastian Bergmann and contributors...... 5 / 5 (100%)Time: 219 ms, Memory: 22.00 MBOK (5 tests, 5 assertions)功能特性
开箱即用,不需要重构原有项目的代码,与MysqL事务写法一致,简单易用。
支持http协议的服务化接口,想要支持其它协议则需要重写中间件。
支持读已提交,可重复读,与MysqL的事务隔离级别同步。
原理解析看过《明日边缘》电影就会知道,存档和读档的 *** 作。这个分布式事务组件仿造《明日边缘》电影的原理,每次请求基础服务一开始时读档,然后继续后面的 *** 作,结束时所有 *** 作全部回滚并且存档,最后commit把存档全部执行成功。整个过程是遵守两段提交协议,先prepare,最后commit。
如何使用以vendor/windawake/laravel-reset-transaction/tests/TransactionTest.PHP文件为例子
<?PHPnamespace 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(); }}个人笔记我之前写了laravel快速服务化包,但是它没有解决数据一致性的问题。尝试用XA,但是XA只能解决单机多个数据库,没法解决多台机器服务化的问题。然后我又尝试去研究tcc和seata,但是看完后一脸懵逼,不知所措。无奈被逼上绝路,没办法了只能自创分布式事务解决方案。一直以来,我一直以为单单只用MysqL是没法解决分布式事务的问题,现在终于明白,还是有办法滴! 总结
以上是内存溢出为你收集整理的Laravel进阶学习之基于reset实现分布式事务全部内容,希望文章能够帮你解决Laravel进阶学习之基于reset实现分布式事务所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)