RuoYi-Cloud 进阶篇_04（ Seata 高可用集群 AT模式需求实战）

柔情只为你懂 2022-09-10 04:23 559阅读 0赞

需求背景：  
模拟下单场景：首先去在自己的本地创建一条下单记录，同时，还要去调用库存服务，执行减库存操作。

这里演示一个客户下订单的流程服务来为小伙伴们进一步了解一下分布式事务到底如何使用?  
首先，我会把系统模块中，开发订单需求；然后，再创建一个库存的子模块，最后，客户端发起订单请求，系统模块接收到请求后，在本地数据库中创建一个。

### 文章目录 ###

*   *   *   *   *  一、数据库部分
                 *   *  1. 订单表创建
                     *  2. 库存数据库创建
                     *  3. 库存表结构初始化
                     *  4. 添加依赖
                 *  二、订单微服务代码部分
                 *   *  2.1. 创建实体类
                     *  2.2. 创建接口类
                     *  2.3. 调整控制层逻辑
                     *  2.4. 修改配置文件
                 *  三、库存微服务代码部分
                 *   *  3.1. 创建实体类
                     *  3.2. 接口库存Dao
                     *  3.3. 容错代码
                     *  3.4. 控制层逻辑调整
                     *  3.5. 配置文件修改
                     *  3.6. 初始化库存
                     *  3.7. 容错代码简述
                 *  四、测试验证
                 *   *  4.1. 启动服务
                     *  4.2. 发起第一轮请求
                     *  4.3. 抛出异常
                     *  4.4. 异常信息监控
                     *  4.5. 流程梳理
                     *  4.6. 数据库验证
                     *  4.7. 发起第二轮请求
                     *  4.8. 发起第三轮请求
                     *  4.9. 数据库数据验证
                     *  4.10. 发起第四轮请求
                     *  4.11. 数据库验证

##### 一、数据库部分 #####

###### 1. 订单表创建 ######

在系统模块连接的，ry-cloud数据库中创建一张订单表 和 AT模式seata需要用到的undolog表，其中undo\_log表，在前面已经创建过了

create table order_tb
    (
    	id int auto_increment
    		primary key,
    	user_id int not null,
    	product_id int not null
    );
    
    CREATE TABLE `undo_log` (
      `branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',
      `xid` varchar(100) NOT NULL COMMENT 'global transaction id',
      `context` varchar(128) NOT NULL COMMENT 'undo_log context,such as serialization',
      `rollback_info` longblob NOT NULL COMMENT 'rollback info',
      `log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',
      `log_created` datetime(6) NOT NULL COMMENT 'create datetime',
      `log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',
      UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AT transaction mode undo table';

###### 2. 库存数据库创建 ######

创建`ry-stock`数据库  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZ2JsZnk_size_20_color_FFFFFF_t_70_g_se_x_16]

###### 3. 库存表结构初始化 ######

```bash create table stock ( id int auto_increment primary key, count int not null, product_id int not null ); CREATE TABLE `undo_log` ( `branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id', `xid` varchar(100) NOT NULL COMMENT 'global transaction id', `context` varchar(128) NOT NULL COMMENT 'undo_log context,such as serialization', `rollback_info` longblob NOT NULL COMMENT 'rollback info', `log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status', `log_created` datetime(6) NOT NULL COMMENT 'create datetime', `log_modified` datetime(6) NOT NULL COMMENT 'modify datetime', UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AT transaction mode undo table';

###### 4. 添加依赖 ######

系统模块

<dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>

##### 二、订单微服务代码部分 #####

我们对现在的order-serv订单服务基础上调整

###### 2.1. 创建实体类 ######

###### 2.2. 创建接口类 ######

###### 2.3. 调整控制层逻辑 ######

###### 2.4. 修改配置文件 ######

##### 三、库存微服务代码部分 #####

###### 3.1. 创建实体类 ######

###### 3.2. 接口库存Dao ######

###### 3.3. 容错代码 ######

###### 3.4. 控制层逻辑调整 ######

###### 3.5. 配置文件修改 ######

###### 3.6. 初始化库存 ######

###### 3.7. 容错代码简述 ######

##### 四、测试验证 #####

###### 4.1. 启动服务 ######

###### 4.2. 发起第一轮请求 ######

###### 4.3. 抛出异常 ######

###### 4.4. 异常信息监控 ######

###### 4.5. 流程梳理 ######

###### 4.6. 数据库验证 ######

###### 4.7. 发起第二轮请求 ######

###### 4.8. 发起第三轮请求 ######

###### 4.9. 数据库数据验证 ######

###### 4.10. 发起第四轮请求 ######

###### 4.11. 数据库验证 ######

改之前配置

# spring配置
    spring: 
      redis:
        host: localhost
        port: 6379
        password: 123456
      datasource:
        druid:
          stat-view-servlet:
            enabled: true
            loginUsername: admin
            loginPassword: 123456
        dynamic:
          druid:
            initial-size: 5
            min-idle: 5
            maxActive: 20
            maxWait: 60000
            timeBetweenEvictionRunsMillis: 60000
            minEvictableIdleTimeMillis: 300000
            validationQuery: SELECT 1 FROM DUAL
            testWhileIdle: true
            testOnBorrow: false
            testOnReturn: false
            poolPreparedStatements: true
            maxPoolPreparedStatementPerConnectionSize: 20
            filters: stat,slf4j
            connectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000
          datasource:
              # 主库数据源
              master:
                driver-class-name: com.mysql.cj.jdbc.Driver
                url: jdbc:mysql://localhost:3306/ry-cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                username: root
                password: 123456
              # 从库数据源
              # slave:
                # username: 
                # password: 
                # url: 
                # driver-class-name: 
          # seata: true # 开启seata代理，开启后默认每个数据源都代理，如果某个不需要代理可单独关闭
    
    # seata配置
    seata:
      # 默认关闭，如需启用spring.datasource.dynami.seata需要同时开启
      enabled: false
      # Seata 应用编号，默认为 ${spring.application.name}
      application-id: ${spring.application.name}
      # Seata 事务组编号，用于 TC 集群名
      tx-service-group: ${spring.application.name}-group
      # 关闭自动代理
      enable-auto-data-source-proxy: false
      # 服务配置项
      service:
        # 虚拟组和分组的映射
        vgroup-mapping:
          ruoyi-system-group: default
      config:
        type: nacos
        nacos:
          serverAddr: 127.0.0.1:8848
          group: SEATA_GROUP
          namespace:
      registry:
        type: nacos
        nacos:
          application: seata-server
          server-addr: 127.0.0.1:8848
          namespace:
    
    # mybatis配置
    mybatis:
        # 搜索指定包别名
        typeAliasesPackage: com.ruoyi.system
        # 配置mapper的扫描，找到所有的mapper.xml映射文件
        mapperLocations: classpath:mapper/**/*.xml
    
    # swagger配置
    swagger:
      title: 系统模块接口文档
      license: Powered By ruoyi
      licenseUrl: https://ruoyi.vip

调整之后配置

# spring配置
    spring: 
      redis:
        host: localhost
        port: 6379
        password: 123456
      datasource:
        druid:
          stat-view-servlet:
            enabled: true
            loginUsername: admin
            loginPassword: 123456
        dynamic:
          druid:
            initial-size: 5
            min-idle: 5
            maxActive: 20
            maxWait: 60000
            timeBetweenEvictionRunsMillis: 60000
            minEvictableIdleTimeMillis: 300000
            validationQuery: SELECT 1 FROM DUAL
            testWhileIdle: true
            testOnBorrow: false
            testOnReturn: false
            poolPreparedStatements: true
            maxPoolPreparedStatementPerConnectionSize: 20
            filters: stat,slf4j
            connectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000
          datasource:
              # 主库数据源
              master:
                driver-class-name: com.mysql.cj.jdbc.Driver
                url: jdbc:mysql://localhost:3306/ry-cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                username: root
                password: 123456
              # 从库数据源
              # slave:
                # username: 
                # password: 
                # url: 
                # driver-class-name: 
          seata: true    # 开启seata代理，开启后默认每个数据源都代理，如果某个不需要代理可单独关闭
    
    # seata配置
    seata:
      # 默认关闭，如需启用spring.datasource.dynami.seata需要同时开启
      enabled: true
      # Seata 应用编号，默认为 ${spring.application.name}
      application-id: ${spring.application.name}
      # Seata 事务组编号，用于 TC 集群名
      tx-service-group: order-service
      # 关闭自动代理
      enable-auto-data-source-proxy: false
      # 服务配置项
      service:
        # 虚拟组和分组的映射
        vgroup-mapping:
          ruoyi-system-group: default
      config:
        type: nacos
        nacos:
          serverAddr: 127.0.0.1:8848
          group: SEATA_GROUP
          namespace: public
          userName: "nacos"
          password: "nacos"
      registry:
        type: nacos
        nacos:
          application: seata-server
          server-addr: 127.0.0.1:8848
          group: SEATA_GROUP
          namespace: public
          userName: "nacos"
          password: "nacos"
    
    # mybatis配置
    mybatis:
        # 搜索指定包别名
        typeAliasesPackage: com.ruoyi.system
        # 配置mapper的扫描，找到所有的mapper.xml映射文件
        mapperLocations: classpath:mapper/**/*.xml
    
    # swagger配置
    swagger:
      title: 系统模块接口文档
      license: Powered By ruoyi
      licenseUrl: https://ruoyi.vip

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAZ2JsZnk_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/01c0070d3cd44e619d2d0af2a60c5145.png