SpringCloud+Seata1.4+Nacos1.4+MySQL8实现分布式事务（客户端）

1. Seata执行流程

TM开启分布式事务（TM向TC注册全局事务记录)

按业务场景，编排数据库、服务等事务内资源（RM向TC汇报资源准备状态）

TM结束分布式事务，事务一阶段结束（TM 通知TC提交/回滚分布式事务）

TC汇总事务信息，决定分布式事务是提交还是回滚

TC通知所有RM提交/回滚资源，事务二阶段结束

TC (Transaction Coordinator) - 事务协调者
维护全局和分支事务的状态，驱动全局事务提交或回滚
TM (Transaction Manager) - 事务管理器
定义全局事务的范围：开始全局事务、提交或回滚全局事务
RM (Resource Manager) - 资源管理器
管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚

2. 搭建Seata1.4+Nacos1.4+MySQL8服务端，不会的可以参考这篇文章

Docker搭建Nacos1.4+Seata1.4+MySQL8分布式事务（服务端）

3. 创建三个微服务，分别为： 订单服务、账户服务、库存服务。源码GitHub自取

https://github.com/KiritsEmiya/seata

这里以订单服务为例

• application.yml

server:
  port: 2001spring:
  application:
    name: seata-order-service
  cloud:
    alibaba:
      seata:
        #自定义事务组名称需要与seata-server中的对应
        tx-service-group: fsp_tx_group
    nacos:
      discovery:
        server-addr: localhost:8848
        group: "SEATA_GROUP"
        namespace: "seata"
        username: "nacos"
        password: "nacos"
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    # 这里替换自己的mysql地址、账户和密码
    url: jdbc:mysql://localhost:3306/seata_order?characterEncoding=utf8&useSSL=false&serverTimezone=UTC
    username: root
    password: root

feign:
  hystrix:
    enabled: falselogging:
  level:
    io:
      seata: info

mybatis:
  mapperLocations: classpath:mapper/*.xml

• 到github的seata源码库弄来两个文件，file.conf、registry.conf。文件放到resource目录下
  https://github.com/seata/seata/tree/develop/script/client/conf

• file.conf修改

service {
  # 这里fsp_tx_group需要与application.yml文件中tx-service-group: fsp_tx_group保持一致（与seata-server中的对应）
  vgroupMapping.fsp_tx_group = "default"
}

• registry.conf修改

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa、custom
  type = "nacos"
  loadBalance = "RandomLoadBalance"
  loadBalanceVirtualNodes = 10

  nacos {
    application = "seata-server"
    # 这里Nacos配置替换自己的ip、group、namespace ID
    serverAddr = "127.0.0.1:8848"
    group = "SEATA_GROUP"
    namespace = "seata"
    username = "nacos"
    password = "nacos"
  }}

4. 建立三个服务的数据库

• 订单服务数据库seata_order

CREATE DATABASE seata_order;CREATE TABLE `t_order`  (
  `id` bigint(0) NOT NULL AUTO_INCREMENT,
  `user_id` bigint(0) NULL DEFAULT NULL COMMENT '用户id',
  `product_id` bigint(0) NULL DEFAULT NULL COMMENT '产品id',
  `count` int(0) NULL DEFAULT NULL COMMENT '数量',
  `money` decimal(11, 0) NULL DEFAULT NULL COMMENT '金额',
  `status` int(0) NULL DEFAULT NULL COMMENT '订单状态：0:创建中； 1：已完结',
  PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB AUTO_INCREMENT = 12 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

• 账户服务数据库seata_account

CREATE DATABASE seata_account;CREATE TABLE `t_account`  (
  `id` bigint(11) NOT NULL AUTO_INCREMENT,
  `user_id` bigint(11) DEFAULT NULL COMMENT '用户id',
  `total` decimal(10, 0) DEFAULT NULL COMMENT '总额度',
  `used` decimal(10, 0) DEFAULT NULL COMMENT '已用余额',
  `residue` decimal(10, 0) DEFAULT NULL COMMENT '可用余额',
  PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;INSERT INTO `t_account` VALUES (1, 1, 1000, 0, 1000);

• 库存服务数据库seata_storage

CREATE DATABASE seata_storage;CREATE TABLE `t_storage`  (
  `id` bigint(0) NOT NULL AUTO_INCREMENT,
  `product_id` bigint(0) NULL DEFAULT NULL COMMENT '产品id',
  `total` int(0) NULL DEFAULT NULL COMMENT '总库存',
  `used` int(0) NULL DEFAULT NULL COMMENT '已用库存',
  `residue` int(0) NULL DEFAULT NULL COMMENT '剩余库存',
  PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;INSERT INTO `t_storage` VALUES (1, 1, 100, 0, 100);

5. 分别在三个服务的数据库下建立undo_log表，用于回滚，Seata官方GitHub源码库sql脚本链接

https://github.com/seata/seata/blob/develop/script/client/at/db/mysql.sql

6. 运行三个微服务，注册进Nacos

一个seata服务端，三个seata客户端

7. 模拟分布式事务问题

• 订单服务先不开启全局事务，注释掉@GlobalTransactional

    /**
     * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
     * 简单说：下订单->扣库存->减余额->改状态
     */
    @Override    //@GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
    public void create(Order order)
    {
        log.info("----->开始新建订单");
        //1 新建订单
        orderDao.create(order);

        //2 扣减库存
        log.info("----->订单微服务开始调用库存，做扣减Count");
        storageService.decrease(order.getProductId(),order.getCount());
        log.info("----->订单微服务开始调用库存，做扣减end");

        //3 扣减账户
        log.info("----->订单微服务开始调用账户，做扣减Money");
        accountService.decrease(order.getUserId(),order.getMoney());
        log.info("----->订单微服务开始调用账户，做扣减end");

        //4 修改订单状态，从零到1,1代表已经完成
        log.info("----->修改订单状态开始");
        orderDao.update(order.getUserId(),0);
        log.info("----->修改订单状态结束");

        log.info("----->下订单结束了，O(∩_∩)O哈哈~");

    }

• 账户服务模拟超时异常

    /**
     * 扣减账户余额
     */
    @Override    public void decrease(Long userId, BigDecimal money) {
        LOGGER.info("------->account-service中扣减账户余额开始");
        //模拟超时异常，全局事务回滚
        //暂停几秒钟线程
        try { TimeUnit.SECONDS.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); }
        accountDao.decrease(userId,money);
        LOGGER.info("------->account-service中扣减账户余额结束");
    }

• Postman测试
  由于账户服务超时，postman连接异常
  

  

  url参数的意思是1号用户购买了10个1号类型的产品，花了100元

order表

account表 （由于feign的重试机制，可能第一次查看和第二次查看的结果会有所不同）

storage表

8. Navicat手动还原数据，验证分布式事务

• 订单服务开启全局事务注解@GlobalTransactional

    /**
     * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
     * 简单说：下订单->扣库存->减余额->改状态
     */
    @Override
    @GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
    public void create(Order order)

• Postman测试
  还是由于账户服务超时，postman连接异常
  

  

  开启全局事务注解时postman调试

order表

account表

storage表