mp-shadingsphere-druid-seata-tcc

准备环境

启动 Nacos server
Nacos Server 下载地址

下载最新版本Nacos Server, 本地启动Nacos

启动Seata Server
Seata Server 下载地址

下载最新版本Seata Server, 本地启动Seata

使用组件介绍

Nacos 注册中心
Nacos 配置中心
Open Feign REST 服务调用
Sentinel 限流熔断
Seata 分布式事务解决方案

项目目录介绍

mp-shadingsphere-druid-seata-tcc
- base-common 通用常量 vo
- base-starter 通用star组件
  - base-core-starter 核心依赖，集成了nacos注册配置中心，openfeign,sentinel，validator
  - base-jdbc-starter 持久化依赖，集成了mybatis-plus+druid+shardingsphere(分库分表+读写分离)
  - base-transaction-starter 分布式事务依赖，集成了seata分布式事务(主要使用tcc模式)
- demo-service-A 订单服务
- demo-service-B 产品库存服务
- doc sql数据库和yaml配置

注意: 使用seata tcc模式的时候请关闭 enable-auto-data-source-proxy: false 自动代码，否则tcc模式执行后会执行at模式

版本

<mybatis-plus.version>3.4.1</mybatis-plus.version>
<druid.version>1.1.22</druid.version>
<mysql-connector-java.version>8.0.21</mysql-connector-java.version>
<shardingsphere.version>4.0.0-RC2</shardingsphere.version>

demo

场景：
当创建订单的时候库存-1
此时两个服务为分布式事务操作

当两个服务调用完毕的时候1/0，发生异常，两个数据回滚

关键代码

@Override
@GlobalTransactional
@Transactional
public void geneOrder(UserOrder userOrder) {
    // 扣减库存
    ResponseEntity<Result> forEntity = restTemplate.getForEntity("http://localhost:8071/deduct?id=1", Result.class);
    if(forEntity.getStatusCode() != HttpStatus.OK ||
            Optional.ofNullable(forEntity.getBody()).orElse(new Result()).getCode() != 200) {
        throw new RuntimeException("扣减库存失败！");
    }
    // 生成订单
    long id = IdWorker.getId();
    userOrder.setId(id);
    userOrderTccAction.geneOrder(userOrder,id);

    int a = 1/0;
}

运行结果

订单服务

2021-04-29 15:57:35.909  INFO 9104 --- [nio-8070-exec-1] i.seata.tm.api.DefaultGlobalTransaction  : Begin new global transaction [192.168.1.188:8091:27149561796388640]
2021-04-29 15:57:39.033  INFO 9104 --- [nio-8070-exec-1] ShardingSphere-SQL                       : Rule Type: master-slave
2021-04-29 15:57:39.033  INFO 9104 --- [nio-8070-exec-1] ShardingSphere-SQL                       : SQL: INSERT INTO user_order  ( id,
order_id,
p_id )  VALUES  ( ?,
?,
? ) ::: DataSources: master
2021-04-29 15:57:39.063  INFO 9104 --- [nio-8070-exec-1] c.d.m.o.a.impl.UserOrderTccActionImpl    : geneOrder---------------------1387677438737305602
2021-04-29 15:57:39.149  INFO 9104 --- [h_RMROLE_1_1_12] i.s.c.r.p.c.RmBranchRollbackProcessor    : rm handle branch rollback process:xid=192.168.1.188:8091:27149561796388640,branchId=27149561796388658,branchType=TCC,resourceId=gene-order,applicationData={"actionContext":{"action-start-time":1619683057855,"sys::prepare":"geneOrder","sys::rollback":"cancel","sys::commit":"commit","id":1387677438737305602,"host-name":"169.254.174.68","actionName":"gene-order"}}
2021-04-29 15:57:39.157  INFO 9104 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractRMHandler            : Branch Rollbacking: 192.168.1.188:8091:27149561796388640 27149561796388658 gene-order
2021-04-29 15:57:39.174  INFO 9104 --- [h_RMROLE_1_1_12] c.d.m.o.a.impl.UserOrderTccActionImpl    : cancel---------------------1387677438737305602
2021-04-29 15:57:39.191  INFO 9104 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : Rule Type: master-slave
2021-04-29 15:57:39.191  INFO 9104 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : SQL: DELETE FROM user_order WHERE id=? ::: DataSources: master
2021-04-29 15:57:39.197  INFO 9104 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractResourceManager      : TCC resource rollback result : true, xid: 192.168.1.188:8091:27149561796388640, branchId: 27149561796388658, resourceId: gene-order
2021-04-29 15:57:39.199  INFO 9104 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractRMHandler            : Branch Rollbacked result: PhaseTwo_Rollbacked
2021-04-29 15:57:39.314  INFO 9104 --- [nio-8070-exec-1] i.seata.tm.api.DefaultGlobalTransaction  : [192.168.1.188:8091:27149561796388640] rollback status: Rollbacked
2021-04-29 15:57:39.338 ERROR 9104 --- [nio-8070-exec-1] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.ArithmeticException: / by zero] with root cause

java.lang.ArithmeticException: / by zero

库存服务

2021-04-29 15:57:39.221  INFO 4656 --- [h_RMROLE_1_1_12] i.s.c.r.p.c.RmBranchRollbackProcessor    : rm handle branch rollback process:xid=192.168.1.188:8091:27149561796388640,branchId=27149561796388642,branchType=TCC,resourceId=order-decuct,applicationData={"actionContext":{"action-start-time":1619683056387,"sys::prepare":"deduct","sys::rollback":"cancel","sys::commit":"commit","id":1,"host-name":"169.254.174.68","actionName":"order-decuct"}}
2021-04-29 15:57:39.229  INFO 4656 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractRMHandler            : Branch Rollbacking: 192.168.1.188:8091:27149561796388640 27149561796388642 order-decuct
2021-04-29 15:57:39.251  INFO 4656 --- [h_RMROLE_1_1_12] c.d.m.p.a.impl.CompanyProductActionImpl  : cancel---------------------1
2021-04-29 15:57:39.252  INFO 4656 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : Rule Type: master-slave
2021-04-29 15:57:39.252  INFO 4656 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : SQL: SELECT  id,product_name,account  FROM company_product 
 
 WHERE (id = ?) ::: DataSources: slave02
2021-04-29 15:57:39.257  INFO 4656 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : Rule Type: master-slave
2021-04-29 15:57:39.257  INFO 4656 --- [h_RMROLE_1_1_12] ShardingSphere-SQL                       : SQL: UPDATE company_product  SET product_name=?,
account=?  WHERE id=? ::: DataSources: master
2021-04-29 15:57:39.264  INFO 4656 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractResourceManager      : TCC resource rollback result : true, xid: 192.168.1.188:8091:27149561796388640, branchId: 27149561796388642, resourceId: order-decuct
2021-04-29 15:57:39.266  INFO 4656 --- [h_RMROLE_1_1_12] io.seata.rm.AbstractRMHandler            : Branch Rollbacked result: PhaseTwo_Rollbacked

感谢seata团队的帮助。