Seata入门系列【18】Seata集成Mybatis-Plus多数据源

浅浅的花香味﹌ 2024-02-20 11:38 78阅读 0赞

## 1 前言 ##

在使用单个服务，多数据源时，也存在分布式事务问题。

当单体系统需要访问多个数据库（实例）时就会产生分布式事务。 比如：用户信 息和订单信息分别在两个MySQL实例存储，用户管理系统删除用户信息，需要分别删除用户信息及用户的订单信 息，由于数据分布在不同的数据实例，需要通过不同的数据库链接去操作数据，此时产生分布式事务。 简言之：跨数据库实例产生分布式事务。

![在这里插入图片描述][4def951920884249bcb08a1b9cf703a7.png]

## 2 问题场景 ##

参考此文档搭建一个多数据源项目Mybatis-Plus入门系列(19) -多数据源使用详解。

在插入订单数据时，模拟一个异常：

@Override
        @DS("db_order")
        @Transactional
        public void insertOrder() {
        
            // 插入订单
            OrderTbl orderTbl = new OrderTbl();
            orderTbl.setUserId("12");
            orderTbl.setCommodityCode("IPHONE 13");
            orderTbl.setCount(1);
            orderTblMapper.insert(orderTbl);
            int i = 5 / 0;
        }

当进行业务操作时，订单发生异常 ，进行了回滚操作，因为在不同的数据库实例中，余额却扣除成功，此时发现数据不一致问题。

## 3 使用Seata 解决多数据源事务问题 ##

### 3.1 集成Nacos Seata ###

参考该系列，给当前服务添加Nacos Seata 相关依赖，并启动Nacos Seata 。

### 3.2 多数据源集成Seata ###

多数据源集成Seata 时，主要是需要修改一下几个配置即可。

多数据源中，开启分布式事务，设置事务模式：

datasource:
        # 多数据源
        dynamic:
          # 省略其他 
          # 开启分布式事务
          seata: true
          # 事务模式 为AT
          seata-mode: AT

seata 中，关闭数据源自动代理

seata:
      # 是否开启spring-boot自动装配，默认true，包括数据源的自动代理以及GlobalTransactionScanner初始化
      enabled: true
      # 是否开启数据源自动代理，默认开启
      enable-auto-data-source-proxy: false

### 3.3 测试 ###

添加@GlobalTransactional注解。

@GlobalTransactional
        @GetMapping("/test")
        public Object test() throws InterruptedException {
        
            accountTblService.reduceMoney();
            orderTblService.insertOrder();
            return "执行完毕！";
        }

测试发现，异常时，余额和订单服务都进行了回滚，集成成功。

![在这里插入图片描述][eca29f10726342f68912213fc3e649da.jpeg]

[4def951920884249bcb08a1b9cf703a7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/c08c68cdb2104de6bbbdda7f02608734.png
[eca29f10726342f68912213fc3e649da.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/f1e76cad7e7e42a4a463013881e5aa8e.png