分布式事务解决方案:@Transactional注解+log记录操作实现
程序员文章站
2022-07-12 17:01:54
...
说明:
在分布式中如订单,账户,库存系统中,数据库独立,这时需要分布式事务解决。
框架:
SpringBoot+mybatis+dubbo+zk+mysql
数据库 | 表名 |
---|---|
transactiondb(log) | transaction-log |
account(账户) | account |
order(订单) | order |
goods(商品) | goods |
业务场景
扣款(account)->创建订单(order)->减少库存(goods)
操作简介:
1.采用log日志(transaction-log)来记录业务系统(account,order,goods)操作成功或者失败;
2.业务系统完成操作之后检查日志系统失败个数,存在失败进行回滚;
具体实现:
- 1.生成事务日志表(centre_no,count,prepare_count,failed_count)
TransactionLog transactionLog = new TransactionLog(); transactionLog.setCentreNo(no);//记录事务整天操作关联的日志表 transactionLog.setCount(3);//此事务关联几个中心操作,此业务场景3 transactionLog.setPrepareCount(3);//未处理的业务数,初始时等于count transactionLog.setFailedCount(0)//失败次数(默认0) transactionLogService.addTransactionLog(transactionLog);
- 2 .业务系统操作(账户,订单,库存)
操作简介:dubbo+zk实现rpc远程服务调用,分四部分: 注:--修改失败次数:(prepare_count=0,failed_count=1) --减少准备操作次数:(prepare_count-1) --也正是因为2.3需要结合其他业务减少准备操作次数,所以业务操作方法(或服务)需要使用异步 ( <dubbo:method name="addOrder" async="true" />) 2.1.校验回滚(校验数据,如库存,账户金额) 不满足:修改失败次数,并抛异常回滚 2.2.业务系统操作处理(如扣款,创建订单,扣库存,捕获异常) 2.2.1失败(捕获异常): 修改失败次数,并抛异常回滚 2.2.2成功:修改失败次数 2.3.查询失败次数(当1,2任意步骤失败,都可以修改失败次数为1) 实现了两种返回:(成功:0,失败:1/抛异常) 实现: while循环,跳出循环条件: 2.3.1 失败:failed_count>0 (return:1/抛异常) 2.3.2 成功:prepare_count<=0(业务系统操作2步骤全部完成) 并且 failed_count==0 2.4.处理查询失败次数返回值 成功:你懂得 失败:1->判断返回值如果等于1,抛异常 捕获异常->catch块中,抛异常(总而言之就是抛异常) ps:忘说了异常为:RuntimeException
项目已经放在github仓库欢迎大家前往下载,也希望能够一起探讨,提出不足与改进。github仓库地址。