• Spring Cloud Alibaba Seata 实现分布式事物

    Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案

    Seata 官网：https://seata.io/zh-cn/

    Spring Cloud Alibaba 官网：https://sca.aliyun.com/zh-cn/

    版本说明

    SpringBoot 版本 2.6.5

    SpringCloud 版本 2021.0.1

    SpringCloudAlibaba 版本 2021.0.1.0

    读者可以先看笔者前面写的文章《Spring Cloud Gateway 使用 Redis 限流使用教程》，里面有创建项目的详细版本说明，这篇seata的文章是在 gateway 限流的项目基础上创建的

    本文详细说明

    数据库服务器版本 mysql 8.0.25

    mybatis plus 版本 3.5.1

    nacos 版本 1.4.2

    seata 客户端版本 1.4.2

    seata 服务端版本 1.7.1，笔者在文章最后面会使用服务端版本 1.4.2 演示，这里使用1.7.1版本的原因是1.4.2版本没有web控制台，且配置没有1.7.1方便，目前1.7.1版本是最新版

    目录

    1、创建项目

    1.1、新建 maven 聚合项目 cloud-learn

    1.2、创建 account 服务

    1.3、创建 order 服务

    2、添加配置

    2.1、客户端配置

    2.2、服务端配置

    3、数据库建表

    3.1、seata 服务端建表

    3.2、seata 客户端建表

    4、运行测试

    5、Seata Server 1.4.2

    6、项目代码

    1、创建项目

    1.1、新建 maven 聚合项目 cloud-learn

    最外层父工程 cloud-learn 的 pom.xml

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>com.wsjzzcbqgroupId>
    8.     <artifactId>cloud-learnartifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.     <modules>
    11.         <module>gateway-learnmodule>
    12.         <module>consumer-learnmodule>
    13.         <module>sentinel-learnmodule>
    14.         <module>seata-at-account-learnmodule>
    15.         <module>seata-at-order-learnmodule>
    16.     modules>
    17.     <packaging>pompackaging>
    18.  
    19.     <repositories>
    20.         <repository>
    21.             <id>naxus-aliyunid>
    22.             <name>naxus-aliyunname>
    23.             <url>https://maven.aliyun.com/repository/publicurl>
    24.             <releases>
    25.                 <enabled>trueenabled>
    26.             releases>
    27.             <snapshots>
    28.                 <enabled>falseenabled>
    29.             snapshots>
    30.         repository>
    31.     repositories>
    32.  
    33.     <parent>
    34.         <groupId>org.springframework.bootgroupId>
    35.         <artifactId>spring-boot-starter-parentartifactId>
    36.         <version>2.6.5version>
    37.         <relativePath/>
    38.     parent>
    39.  
    40.     <properties>
    41.         <spring-cloud.version>2021.0.1spring-cloud.version>
    42.         <spring-cloud-alibaba.version>2021.0.1.0spring-cloud-alibaba.version>
    43.         <alibaba-nacos-discovery.veriosn>2021.1alibaba-nacos-discovery.veriosn>
    44.         <alibaba-nacos-config.version>2021.1alibaba-nacos-config.version>
    45.         <spring-cloud-starter-bootstrap.version>3.1.1spring-cloud-starter-bootstrap.version>
    46.         <druid.version>1.1.17druid.version>
    47.         <mysql.version>8.0.11mysql.version>
    48.         <mybatis-plus.version>3.5.1mybatis-plus.version>
    49.     properties>
    50.  
    51.     <dependencyManagement>
    52.         <dependencies>
    53.             <dependency>
    54.                 <groupId>org.springframework.cloudgroupId>
    55.                 <artifactId>spring-cloud-dependenciesartifactId>
    56.                 <version>${spring-cloud.version}version>
    57.                 <type>pomtype>
    58.                 <scope>importscope>
    59.             dependency>
    60.  
    61.             <dependency>
    62.                 <groupId>com.alibaba.cloudgroupId>
    63.                 <artifactId>spring-cloud-alibaba-dependenciesartifactId>
    64.                 <version>${spring-cloud-alibaba.version}version>
    65.                 <type>pomtype>
    66.                 <scope>importscope>
    67.             dependency>
    68.  
    69.             <dependency>
    70.                 <groupId>com.alibaba.cloudgroupId>
    71.                 <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    72.                 <version>${alibaba-nacos-discovery.veriosn}version>
    73.             dependency>
    74.  
    75.             <dependency>
    76.                 <groupId>com.alibaba.cloudgroupId>
    77.                 <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId>
    78.                 <version>${alibaba-nacos-config.version}version>
    79.             dependency>
    80.  
    81.             
    82.             <dependency>
    83.                 <groupId>org.springframework.cloudgroupId>
    84.                 <artifactId>spring-cloud-starter-bootstrapartifactId>
    85.                 <version>${spring-cloud-starter-bootstrap.version}version>
    86.             dependency>
    87.  
    88.             <dependency>
    89.                 <groupId>com.alibaba.fastjson2groupId>
    90.                 <artifactId>fastjson2artifactId>
    91.                 <version>2.0.40version>
    92.             dependency>
    93.         dependencies>
    94.     dependencyManagement>
    95.  
    96.     <dependencies>
    97.         <dependency>
    98.             <groupId>org.projectlombokgroupId>
    99.             <artifactId>lombokartifactId>
    100.         dependency>
    101.     dependencies>
    102.  
    103.  
    104. project>

    下面会创建2个服务 account 和 order，模拟用户下订单后扣减账户金额，服务间使用 feign 调用，因为 account 和 order 服务使用不同的数据库，因此产生分布式事物，使用 seata 解决

    seata 默认使用 AT 事物模型，本文讲解演示的就是 AT 事物模型，其他事物模型在后面的文章中讲解

    1.2、创建 account 服务

    创建子工程 seata-at-account-learn

    seata-at-account-learn pom 文件

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>cloud-learnartifactId>
    7.         <groupId>com.wsjzzcbqgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>seata-at-account-learnartifactId>
    13.  
    14.     <dependencies>
    15.         <dependency>
    16.             <groupId>org.springframework.bootgroupId>
    17.             <artifactId>spring-boot-starter-webartifactId>
    18.         dependency>
    19.         <dependency>
    20.             <groupId>com.alibaba.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>com.alibaba.cloudgroupId>
    25.             <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId>
    26.         dependency>
    27.  
    28.         <dependency>
    29.             <groupId>com.alibaba.cloudgroupId>
    30.             <artifactId>spring-cloud-starter-alibaba-seataartifactId>
    31.         dependency>
    32.  
    33.         <dependency>
    34.             <groupId>com.alibabagroupId>
    35.             <artifactId>druid-spring-boot-starterartifactId>
    36.             <version>${druid.version}version>
    37.         dependency>
    38.  
    39.         <dependency>
    40.             <groupId>mysqlgroupId>
    41.             <artifactId>mysql-connector-javaartifactId>
    42.             <version>${mysql.version}version>
    43.         dependency>
    44.  
    45.         <dependency>
    46.             <groupId>com.baomidougroupId>
    47.             <artifactId>mybatis-plus-boot-starterartifactId>
    48.             <version>${mybatis-plus.version}version>
    49.         dependency>
    50.     dependencies>
    51.  
    52.     <build>
    53.         <plugins>
    54.             <plugin>
    55.                 <groupId>org.springframework.bootgroupId>
    56.                 <artifactId>spring-boot-maven-pluginartifactId>
    57.             plugin>
    58.         plugins>
    59.     build>
    60.  
    61. project>

    启动类 SeataATAccountApplication

    1. package com.wsjzzcbq;
    2.  
    3. import org.mybatis.spring.annotation.MapperScan;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6.  
    7. /**
    8.  * SeataATAccountApplication
    9.  *
    10.  * @author wsjz
    11.  * @date 2023/10/14
    12.  */
    13. @MapperScan(value = {"com.wsjzzcbq.mapper"})
    14. @SpringBootApplication
    15. public class SeataATAccountApplication {
    16.  
    17.     public static void main(String[] args) {
    18.         SpringApplication.run(SeataATAccountApplication.class, args);
    19.     }
    20. }

    实体类 Account

    1. package com.wsjzzcbq.bean;
    2.  
    3. import lombok.Data;
    4.  
    5. /**
    6.  * Account
    7.  *
    8.  * @author wsjz
    9.  * @date 2022/07/07
    10.  */
    11. @Data
    12. public class Account {
    13.  
    14.     private Integer id;
    15.  
    16.     private String userId;
    17.  
    18.     private Integer money;
    19. }

     AccountMapper

    1. package com.wsjzzcbq.mapper;
    2.  
    3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    4. import com.wsjzzcbq.bean.Account;
    5.  
    6. /**
    7.  * AccountMapper
    8.  *
    9.  * @author wsjz
    10.  * @date 2023/10/13
    11.  */
    12. public interface AccountMapper extends BaseMapper {
    13. }

    AccountService

    1. package com.wsjzzcbq.service;
    2.  
    3. import com.baomidou.mybatisplus.extension.service.IService;
    4. import com.wsjzzcbq.bean.Account;
    5.  
    6. /**
    7.  * AccountService
    8.  *
    9.  * @author wsjz
    10.  * @date 2023/10/13
    11.  */
    12. public interface AccountService extends IService {
    13.  
    14.     String reduce(String userId, int money);
    15. }

    AccountServiceImpl

    1. package com.wsjzzcbq.service.impl;
    2.  
    3. import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
    4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    5. import com.wsjzzcbq.bean.Account;
    6. import com.wsjzzcbq.mapper.AccountMapper;
    7. import com.wsjzzcbq.service.AccountService;
    8. import io.seata.core.context.RootContext;
    9. import org.springframework.stereotype.Service;
    10.  
    11. /**
    12.  * AccountServiceImpl
    13.  *
    14.  * @author wsjz
    15.  * @date 2023/10/13
    16.  */
    17. @Service
    18. public class AccountServiceImpl extends ServiceImpl implements AccountService {
    19.  
    20.     @Override
    21.     public String reduce(String userId, int money) {
    22.         String xid = RootContext.getXID();
    23.         System.out.println(xid);
    24.         UpdateWrapper up = new UpdateWrapper<>();
    25.         String sql = "money = money - " + money;
    26.         up.setSql(sql);
    27.         up.eq("user_id", userId);
    28.         this.update(up);
    29.         return "ok";
    30.     }
    31. }

    AccountController

    1. package com.wsjzzcbq.controller;
    2.  
    3. import com.fasterxml.jackson.core.JsonProcessingException;
    4. import com.fasterxml.jackson.databind.ObjectMapper;
    5. import com.wsjzzcbq.bean.Account;
    6. import com.wsjzzcbq.service.AccountService;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.web.bind.annotation.GetMapping;
    9. import org.springframework.web.bind.annotation.RequestMapping;
    10. import org.springframework.web.bind.annotation.RestController;
    11.  
    12. /**
    13.  * AccountController
    14.  *
    15.  * @author wsjz
    16.  * @date 2023/10/13
    17.  */
    18. @RequestMapping("/account")
    19. @RestController
    20. public class AccountController {
    21.  
    22.     @Autowired
    23.     private AccountService accountService;
    24.  
    25.     @GetMapping("/find")
    26.     public String find() throws JsonProcessingException {
    27.         Account account = accountService.list().get(0);
    28.         ObjectMapper objectMapper = new ObjectMapper();
    29.         String res = objectMapper.writeValueAsString(account);
    30.         System.out.println(res);
    31.         return res;
    32.     }
    33.  
    34.     @RequestMapping("/reduce")
    35.     public String debit(String userId, int money) {
    36.         try {
    37.             accountService.reduce(userId, money);
    38.             return "扣款成功";
    39.         } catch (Exception e) {
    40.             return "扣款失败";
    41.         }
    42.     }
    43. }

    application.yml 文件

    1. server:
    2.   port: 9001
    3. spring:
    4.   application:
    5.     name: seata-at-account-learn
    6.   datasource:
    7.     driver-class-name: com.mysql.cj.jdbc.Driver
    8.     url: jdbc:mysql://192.168.3.232:3306/pmc-account?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
    9.     username: root
    10.     password: 123456
    11.   cloud:
    12.     nacos:
    13.       username: nacos
    14.       password: nacos
    15.       server-addr: 192.168.2.140
    16.       discovery:
    17.         namespace: public
    18. #        server-addr: 192.168.2.140
    19. #      config:
    20. #        server-addr:
    21.  
    22.  
    23.  
    24. seata:
    25.   config:
    26.     type: nacos
    27.     nacos:
    28.       server-addr: ${spring.cloud.nacos.server-addr}
    29.       username: ${spring.cloud.nacos.username}
    30.       password: ${spring.cloud.nacos.password}
    31.       group: SEATA_GROUP
    32.       data-id: seata.properties
    33.   registry:
    34.     type: nacos
    35.     nacos:
    36.       application: seata-server
    37.       cluster: default
    38.       server-addr: ${spring.cloud.nacos.server-addr}
    39.       username: ${spring.cloud.nacos.username}
    40.       password: ${spring.cloud.nacos.password}
    41.       group: SEATA_GROUP
    42. # 事物分组，如果不配置默认是spring.application.name + '-seata-service-group'
    43. #  tx-service-group:
    44.  
    45.  
    46. logging:
    47.   level:
    48.     com.wsjzzcbq.mapper: debug
    49.  
    50. mybatis-plus:
    51.   global-config:
    52.     db-config:
    53.       id-type: auto

    关键配置说明

    nacos 注册中心和配置中心默认从 spring.cloud.nacos.server-addr 中获取，因此可以配置一个

    seata config 和 registry，config是客户端在nacos config 中存放的配置文件，它的 group 是 SEATA_GROUP，data-id 是 seata.properties，当然 group 和 data-id 名称是任意自定义的，但要保证和 nacos 中的对应上，否则找不到配置，seata.properties 具体配置内容后面详细说明；registry 配置的是nacos 中seata server 的信息，seata 客户端通过nacos 注册中心中配置的 seata server 的信息获取 seata server 实例，进行连接，这里笔者配置的 seata server group 是 SEATA_GROUP，seata server 的服务名是 seata-server，其实，可以把 seata server 理解为注册在nacos中的服务，相同的服务名，多个实例。项目启动后，会在nacos 注册中心中寻找服务名为 seata-server 的 seata 服务器，seata config、registry、nacos 和 seata server 的关系，看下图

    tx-service-group 事物分组，在同一分布式事物中的服务，需要使用同一事物分组，事物分组如果不配置，默认是 spring.application.name + '-seata-service-group'，这里笔者没有配置，使用默认的，即为 seata-at-account-learn-seata-service-group。事物分组是 seata的资源逻辑，事物分组详细说明，看官网文档截图

    1.3、创建 order 服务

    创建子工程 seata-at-order-learn 项目

    seata-at-order-learn pom 文件

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>cloud-learnartifactId>
    7.         <groupId>com.wsjzzcbqgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>seata-at-order-learnartifactId>
    13.  
    14.     <dependencies>
    15.         <dependency>
    16.             <groupId>org.springframework.bootgroupId>
    17.             <artifactId>spring-boot-starter-webartifactId>
    18.         dependency>
    19.         <dependency>
    20.             <groupId>com.alibaba.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>com.alibaba.cloudgroupId>
    25.             <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId>
    26.         dependency>
    27.  
    28.         <dependency>
    29.             <groupId>org.springframework.cloudgroupId>
    30.             <artifactId>spring-cloud-starter-openfeignartifactId>
    31.         dependency>
    32.  
    33.         <dependency>
    34.             <groupId>org.springframework.cloudgroupId>
    35.             <artifactId>spring-cloud-starter-loadbalancerartifactId>
    36.         dependency>
    37.  
    38.         <dependency>
    39.             <groupId>com.alibaba.cloudgroupId>
    40.             <artifactId>spring-cloud-starter-alibaba-seataartifactId>
    41.         dependency>
    42.  
    43.         <dependency>
    44.             <groupId>com.alibabagroupId>
    45.             <artifactId>druid-spring-boot-starterartifactId>
    46.             <version>${druid.version}version>
    47.         dependency>
    48.  
    49.         <dependency>
    50.             <groupId>mysqlgroupId>
    51.             <artifactId>mysql-connector-javaartifactId>
    52.             <version>${mysql.version}version>
    53.         dependency>
    54.  
    55.         <dependency>
    56.             <groupId>com.baomidougroupId>
    57.             <artifactId>mybatis-plus-boot-starterartifactId>
    58.             <version>${mybatis-plus.version}version>
    59.         dependency>
    60.     dependencies>
    61.  
    62.     <build>
    63.         <plugins>
    64.             <plugin>
    65.                 <groupId>org.springframework.bootgroupId>
    66.                 <artifactId>spring-boot-maven-pluginartifactId>
    67.             plugin>
    68.         plugins>
    69.     build>
    70. project>

    启动类 SeataATOrderApplication

    1. package com.wsjzzcbq;
    2.  
    3. import org.mybatis.spring.annotation.MapperScan;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. import org.springframework.cloud.openfeign.EnableFeignClients;
    7.  
    8. /**
    9.  * SeataATOrderApplication
    10.  *
    11.  * @author wsjz
    12.  * @date 2023/10/14
    13.  */
    14. @MapperScan(value = {"com.wsjzzcbq.mapper"})
    15. @EnableFeignClients
    16. @SpringBootApplication
    17. public class SeataATOrderApplication {
    18.  
    19.     public static void main(String[] args) {
    20.         SpringApplication.run(SeataATOrderApplication.class, args);
    21.     }
    22. }

    订单实体类 Order

    1. package com.wsjzzcbq.bean;
    2.  
    3. import com.baomidou.mybatisplus.annotation.TableName;
    4. import lombok.Data;
    5.  
    6. /**
    7.  * Order
    8.  *
    9.  * @author wsjz
    10.  * @date 2022/07/07
    11.  */
    12. @TableName("order_tbl")
    13. @Data
    14. public class Order {
    15.  
    16.     private Integer id;
    17.  
    18.     private String userId;
    19.  
    20.     private String code;
    21.  
    22.     private Integer count;
    23.  
    24.     private Integer money;
    25. }

    OrderMapper

    1. package com.wsjzzcbq.mapper;
    2.  
    3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    4. import com.wsjzzcbq.bean.Order;
    5.  
    6. /**
    7.  * OrderMapper
    8.  *
    9.  * @author wsjz
    10.  * @date 2022/07/07
    11.  */
    12. public interface OrderMapper extends BaseMapper {
    13. }

    AccountFeign

    1. package com.wsjzzcbq.feign;
    2.  
    3. import org.springframework.cloud.openfeign.FeignClient;
    4. import org.springframework.web.bind.annotation.RequestMapping;
    5. import org.springframework.web.bind.annotation.RequestParam;
    6.  
    7. /**
    8.  * AccountFeign
    9.  *
    10.  * @author wsjz
    11.  * @date 2023/10/13
    12.  */
    13. @FeignClient(value = "seata-at-account-learn")
    14. public interface AccountFeign {
    15.  
    16.     @RequestMapping("/account/reduce")
    17.     String debit(@RequestParam("userId") String userId, @RequestParam("money") int money);
    18. }

    OrderService

    1. package com.wsjzzcbq.service;
    2.  
    3. import com.baomidou.mybatisplus.extension.service.IService;
    4. import com.wsjzzcbq.bean.Order;
    5.  
    6. /**
    7.  * OrderService
    8.  *
    9.  * @author wsjz
    10.  * @date 2022/07/07
    11.  */
    12. public interface OrderService extends IService {
    13.  
    14.     void create(String userId, int money, boolean rollback);
    15. }

    OrderServiceImpl

    1. package com.wsjzzcbq.service.impl;
    2.  
    3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    4. import com.wsjzzcbq.bean.Order;
    5. import com.wsjzzcbq.feign.AccountFeign;
    6. import com.wsjzzcbq.mapper.OrderMapper;
    7. import com.wsjzzcbq.service.OrderService;
    8. import io.seata.core.context.RootContext;
    9. import io.seata.spring.annotation.GlobalTransactional;
    10. import org.springframework.beans.factory.annotation.Autowired;
    11. import org.springframework.stereotype.Service;
    12. import java.util.UUID;
    13.  
    14. /**
    15.  * OrderServiceImpl
    16.  *
    17.  * @author wsjz
    18.  * @date 2022/07/07
    19.  */
    20. @Service
    21. public class OrderServiceImpl extends ServiceImpl implements OrderService {
    22.  
    23.     @Autowired
    24.     private AccountFeign accountFeign;
    25.  
    26.     @GlobalTransactional
    27.     @Override
    28.     public void create(String userId, int money, boolean rollback) {
    29.         String xid = RootContext.getXID();
    30.         System.out.println(xid);
    31.         String orderCode = UUID.randomUUID().toString();
    32.  
    33.         Order order = new Order();
    34.         order.setCode(orderCode);
    35.         order.setCount(1);
    36.         order.setUserId(userId);
    37.         order.setMoney(money);
    38.  
    39.         this.save(order);
    40.  
    41.         accountFeign.debit(userId, money);
    42.  
    43.         if (rollback) {
    44.             int a = 1/0;
    45.         }
    46.  
    47.     }
    48. }

    OrderController

    1. package com.wsjzzcbq.controller;
    2.  
    3. import com.wsjzzcbq.service.OrderService;
    4. import org.springframework.beans.factory.annotation.Autowired;
    5. import org.springframework.web.bind.annotation.RequestMapping;
    6. import org.springframework.web.bind.annotation.RestController;
    7.  
    8. /**
    9.  * OrderController
    10.  *
    11.  * @author wsjz
    12.  * @date 2022/07/09
    13.  */
    14. @RequestMapping("/order")
    15. @RestController
    16. public class OrderController {
    17.  
    18.     @Autowired
    19.     private OrderService orderService;
    20.  
    21.     /**
    22.      * http://localhost:9002/order/create?userId=101&money=10&rollback=false
    23.      * @param userId
    24.      * @param money
    25.      * @param rollback
    26.      * @return
    27.      */
    28.     @RequestMapping("/create")
    29.     public String create(String userId, int money, boolean rollback) {
    30.         try {
    31.             orderService.create(userId, money, rollback);
    32.             return "下单成功";
    33.         } catch (Exception e) {
    34.             e.printStackTrace();
    35.             return "下单失败";
    36.         }
    37.     }
    38.  
    39. }

    application.yml 文件

    1. server:
    2.   port: 9002
    3. spring:
    4.   application:
    5.     name: seata-at-order-learn
    6.   datasource:
    7.     driver-class-name: com.mysql.cj.jdbc.Driver
    8.     url: jdbc:mysql://192.168.3.232:3306/pmc-order?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
    9.     username: root
    10.     password: 123456
    11.   cloud:
    12.     nacos:
    13.       username: nacos
    14.       password: nacos
    15.       server-addr: 192.168.2.140
    16.       discovery:
    17.         namespace: public
    18. #        server-addr: 192.168.2.140
    19. #      config:
    20. #        server-addr:
    21.  
    22.  
    23.  
    24. seata:
    25.   config:
    26.     type: nacos
    27.     nacos:
    28.       server-addr: ${spring.cloud.nacos.server-addr}
    29.       username: ${spring.cloud.nacos.username}
    30.       password: ${spring.cloud.nacos.password}
    31.       group: SEATA_GROUP
    32.       data-id: seata.properties
    33.   registry:
    34.     type: nacos
    35.     nacos:
    36.       application: seata-server
    37.       cluster: default
    38.       server-addr: ${spring.cloud.nacos.server-addr}
    39.       username: ${spring.cloud.nacos.username}
    40.       password: ${spring.cloud.nacos.password}
    41.       group: SEATA_GROUP
    42. # 事物分组，如果不配置默认是spring.application.name + '-seata-service-group'
    43.   tx-service-group: seata-at-account-learn-seata-service-group
    44.  
    45. logging:
    46.   level:
    47.     com.wsjzzcbq.mapper: debug
    48.  
    49. mybatis-plus:
    50.   global-config:
    51.     db-config:
    52.       id-type: auto

    配置说明

    基本和 account 服务配置相同，这里事物分组和 account 服务是一样的 seata-at-account-learn-seata-service-group

    2、添加配置

    2.1、客户端配置

    需要在nacos 中新建 group 是 SEATA_GROUP，data-id 是 seata.properties 的客户端配置

    配置内容如何获取？可以在github 上克隆seata 代码，在源代码 script 目录下有 config-center 目录，在 config-center 目录下有全部配置在 config.txt 文件中

    seata 源代码地址：https://github.com/seata/seata

    另一种方式是下载seata server，笔者下载的 seata server 1.7.1解压后，有 script目录，script目录下config-center 下config.txt 文件中有全部配置

    seata server 下载地址：https://github.com/seata/seata/releases

    config.txt 文件中有英文注释，说明了哪些配置是客户端的哪些是服务端的

    这里笔者已经整理好了客户端配置，在nacos上新建 group 是 SEATA_GROUP，data-id 是 seata.properties 的配置，内容如下

    seata.properties 内容

    1. #For details about configuration items, see https://seata.io/zh-cn/docs/user/configurations.html
    2. #Transport configuration, for client and server
    3. transport.type=TCP
    4. transport.server=NIO
    5. transport.heartbeat=true
    6. transport.enableTmClientBatchSendRequest=false
    7. transport.enableRmClientBatchSendRequest=true
    8. transport.enableTcServerBatchSendResponse=false
    9. transport.rpcRmRequestTimeout=30000
    10. transport.rpcTmRequestTimeout=30000
    11. transport.rpcTcRequestTimeout=30000
    12. transport.threadFactory.bossThreadPrefix=NettyBoss
    13. transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
    14. transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
    15. transport.threadFactory.shareBossWorker=false
    16. transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
    17. transport.threadFactory.clientSelectorThreadSize=1
    18. transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
    19. transport.threadFactory.bossThreadSize=1
    20. transport.threadFactory.workerThreadSize=default
    21. transport.shutdown.wait=3
    22. transport.serialization=seata
    23. transport.compressor=none
    24.  
    25. #Transaction routing rules configuration, only for the client
    26. service.vgroupMapping.seata-at-account-learn-seata-service-group=default
    27. #If you use a registry, you can ignore it
    28. service.default.grouplist=127.0.0.1:8091
    29. service.enableDegrade=false
    30. service.disableGlobalTransaction=false
    31.  
    32. #Transaction rule configuration, only for the client
    33. client.rm.asyncCommitBufferLimit=10000
    34. client.rm.lock.retryInterval=10
    35. client.rm.lock.retryTimes=30
    36. client.rm.lock.retryPolicyBranchRollbackOnConflict=true
    37. client.rm.reportRetryCount=5
    38. client.rm.tableMetaCheckEnable=true
    39. client.rm.tableMetaCheckerInterval=60000
    40. client.rm.sqlParserType=druid
    41. client.rm.reportSuccessEnable=false
    42. client.rm.sagaBranchRegisterEnable=false
    43. client.rm.sagaJsonParser=fastjson
    44. client.rm.tccActionInterceptorOrder=-2147482648
    45. client.tm.commitRetryCount=5
    46. client.tm.rollbackRetryCount=5
    47. client.tm.defaultGlobalTransactionTimeout=60000
    48. client.tm.degradeCheck=false
    49. client.tm.degradeCheckAllowTimes=10
    50. client.tm.degradeCheckPeriod=2000
    51. client.tm.interceptorOrder=-2147482648
    52. client.undo.dataValidation=true
    53. client.undo.logSerialization=jackson
    54. client.undo.onlyCareUpdateColumns=true
    55. server.undo.logSaveDays=7
    56. server.undo.logDeletePeriod=86400000
    57. client.undo.logTable=undo_log
    58. client.undo.compress.enable=true
    59. client.undo.compress.type=zip
    60. client.undo.compress.threshold=64k
    61. #For TCC transaction mode
    62. tcc.fence.logTableName=tcc_fence_log
    63. tcc.fence.cleanPeriod=1h
    64. # You can choose from the following options: fastjson, jackson, gson
    65. tcc.contextJsonParserType=fastjson
    66.  
    67. #Log rule configuration, for client and server
    68. log.exceptionRate=100

    这里需要改的有2处，一个是 service.vgroupMapping.seata-at-account-learn-seata-service-group=default，需要把 service.vgroupMapping. 后面的改成 account项目和 order 项目共同的事物分组 seata-at-account-learn-seata-service-group，这里笔者已经改完，默认的配置不是这个；另一处配置是 service.default.grouplist=127.0.0.1:8091，这里配置的是 seata server 的地址，因为笔者的 seata server 和项目在同一台电脑上，因此不做修改，使用127.0.0.1，读者可根据自己的情况配置

    2.2、服务端配置

    先下载 seata-server-1.7.1，然后进入 seata-server-1.7.1 的 conf 目录

    在 application.yml 文件中进行配置

    spring.application.name 默认是 seata-server ，和前面项目中配置的一样，不用修改

    控制台账号密码默认都是 seata

    seata config 和 registry 是关键，道理和客户端类似，seata server 从nacos 配置中心中获取group 是 SEATA_GROUP，data-id 是 seataServer.properties 的配置

    同时会把自身以group 是 SEATA_GROUP，服务名是 seata-server 的形式注册到 nacos 注册中心

    cluster 是 default，前面客户端的 service.vgroupMapping.seata-at-account-learn-seata-service-group=default，service.default.grouplist=127.0.0.1:8091，都是以 default 对应的

    笔者的 seata-server-1.7.1 的 application.yml  配置内容

    1. #  Copyright 1999-2019 Seata.io Group.
    2. #
    3. #  Licensed under the Apache License, Version 2.0 (the "License");
    4. #  you may not use this file except in compliance with the License.
    5. #  You may obtain a copy of the License at
    6. #
    7. #  http://www.apache.org/licenses/LICENSE-2.0
    8. #
    9. #  Unless required by applicable law or agreed to in writing, software
    10. #  distributed under the License is distributed on an "AS IS" BASIS,
    11. #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12. #  See the License for the specific language governing permissions and
    13. #  limitations under the License.
    14.  
    15. server:
    16.   port: 7091
    17.  
    18. spring:
    19.   application:
    20.     name: seata-server
    21.  
    22. logging:
    23.   config: classpath:logback-spring.xml
    24.   file:
    25.     path: ${log.home:${user.home}/logs/seata}
    26.   extend:
    27.     logstash-appender:
    28.       destination: 127.0.0.1:4560
    29.     kafka-appender:
    30.       bootstrap-servers: 127.0.0.1:9092
    31.       topic: logback_to_logstash
    32.  
    33. console:
    34.   user:
    35.     username: seata
    36.     password: seata
    37. seata:
    38.   config:
    39.     # support: nacos, consul, apollo, zk, etcd3
    40.     type: nacos
    41.     nacos:
    42.       server-addr: 192.168.2.140:8848
    43.       namespace:
    44.       group: SEATA_GROUP
    45.       username: nacos
    46.       password: nacos
    47.       context-path:
    48.       ##if use MSE Nacos with auth, mutex with username/password attribute
    49.       #access-key:
    50.       #secret-key:
    51.       data-id: seataServer.properties    
    52.   registry:
    53.     # support: nacos, eureka, redis, zk, consul, etcd3, sofa
    54.     type: nacos
    55.     nacos:
    56.       application: seata-server
    57.       server-addr: 192.168.2.140:8848
    58.       group: SEATA_GROUP
    59.       namespace:
    60.       cluster: default
    61.       username: nacos
    62.       password: nacos
    63.       context-path:
    64.       ##if use MSE Nacos with auth, mutex with username/password attribute
    65.       #access-key:
    66.       #secret-key:    
    67.   #store:
    68.     # support: file 、 db 、 redis
    69.     #mode: file
    70. #  server:
    71. #    service-port: 8091 #If not configured, the default is '${server.port} + 1000'
    72.   security:
    73.     secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017
    74.     tokenValidityInMilliseconds: 1800000
    75.     ignore:
    76.       urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.jpeg,/**/*.ico,/api/v1/auth/login

    配置完 seata-server-1.7.1 的 application.yml 文件后

    在nacos 中新建配置 seataServer.properties 

    seataServer.properties 内容

    1. #Transport configuration, for client and server
    2. transport.type=TCP
    3. transport.server=NIO
    4. transport.heartbeat=true
    5. transport.enableTmClientBatchSendRequest=false
    6. transport.enableRmClientBatchSendRequest=true
    7. transport.enableTcServerBatchSendResponse=false
    8. transport.rpcRmRequestTimeout=30000
    9. transport.rpcTmRequestTimeout=30000
    10. transport.rpcTcRequestTimeout=30000
    11. transport.threadFactory.bossThreadPrefix=NettyBoss
    12. transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
    13. transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
    14. transport.threadFactory.shareBossWorker=false
    15. transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
    16. transport.threadFactory.clientSelectorThreadSize=1
    17. transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
    18. transport.threadFactory.bossThreadSize=1
    19. transport.threadFactory.workerThreadSize=default
    20. transport.shutdown.wait=3
    21. transport.serialization=seata
    22. transport.compressor=none
    23.  
    24. #Log rule configuration, for client and server
    25. log.exceptionRate=100
    26.  
    27. #Transaction storage configuration, only for the server. The file, db, and redis configuration values are optional.
    28. store.mode=db
    29. store.lock.mode=db
    30. store.session.mode=db
    31. #Used for password encryption
    32. store.publicKey=
    33.  
    34. #If `store.mode,store.lock.mode,store.session.mode` are not equal to `file`, you can remove the configuration block.
    35. store.file.dir=file_store/data
    36. store.file.maxBranchSessionSize=16384
    37. store.file.maxGlobalSessionSize=512
    38. store.file.fileWriteBufferCacheSize=16384
    39. store.file.flushDiskMode=async
    40. store.file.sessionReloadReadSize=100
    41.  
    42. #These configurations are required if the `store mode` is `db`. If `store.mode,store.lock.mode,store.session.mode` are not equal to `db`, you can remove the configuration block.
    43. store.db.datasource=druid
    44. store.db.dbType=mysql
    45. store.db.driverClassName=com.mysql.cj.jdbc.Driver
    46. store.db.url=jdbc:mysql://192.168.3.232:3306/seata?useUnicode=true&rewriteBatchedStatements=true
    47. store.db.user=root
    48. store.db.password=123456
    49. store.db.minConn=5
    50. store.db.maxConn=30
    51. store.db.globalTable=global_table
    52. store.db.branchTable=branch_table
    53. store.db.distributedLockTable=distributed_lock
    54. store.db.queryLimit=100
    55. store.db.lockTable=lock_table
    56. store.db.maxWait=5000
    57.  
    58. #These configurations are required if the `store mode` is `redis`. If `store.mode,store.lock.mode,store.session.mode` are not equal to `redis`, you can remove the configuration block.
    59. store.redis.mode=single
    60. store.redis.type=pipeline
    61. store.redis.single.host=127.0.0.1
    62. store.redis.single.port=6379
    63. store.redis.sentinel.masterName=
    64. store.redis.sentinel.sentinelHosts=
    65. store.redis.maxConn=10
    66. store.redis.minConn=1
    67. store.redis.maxTotal=100
    68. store.redis.database=0
    69. store.redis.password=
    70. store.redis.queryLimit=100
    71.  
    72. #Transaction rule configuration, only for the server
    73. server.recovery.committingRetryPeriod=1000
    74. server.recovery.asynCommittingRetryPeriod=1000
    75. server.recovery.rollbackingRetryPeriod=1000
    76. server.recovery.timeoutRetryPeriod=1000
    77. server.maxCommitRetryTimeout=-1
    78. server.maxRollbackRetryTimeout=-1
    79. server.rollbackRetryTimeoutUnlockEnable=false
    80. server.distributedLockExpireTime=10000
    81. server.xaerNotaRetryTimeout=60000
    82. server.session.branchAsyncQueueSize=5000
    83. server.session.enableBranchAsyncRemove=false
    84. server.enableParallelRequestHandle=true
    85. server.enableParallelHandleBranch=false
    86.  
    87. #Metrics configuration, only for the server
    88. metrics.enabled=false
    89. metrics.registryType=compact
    90. metrics.exporterList=prometheus
    91. metrics.exporterPrometheusPort=9898

    这里的关键配置是存储 store，默认是 file 文件的形式

    笔者使用 mysql 数据库 db的形式储存事物相关信息

    需修改下面7项内容

    store.mode=db
    store.lock.mode=db
    store.session.mode=db
    store.db.driverClassName=com.mysql.cj.jdbc.Driver
    store.db.url=jdbc:mysql://192.168.3.232:3306/seata?useUnicode=true&rewriteBatchedStatements=true
    store.db.user=root
    store.db.password=123456

    笔者使用 mysql8，因此使用 com.mysql.cj.jdbc.Driver，数据库信息读者根据自己的情况修改

    nacos 中新建 seataServer.properties 

    3、数据库建表

    3.1、seata 服务端建表

    笔者所有数据库使用同一数据库服务器

    新建数据库 seata

    建表 sql 在 seata-server-1.7.1 的 seata-server-1.7.1\seata\script\server\db 目录下

    创建完成，有4张表

    3.2、seata 客户端建表

    seata 为实现分布式事物，业务库下需要有张记录日志的 undo_log 表

    undo_log 表 sql 可以在seata源码 seata\script\client\at\db 目录下找到，不同版本 seata server 会有差异

    笔者 account 服务建表，已包含 undo_log 表

    1. DROP TABLE IF EXISTS `account`;
    2. CREATE TABLE `account`  (
    3.   `id` int(0) NOT NULL AUTO_INCREMENT,
    4.   `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
    5.   `money` int(0) NULL DEFAULT 0,
    6.   PRIMARY KEY (`id`) USING BTREE
    7. ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
    8.  
    9. -- ----------------------------
    10. -- Records of account
    11. -- ----------------------------
    12. INSERT INTO `account` VALUES (1, '101', 900);
    13.  
    14. -- ----------------------------
    15. -- Table structure for undo_log
    16. -- ----------------------------
    17. DROP TABLE IF EXISTS `undo_log`;
    18. CREATE TABLE `undo_log`  (
    19.   `id` bigint(0) NOT NULL AUTO_INCREMENT,
    20.   `branch_id` bigint(0) NOT NULL,
    21.   `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
    22.   `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
    23.   `rollback_info` longblob NOT NULL,
    24.   `log_status` int(0) NOT NULL,
    25.   `log_created` datetime(0) NOT NULL,
    26.   `log_modified` datetime(0) NOT NULL,
    27.   PRIMARY KEY (`id`) USING BTREE,
    28.   UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
    29. ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

    笔者 order 服务建表，已包含 undo_log 表

    1. DROP TABLE IF EXISTS `order_tbl`;
    2. CREATE TABLE `order_tbl`  (
    3.   `id` int(0) NOT NULL AUTO_INCREMENT,
    4.   `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
    5.   `code` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
    6.   `count` int(0) NULL DEFAULT 0,
    7.   `money` int(0) NULL DEFAULT 0,
    8.   PRIMARY KEY (`id`) USING BTREE
    9. ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
    10.  
    11. -- ----------------------------
    12. -- Table structure for undo_log
    13. -- ----------------------------
    14. DROP TABLE IF EXISTS `undo_log`;
    15. CREATE TABLE `undo_log`  (
    16.   `id` bigint(0) NOT NULL AUTO_INCREMENT,
    17.   `branch_id` bigint(0) NOT NULL,
    18.   `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
    19.   `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
    20.   `rollback_info` longblob NOT NULL,
    21.   `log_status` int(0) NOT NULL,
    22.   `log_created` datetime(0) NOT NULL,
    23.   `log_modified` datetime(0) NOT NULL,
    24.   PRIMARY KEY (`id`) USING BTREE,
    25.   UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
    26. ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

    建表完成

    4、运行测试

    启动 seata-server-1.7.1

    进入 bin 目录，双击 seata-server.bat

    seata 控制台：http://localhost:7091/

    账号密码都是 seata

    启动 account 和 order 服务

    nacos 服务和配置

    测试正常情况

    浏览器请求：http://localhost:9002/order/create?userId=101&money=10&rollback=false

    扣减账户 10 元，新增订单

    测试回滚情况

    5、Seata Server 1.4.2

    seata-server-1.4.2 配置说明

    进入 seata-server-1.4.2 的 conf 目录

    配置文件是 registry.conf 和 file.conf，这个是seata 服务端早期的配置方式，没有1.7.1的application.yml 文件方便

    registry.conf 文件中 registry， 通过 type 指定注册中心，默认是 file，如果使用 nacos，要在下面nacos 配置的位置配置nacos的信息，其他注册中心同理

    registry.conf 文件中 config，通过 type 指定，默认是file，如果使用nacos，需要在下面nacos配置位置配置nacos信息，其他配置中心同理

    file.conf 配置说明（如果registry.conf 文件中 config使用 file，file.conf 配置才生效），通过mode 指定存储形式，默认是file，如果想使用db，需要在下面db配置处配置数据库信息

    6、项目代码

    码云地址：https://gitee.com/wsjzzcbq/csdn-blog/tree/master/cloud-learn

    至此完

  • 相关阅读:
    JavaScript学习笔记——BOM
    2022谷粒商城学习笔记（二）人人开源逆向工程
    【KafkaStream】流式计算概述&KafkaStream入门
    第一章 计算机网络基础
    Git使用总结
    零基础5分钟上手亚马逊云科技AWS核心云架构知识 - 为应用配置自动扩展
    【无标题】
    loadrunner lr解决参数化一次取多条记录【一对多问题】
    SELinux零知识学习十八、SELinux策略语言之类型强制（3）
    vscode c++食用指南
  • 原文地址：https://blog.csdn.net/wsjzzcbq/article/details/133828606