Spring Boot整合Seata的过程详解(AT 模式)

wget https://github.com/seata/seata/releases/download/v2.0.0/seata-server-2.0.0.zip

registry {
  type = "nacos"
  nacos {
    server-addr = "127.0.0.1:8848"
    namespace = ""
    group = "DEFAULT_GROUP"
  }
}
config {
  type = "nacos"
  nacos {
    server-addr = "127.0.0.1:8848"
    namespace = ""
    group = "SEATA_GROUP"
    data-id = "seataServer.properties"
  }
}

cd seata/bin
./seata-server.sh -p 8091 -m file

-- MySQL 示例
CREATE TABLE `undo_log` (
  `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
  `branch_id` BIGINT(20) NOT NULL,
  `xid` VARCHAR(100) NOT NULL,
  `context` VARCHAR(128) 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) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

<!-- Spring Boot Starter -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- MyBatis Plus -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>
<!-- MySQL 驱动 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Seata Starter -->
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
</dependency>
<!-- Nacos Discovery（可选） -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

server:
  port: 8081
spring:
  application:
    name: order-service
  datasource:
    url: jdbc:mysql://localhost:3306/order_db?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver
    # 使用 Seata 数据源代理
    type: io.seata.rm.datasource.SeataDataSourceProxy
# Seata 配置
seata:
  enabled: true
  application-id: ${spring.application.name} # 应用唯一ID
  tx-service-group: my_test_tx_group       # 事务组名（与 TC 配置一致）
  service:
    vgroup-mapping:
      my_test_tx_group: default             # 映射事务组到默认集群
    grouplist:
      default: 127.0.0.1:8091               # TC 地址（仅测试环境需要）
  config:
    type: nacos                            # 配置中心类型
    nacos:
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      data-id: seataServer.properties
  registry:
    type: nacos                           # 注册中心类型
    nacos:
      server-addr: 127.0.0.1:8848

import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.stereotype.Service;
@Service
public class OrderService {
    @GlobalTransactional(name = "create-order", rollbackFor = Exception.class)
    public void createOrder() throws Exception {
        // 调用库存服务扣减库存（RPC）
        stockService.decreaseStock();
        // 插入订单
        orderMapper.insert(new Order(...));
        // 模拟异常触发回滚
        if (true) {
            throw new RuntimeException("模拟失败");
        }
    }
}

@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }
}