Springboot 集成 Seata

矫情吗；* 2024-02-22 09:27 43阅读 0赞

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

## 1.找到适合的Seata版本 ##

[参考：SpringCloudAlibaba SpringCloud SpringBoot 版本对照][SpringCloudAlibaba SpringCloud SpringBoot]

> 依赖版本：
> 
> spring-boot：2.3.12.RELEASE
> 
> spring-cloud-alibaba：2.2.7.RELEASE
> 
> spring-cloud：Hoxton.SR12
> 
> [nacos][]：2.0.3
> 
> seata: 1.3.0

## 2.下载合适版本的Seata源码下载 ##

[Release v1.3.0 · seata/seata · GitHub][Release v1.3.0 _ seata_seata _ GitHub]

wget https://github.com/seata/seata/archive/refs/tags/v1.3.0.zip
    wget https://github.com/seata/seata/archive/refs/tags/v1.3.0.tar.gz

## 3.配置启动Seata ##

### 3.1 初始化数据库 ###

#### 3.1.1 创建seata数据库 ####

#### 3.1.2 初始化表 ####

资源链接：[https://github.com/seata/seata/blob/1.3.0/script/server/db/mysql.sql][https_github.com_seata_seata_blob_1.3.0_script_server_db_mysql.sql]

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
    -- the table to store GlobalSession data
    CREATE TABLE IF NOT EXISTS `global_table`
    (
        `xid`                       VARCHAR(128) NOT NULL,
        `transaction_id`            BIGINT,
        `status`                    TINYINT      NOT NULL,
        `application_id`            VARCHAR(32),
        `transaction_service_group` VARCHAR(32),
        `transaction_name`          VARCHAR(128),
        `timeout`                   INT,
        `begin_time`                BIGINT,
        `application_data`          VARCHAR(2000),
        `gmt_create`                DATETIME,
        `gmt_modified`              DATETIME,
        PRIMARY KEY (`xid`),
        KEY `idx_gmt_modified_status` (`gmt_modified`, `status`),
        KEY `idx_transaction_id` (`transaction_id`)
    ) ENGINE = InnoDB
      DEFAULT CHARSET = utf8;
    
    -- the table to store BranchSession data
    CREATE TABLE IF NOT EXISTS `branch_table`
    (
        `branch_id`         BIGINT       NOT NULL,
        `xid`               VARCHAR(128) NOT NULL,
        `transaction_id`    BIGINT,
        `resource_group_id` VARCHAR(32),
        `resource_id`       VARCHAR(256),
        `branch_type`       VARCHAR(8),
        `status`            TINYINT,
        `client_id`         VARCHAR(64),
        `application_data`  VARCHAR(2000),
        `gmt_create`        DATETIME(6),
        `gmt_modified`      DATETIME(6),
        PRIMARY KEY (`branch_id`),
        KEY `idx_xid` (`xid`)
    ) ENGINE = InnoDB
      DEFAULT CHARSET = utf8;
    
    -- the table to store lock data
    CREATE TABLE IF NOT EXISTS `lock_table`
    (
        `row_key`        VARCHAR(128) NOT NULL,
        `xid`            VARCHAR(96),
        `transaction_id` BIGINT,
        `branch_id`      BIGINT       NOT NULL,
        `resource_id`    VARCHAR(256),
        `table_name`     VARCHAR(32),
        `pk`             VARCHAR(36),
        `gmt_create`     DATETIME,
        `gmt_modified`   DATETIME,
        PRIMARY KEY (`row_key`),
        KEY `idx_branch_id` (`branch_id`)
    ) ENGINE = InnoDB
      DEFAULT CHARSET = utf8;

## 3.2 完善Nacos相关配置 ##

安装配置启动Nacos参考：[Linux Nacos 快速启动\_nacos linux快速启动-CSDN博客][Linux Nacos _nacos linux_-CSDN]

### 3.2.1 新建命名空间 seata ###

![801a4415222a4497896abb2c683c8c50.png][]

![457cf8c0a2434048ae5b34fad3197252.png][]

###  ###

### 3.2.2 修改config.txt ###

/seata/script/config-center/config.txt

service.vgroupMapping.my_test_tx_group=SEATA_GROUP
    
    store.mode=db
    
    store.db.url=jdbc:mysql://xxxx:3306/seata?useUnicode=true
    store.db.user=seata
    store.db.password=xxxx

###  ###

### 3.2.3 将配置信息推送至nacos ###

源码目录下：/seata-1.3.0/script/config-center/nacos/nacos-config.sh

chmod +x nacos-config.sh
    
    ./nacos-config.sh -h 127.0.0.1 -p 8848 -g SEATA_GROUP -t 61311143-2318-4af4-9180-ebbc0fxxxxx -u nacos -w nacos

> \-h: host, 默认值 localhost
> 
> \-p: port, 默认值 8848
> 
> \-g: 配置分组 默认值 SEATA\_GROUP
> 
> \-t: 命名空间
> 
> \-u: 用户名, nacos 1.2.0+ 之后添加权限验证 默认为''
> 
> \-w: 密码, nacos 1.2.0+ 之后添加权限验证 默认为''

##  ##

## 4. 配置启动Seata服务 ##

wget https://github.com/seata/seata/releases/download/v1.3.0/seata-server-1.3.0.tar.gz  
wget https://github.com/seata/seata/releases/download/v1.3.0/seata-server-1.3.0.zip

### 4.1 修改registry.conf ###

服务目录下：/seata/conf/registry.conf

注意：命名空间需要与上文中生成的保持一致。

registry {
      # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
      type = "nacos"
    
      nacos {
        application = "seata-server"
        serverAddr = "127.0.0.1:8848"
        group = "SEATA_GROUP"
        namespace = "61311143-2318-4af4-9180-ebxxx"
        username = "nacos"
        password = "nacos"
      }
    }
    config {
      # file、nacos 、apollo、zk、consul、etcd3、springCloudConfig
      type = "nacos"
    
      nacos {
        serverAddr = "127.0.0.1:8848"
        namespace = "61311143-2318-4af4-9180-ebxxx"
        group = "SEATA_GROUP"
        username = "nacos"
        password = "nacos"
      }
    }

###  ###

### 4.2 修改file.conf ###

服务目录下：/seata/conf/file.conf

## transaction log store, only used in seata-server
    store {
      ## store mode: file、db、redis
      mode = "db"
    
      db {
        ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.
        datasource = "druid"
        ## mysql/oracle/postgresql/h2/oceanbase etc.
        dbType = "mysql"
        driverClassName = "com.mysql.jdbc.Driver"
        url = "jdbc:mysql://Xx:3306/seata"
        user = "seata"
        password = "Xx"
        minConn = 5
        maxConn = 30
        globalTable = "global_table"
        branchTable = "branch_table"
        lockTable = "lock_table"
        queryLimit = 100
        maxWait = 5000
      }
    }

### 4.3 启动服务 ###

sh ./bin/seata-server.sh -h 127.0.0.1 -p 8091 -m db

> \-h nacos 地址
> 
> \-p seata服务端口 默认8091
> 
> \-m 存在事务日志的类型 file 文件 db 数据库 redis...

![0dfa2abfb73049f39227c4af5cd04718.png][]

注意：将合适的数据库链接jar包放到 lib目录，（msyql8+ 使用seata/bin/jdbc/mysql-connector-java-8.0.19.jar）。

## 5.简单XA模式集成 ##

### 5.1 业务库中添加表 ###

参照官网：[快速启动 | Seata][_ Seata]

DROP TABLE IF EXISTS `undo_log`;
    CREATE TABLE `undo_log`  (
                                 `id` bigint(20) NOT NULL AUTO_INCREMENT,
                                 `branch_id` bigint(20) NOT NULL,
                                 `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
                                 `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
                                 `rollback_info` longblob NOT NULL,
                                 `log_status` int(11) NOT NULL,
                                 `log_created` datetime NOT NULL,
                                 `log_modified` datetime NOT NULL,
                                 `ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
                                 PRIMARY KEY (`id`) USING BTREE,
                                 UNIQUE INDEX `ux_undo_log`(`xid`, `branch_id`) USING BTREE
    ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = DYNAMIC;

###  ###

### 5.2 添加依赖 ###

此版本需要收到手动重新导入依赖包（1.3.0），否则jar冲突导致启动报错。

<dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
                <exclusions>
                    <exclusion>
                        <groupId>io.seata</groupId>
                        <artifactId>seata-spring-boot-starter</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-spring-boot-starter</artifactId>
                <version>1.3.0</version>
            </dependency>

### 5.3 添加配置 ###

my_test_tx_group使用需要注意。

seata:
      data-source-proxy-mode: XA # 开启XA事务
      registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
        # 参考tc服务自己的registry.conf中的配置
        type: nacos
        nacos: # tc
          server-addr: nacosip
          namespace: "命名空间ID"
          group: SEATA_GROUP
          application: seata-server # tc服务在nacos中的服务名称
          cluster: default #集群
      tx-service-group: my_test_tx_group # 事务组，根据这个获取tc服务的cluster名称
      service:
        grouplist:
          seata-server: 指定seata的IP端口
          vgroup-mapping: # 事务组与TC服务cluster的映射关系
            my_test_tx_group: default

### 5.4 测试表 ###

参照官网：[快速启动 | Seata][_ Seata]

> DROP TABLE IF EXISTS \`order\_tbl\`;  
> CREATE TABLE \`order\_tbl\` (  
> \`id\` int(11) NOT NULL AUTO\_INCREMENT,  
> \`user\_id\` varchar(255) DEFAULT NULL,  
> \`commodity\_code\` varchar(255) DEFAULT NULL,  
> \`count\` int(11) DEFAULT 0,  
> \`money\` int(11) DEFAULT 0,  
> PRIMARY KEY (\`id\`)  
> ) ENGINE=InnoDB DEFAULT CHARSET=utf8;  
>   
>   
> DROP TABLE IF EXISTS \`account\_tbl\`;  
> CREATE TABLE \`account\_tbl\` (  
> \`id\` int(11) NOT NULL AUTO\_INCREMENT,  
> \`user\_id\` varchar(255) DEFAULT NULL,  
> \`money\` int(11) DEFAULT 0,  
> PRIMARY KEY (\`id\`)  
> ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

### 5.4测试代码 ###

#### 5.4.1订单 ####

@RestController
    @RequestMapping("/orderTbl")
    public class OrderTblController {
    
        @Resource
        private OrderTblService orderTblService;
    
        @PostMapping("/add/{userId}/{money}")
        public CxResult<Boolean> add(@PathVariable("userId") String userId, @PathVariable("money") Integer money) {
            return CxResult.success(orderTblService.add(userId, money));
        }
    
    }
    
    public interface OrderTblService extends IService<OrderTbl> {
    
        Boolean add(String userId, Integer money);
    
    }
    
    @Service
    public class OrderTblServiceImpl extends ServiceImpl<OrderTblMapper, OrderTbl> implements OrderTblService {
    
        @DubboReference
        private AccountProviderService accountProviderService;
    
        @Override
        @GlobalTransactional
        public Boolean add(String userId, Integer money) {
            OrderTbl orderTbl = new OrderTbl();
            orderTbl.setUserId(userId);
            orderTbl.setMoney(money);
            this.save(orderTbl);
    
            accountProviderService.addRecord(userId, money);
            if (money > 10000) {
                throw new BusinessException(ErrorMsg.COMMON_ERROR_1);
            }
            return Boolean.TRUE;
        }
    
    }

#### 5.4.2 账户 ####

public interface AccountProviderService {
    
        void addRecord(String userId, Integer money);
    }
    
    @DubboService
    public class AccountProvider implements AccountProviderService {
    
        @Resource
        private AccountTblService accountTblService;
    
        @Override
        @GlobalTransactional
        public void addRecord(String userId, Integer money) {
            AccountTbl accountTbl = new AccountTbl();
            accountTbl.setUserId(userId);
            accountTbl.setMoney(money);
            accountTblService.save(accountTbl);
        }
    
    }

[Seata]: http://seata.io/zh-cn/
[SpringCloudAlibaba SpringCloud SpringBoot]: https://blog.csdn.net/qq_34253002/article/details/133814012?spm=1001.2014.3001.5501
[nacos]: https://so.csdn.net/so/search?q=nacos&spm=1001.2101.3001.7020
[Release v1.3.0 _ seata_seata _ GitHub]: https://github.com/seata/seata/releases/tag/v1.3.0
[https_github.com_seata_seata_blob_1.3.0_script_server_db_mysql.sql]: https://github.com/seata/seata/blob/1.3.0/script/server/db/mysql.sql
[Linux Nacos _nacos linux_-CSDN]: https://blog.csdn.net/qq_34253002/article/details/121561237
[801a4415222a4497896abb2c683c8c50.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/22/78358538273345c9adce42d4263a2d58.png
[457cf8c0a2434048ae5b34fad3197252.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/22/fd355814dc524fc986143c740d30b372.png
[0dfa2abfb73049f39227c4af5cd04718.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/22/c8a3d97628f74779a35dd74237d7fbeb.png
[_ Seata]: http://seata.io/zh-cn/docs/user/quickstart