Springcloud 集成 Seata1.5.2

news2024/11/17 9:27:11

一、关于seata1.5.2的安装部署请参考：

Seata1.5.2安装配置+部署_不知道取啥昵称的博客-CSDN博客

二、springcloud程序集成seata

我这里使用的alibaba-cloud版本为 2.2.6.RELEASE，其对应的seata版本为1.3.0，但是想使用seata1.5.2的版本，故需要替换seata核心包。

1. 父(parent)工程 pom 引用：

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR9</spring-cloud.version>
        <spring-alibaba-cloud.version>2.2.6.RELEASE</spring-alibaba-cloud.version>
        <seata.version>1.5.2</seata.version>
    </properties>

<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-spring-boot-starter</artifactId>
                <version>${seata.version}</version>
            </dependency>

        </dependencies>
    </dependencyManagement>

2. 子程序pom依赖(common.pom)。

注意：这里引入了spring-cloud-starter-alibaba-seata, 如果不引入该包，会导致应用程序中XID不会自动传递，需要手动处理。

        <!--seata -->
        <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>
        </dependency>

3. 子程序nacos对应服务配置文件或者当前程序resource下配置文件 application.yml 中添加seata配置项如下：

#seata分布式事务
seata:
  enabled: true
  tx-service-group: default_tx_group
  application-id: ${spring.application.name}
  enable-auto-data-source-proxy: true
  #数据源代理模式使用AT模式(可以不用配置，seata默认使用AT模式)
  data-source-proxy-mode: AT
  #事务群组（可以每个应用独立取名，也可以使用相同的名字），要与服务端seataServer.properties中service.vgroup_mapping中存在,并且要保证多个群组情况下后缀名要保持一致-tx_group
  service:
    vgroup-mapping:
      default_tx_group: default

  registry:
    type: nacos
    nacos:
      server-addr: ${spring.cloud.nacos.discovery.server-addr}
      username: ${spring.cloud.nacos.discovery.username}
      password: ${spring.cloud.nacos.discovery.password}
      #seata分组名称SEATA_GROUP
      group: SEATA_GROUP
      #nacos命名空间ID
      namespace: seata-namespace-id
      #seata服务名
      application: seata-server

  config:
    type: nacos
    nacos:
      server-addr: ${spring.cloud.nacos.discovery.server-addr}
      username: ${spring.cloud.nacos.discovery.username}
      password: ${spring.cloud.nacos.discovery.password}
      #seata分组名称
      group: SEATA_GROUP
      #nacos命名空间ID
      namespace: seata-namespace-id
      data-id: seataServer.properties

需要注意的地方如下图：

4. 配置每个应用程序的业务库，都执行如下seata数据库脚本。（seata-AT模式）

-- for AT mode you must to init this sql for you business database. the seata server not need it.
CREATE TABLE IF NOT EXISTS `undo_log`
(
    `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(128) 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
  AUTO_INCREMENT = 1
  DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';