Spring Boot整合Seata的過程詳解(AT 模式)

更新時間：2025年10月10日 11:38:24 作者：一個憨憨coder

文章介紹了如何在SpringBoot項目中整合Seata框架來管理跨服務、跨數(shù)據(jù)庫的分布式事務,本文結合實例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧

在 Spring Boot 項目中整合 Seata（分布式事務框架），可以實現(xiàn)跨服務、跨數(shù)據(jù)庫的分布式事務管理。Seata 提供了多種模式，如 AT、TCC、Saga、XA 等，其中 AT 模式 是最常用的一種，它通過代理數(shù)據(jù)源和全局事務日志（undo_log）來實現(xiàn)自動回滾。

下面介紹 Spring Boot 整合 Seata（AT 模式） ：

?? 前提條件

已安裝并啟動 Seata Server
數(shù)據(jù)庫支持：MySQL / Oracle / PostgreSQL 等
Spring Boot 項目使用 MyBatis / JPA / JDBC
使用 Dubbo 或 Spring Cloud Alibaba 微服務架構

? 一：搭建 Seata Server（TC）

1. 下載 Seata Server

前往 Seata GitHub Releases 下載最新版本。

例如：

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

2. 配置registry.conf和file.conf

修改 registry.conf（注冊中心）

如果你用的是 Nacos 注冊中心，配置如下：

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"
  }
}

3. 啟動 Seata Server

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

注意：Windows 用戶執(zhí)行 seata-server.bat

? 二：配置數(shù)據(jù)庫（undo_log 表）

每個參與分布式事務的數(shù)據(jù)庫都需要創(chuàng)建 undo_log 表：

-- 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 項目整合 Seata

1. 添加依賴（Maven）

<!-- 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>

2. 配置 application.yml

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 數(shù)據(jù)源代理
    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 地址（僅測試環(huán)境需要）
  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

3. 編寫業(yè)務代碼

Service 層添加 @GlobalTransactional 注解

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(...));
        // 模擬異常觸發(fā)回滾
        if (true) {
            throw new RuntimeException("模擬失敗");
        }
    }
}

4. 啟動類

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

? 四：多服務協(xié)同調用（微服務場景）

所有服務都引入 seata-spring-boot-starter
所有服務都要配置相同的 tx-service-group
在 Feign/RPC 調用時，Seata 會自動傳播 XID，實現(xiàn)全局事務控制

? 驗證是否生效

查看日志中是否有 xid=xxx 輸出
觸發(fā)異常后，檢查各服務數(shù)據(jù)庫是否回滾
查看 Seata Server 控制臺日志

?? 常見問題排查

問題	解決方案
無法連接 TC	檢查 Seata Server 是否啟動，配置的 IP/端口是否正確
未找到 undo_log 表	檢查數(shù)據(jù)庫是否已創(chuàng)建該表
分布式事務不生效	檢查是否開啟 `@GlobalTransactional`，是否使用 Seata 數(shù)據(jù)源代理
多個服務之間 XID 不一致	檢查 Feign/RPC 是否開啟攔截器，或是否遺漏 Seata 配置

? 小結

步驟	內容
1	安裝并啟動 Seata Server
2	創(chuàng)建 `undo_log` 表
3	引入依賴、配置數(shù)據(jù)源、添加注解
4	多服務協(xié)調調用，驗證事務一致性

到此這篇關于Spring Boot整合Seata的過程詳解(AT 模式)的文章就介紹到這了,更多相關springboot整合seata內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: