阅读 16 SEO

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: 2001

spring:
  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: false

logging:
  level:
    io:
      seata: info

mybatis:
  mapperLocations: classpath:mapper/*.xml
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;
id user_id product_id count money status
(N/A) (N/A) (N/A) (N/A) (N/A) (N/A)
  • 账户服务数据库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);
id user_id total used residue
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);
id product_id total used residue
1 1 1000 0 1000

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

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

branch_id xid context rollback_info log_status log_created log_modified
(N/A) (N/A) (N/A) (N/A) (N/A) (N/A) (N/A)

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表

id user_id product_id count money status
1 1 1 10 100 0

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

id user_id total used residue
1 1 1000 100 900

storage表

id product_id total used residue
1 1 100 10 90

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

  • 订单服务开启全局事务注解@GlobalTransactional
    /**
     * 创建订单->调用库存服务扣减库存->调用账户服务扣减账户余额->修改订单状态
     * 简单说:下订单->扣库存->减余额->改状态
     */
    @Override
    @GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class)
    public void create(Order order)
  • Postman测试
    还是由于账户服务超时,postman连接异常
    开启全局事务注解时postman调试

order表

id user_id product_id count money status
(N/A) (N/A) (N/A) (N/A) (N/A) (N/A)

account表

id user_id total used residue
1 1 1000 0 1000

storage表

id product_id total used residue
1 1 100 0 100

作者:Kirits

原文链接:https://www.jianshu.com/p/cbe5c163318a

文章分类
后端
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 gxwowoo@163.com 举报,一经查实,本站将立刻删除。
相关推荐