前言微服务架构最大的数据一致性难题就是分布式事务。单体项目中我们依靠Transactional即可保证数据库事务原子性要么全部成功、要么全部回滚。但微服务拆分后一次业务操作会跨多个服务、多个数据库本地事务彻底失效极易出现部分成功、部分失败、数据脏写、数据不一致问题引发资损、业务异常。Seata是阿里开源、Apache 顶级开源的一站式高性能分布式事务解决方案彻底解决微服务跨库、跨服务事务一致性问题是 Spring Cloud Alibaba 体系中解决分布式事务的行业标准组件。本文从零搭建全套运行环境包含Seata服务端部署、Nacos联动配置、客户端完整代码、步骤化测试、原理详解、优缺点、生产实践与适用场景全程可直接复刻运行风格统一适配微服务全家桶系列博客。一、Seata 技术背景与发展历程1.1 为什么必须用分布式事务微服务拆分后业务链路被拆解为多个独立服务每个服务独立数据库本地事务无法跨服务生效。经典电商下单场景创建订单(订单服务) → 扣减库存(库存服务) → 扣减余额(账户服务)。若前两个服务执行成功最后扣减余额异常会出现订单生成、库存减少、用户余额未扣的数据不一致问题直接造成平台资损、脏数据堆积是生产环境绝对无法容忍的问题。1.2 传统分布式事务方案缺陷在Seata出现之前行业主流分布式事务方案均存在明显短板无法适配微服务高并发、低侵入、易维护的核心需求原生XA2PC强一致性但性能极差、长事务阻塞数据库完全不适合高并发微服务场景手写TCC补偿代码侵入极高、开发成本巨大每个业务需单独实现Try/Confirm/Cancel无通用性本地消息表业务与事务逻辑强耦合需维护额外消息表状态机复杂最终一致性保障弱RabbitMQ可靠消息强依赖MQ中间件、事务延迟高仅适配非实时最终一致场景无法满足金融、交易类强一致需求。1.3 Seata 发展与核心定位Seata 源自阿里双十一高并发分布式事务实战打磨专为微服务架构设计核心目标低侵入、高性能、易落地、多场景适配。目前支持 AT、TCC、SAGA、XA 四大事务模式全覆盖高并发、长事务、强一致、老旧系统兼容场景是国内微服务分布式事务唯一主流标准化解决方案无缝适配Spring Cloud Alibaba全套生态。二、Seata 核心架构与三大核心角色Seata 采用经典的协调器客户端架构整体由 TC、TM、RM 三大核心组件协同工作所有分布式事务的开启、注册、提交、回滚均由三者联动完成。2.1 TCTransaction Coordinator 事务协调器独立部署的Seata Server服务端是全局事务的调度中枢与核心管控节点全局唯一。核心职责统一维护全局事务、分支事务的状态、生命周期接收TM的全局事务开启、提交、回滚指令调度所有RM分支事务实现统一提交或统一回滚支持事务日志持久化、集群高可用、故障恢复保障事务可靠性。2.2 TMTransaction Manager 事务管理器嵌入在业务发起方微服务中的客户端组件是全局事务的创建者与终结者。核心职责向TC申请开启全局事务生成全局唯一事务IDXID业务链路执行完毕后根据执行结果通知TC全局提交或全局回滚。2.3 RMResource Manager 资源管理器嵌入在所有参与分布式事务的微服务中是分支事务的实际执行者。核心职责向TC注册本地分支事务关联全局XID拦截业务SQL记录事务快照与回滚日志接收TC调度指令执行分支事务提交或回滚操作。2.4 完整事务调用链路TM开启全局事务生成XID → 所有微服务RM注册分支事务 → 各服务执行业务SQL → 全部成功则TC调度全局提交 / 任意分支异常则TC调度全局回滚三、Seata 四大事务模式详解核心重点3.1 AT 模式Auto Transaction 自动事务·生产首选定位Seata默认模式、零业务侵入、性能接近本地事务、适配90%以上微服务高并发场景企业落地主流方案。3.1.1 两阶段核心原理第一阶段执行阶段RM自动拦截业务SQL解析数据库数据前后镜像生成并写入undo_log回滚日志执行本地业务SQL并提交本地事务同时占用全局行锁无需阻塞等待。第二阶段决议阶段根据全局事务结果执行不同逻辑全局成功TC下发提交指令RM异步清理undo_log日志、释放全局锁性能极高全局失败TC下发回滚指令RM解析undo_log镜像反向生成回滚SQL精准恢复事务前数据状态杜绝脏数据。核心特点业务零改造、无需手动补偿、无人工代码侵入、高并发友好、隔离性可控。3.2 TCC 模式手动补偿模式定位高自定义、强可控、适配非数据库事务、复杂特殊业务场景。需开发者手动实现三段式接口完全脱离数据库本地事务纯代码实现事务补偿Try资源校验/锁定检查业务资源、锁定资源完成预执行业务Confirm确认提交全局事务成功确认执行业务、释放锁定资源Cancel回滚补偿全局事务失败撤销Try操作、释放资源、数据回滚。优缺点可控性最强、适配特殊场景代码侵入极高、开发维护成本大。3.3 SAGA 模式长事务模式定位适配长耗时、长链路、异步化事务场景无锁、最终一致性。核心原理为每一个正向业务接口配置对应的反向补偿接口事务链路执行异常时逆向依次执行补偿逻辑回滚整条链路数据适用于订单履约、流程审批、超时关闭等长事务场景。3.4 XA 模式原生强一致模式定位兼容数据库原生XA二阶段协议强一致性、无脏数据。核心缺陷事务全程阻塞、数据库锁持有时间长、性能极低完全不适合高并发微服务仅用于老旧传统项目兼容改造。四、Seata 优缺点全面总结4.1 核心优点极低业务侵入AT模式仅需一行全局事务注解无需改动核心业务代码高性能高并发一阶段本地事务立即提交二阶段异步清理性能无限接近本地事务全场景覆盖四大事务模式适配高并发、长事务、强一致、老旧系统各类场景生态无缝适配完美整合Nacos、Gateway、Sentinel、OpenFeign全套Spring Cloud Alibaba生态生产高可用支持DB/Redis/Raft事务持久化、TC集群部署杜绝单点故障工业级稳定经过阿里双十一亿级流量验证社区活跃、企业落地成熟。4.2 核心缺点AT模式存在经典问题存在空回滚、悬挂、重复执行风险需通过配置与机制规避强依赖TC节点TC服务故障会导致分布式事务无法正常执行需集群保障AT模式隔离性有限存在全局行锁竞争超高并发场景需针对性优化TCC/SAGA成本高需手动编写补偿逻辑开发与维护成本远高于AT模式。五、全套运行环境搭建服务端数据库配置本节搭建可直接生产使用的完整Seata运行环境包含Nacos依赖、Seata服务端部署、数据库初始化、服务端配置全程无遗漏。5.1 全套前置环境搭建Nacos基础环境从零落地本文所有实战内容无需任何前置环境本节手把手完成 Nacos 服务端搭建、初始化配置、环境校验搭配后续 Seata 部署实现整套分布式事务环境从零搭建、可直接用于开发与测试。5.1.1 基础软件版本规范统一落地版本为避免版本报错、兼容问题统一使用稳定生产版本与Spring Cloud Alibaba生态完美适配JDK17企业通用稳定版Maven3.6MySQL8.0支持undo_log大字段、事务日志存储Nacos2.5.2Seata2.0.05.1.2 Nacos服务端下载与启动Nacos作为注册中心配置中心是Seata服务注册、客户端联动的核心依赖必须优先搭建。1、下载安装包Nacos官网下载nacos-server-2.5.3.zip解压至纯英文无空格目录。下载路径https://github.com/alibaba/nacos/releases/tag/v2.5.32、启动Nacos单机模式必选禁止集群启动新手统一单机测试。Windows进入nacos/bin执行startup.cmd -m standaloneLinux/Mac执行sh startup.sh -m standalone3、访问控制台浏览器打开 http://localhost:8848/nacos默认账号密码nacos / nacos(提示密码错误可以查看控制台密码信息)5.1.3 Nacos环境校验关键落地步骤启动完成后必须校验避免后续Seata、微服务注册失败访问控制台正常登录无报错端口8848正常监听无端口占用冲突默认命名空间public存在Seata默认绑定此命名空间。5.1.4 Nacos核心配置适配Seata无需额外复杂配置保持默认即可核心适配规则关闭认证本地测试环境避免服务注册鉴权失败保留默认端口8848全文所有配置统一复用此端口事务分组、服务注册全部挂载public命名空间统一环境隔离。环境落地结论Nacos搭建完成后后续Seata服务端、订单服务、库存服务均可自动完成注册与发现实现分布式联动。也可以使用官网提供的一键安装脚本官网地址Nacos Server 下载 | Nacos 官网powershell -NoProfile -ExecutionPolicy Bypass -Command iwr -UseBasicParsing https://nacos.io/nacos-installer.ps1 | iex使用官网的一键安装脚本默认安装最新版本需要使用下列脚本设置为对应的版本不要使用上面的一键安装脚本nacos-setup -v 2.5.3安装完成之后启动方式与上述一致但是脚本安装的登录密码不是默认的nacos得修改conf/application.properties的配置信息# 开启鉴权 nacos.core.auth.enabledtrue nacos.core.auth.system.typenacos # 服务内部通信密钥必须成对填写自定义即可 nacos.core.auth.server.identity.keynacos nacos.core.auth.server.identity.valuenacos # JWT token密钥不要使用默认值复制下面这段 nacos.core.auth.plugin.nacos.token.secret.keyVGhpc0lzTXlDdXN0b21TZWNyZXRLZXkwMTIzNDU2Nzg # 【关键】预置管理员账号明文nacos自动BCrypt匹配 nacos.core.auth.default.usernamenacos nacos.core.auth.default.password$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuSwc2TlQxOqnJRtXG.O5.2 数据库初始化生产必备从零执行5.2 数据库初始化生产必备需要初始化服务端事务库和业务库回滚日志表两套SQL缺一不可。5.2.1 Seata服务端数据库seata_serverCREATE DATABASE IF NOT EXISTS seata_server DEFAULT CHARSET utf8mb4; USE seata_server; -- Seata服务端事务日志、分支、全局事务表 CREATE TABLE global_table ( xid VARCHAR(128) NOT NULL, transaction_id BIGINT, status TINYINT NOT NULL, application_id VARCHAR(32), transaction_group VARCHAR(32), transaction_name VARCHAR(128), timeout INT, begin_time BIGINT, begin_timestamp BIGINT, end_time BIGINT, end_timestamp BIGINT, server_addr VARCHAR(128), client_ip VARCHAR(128), retry INT, PRIMARY KEY (xid), KEY idx_status (status), KEY idx_transaction_id (transaction_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; CREATE TABLE branch_table ( xid VARCHAR(128) NOT NULL, branch_id BIGINT NOT NULL, transaction_id BIGINT, resource_group_id VARCHAR(32), resource_id VARCHAR(256), branch_type TINYINT, status TINYINT, client_ip VARCHAR(128), application_id VARCHAR(32), gmt_create DATETIME, gmt_modified DATETIME, PRIMARY KEY (xid,branch_id), KEY idx_status (status) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; CREATE TABLE lock_table ( row_key VARCHAR(128) NOT NULL, xid VARCHAR(128), transaction_id BIGINT, branch_id BIGINT, resource_id VARCHAR(256), table_name VARCHAR(32), pk VARCHAR(128), gmt_create DATETIME, gmt_modified DATETIME, PRIMARY KEY (row_key), KEY idx_xid (xid) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;5.2.2 业务库回滚日志表每个业务库都需执行CREATE TABLE IF NOT EXISTS undo_log ( id BIGINT NOT NULL AUTO_INCREMENT, branch_id BIGINT NOT NULL, xid VARCHAR(128) NOT NULL, context VARCHAR(128) NOT NULL, rollback_info LONGBLOB NOT NULL, log_status INT NOT NULL, log_created DATETIME NOT NULL, log_modified DATETIME NOT NULL, PRIMARY KEY (id), UNIQUE KEY ux_undo_log (xid,branch_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;5.3 Seata服务端完整部署与精细化配置从零落地·超详细本节为生产级完整版Seata服务端部署教程包含精准版本下载、目录结构说明、核心配置文件路径、全量参数配置、Nacos联动、DB持久化开启、启动校验所有步骤、文件路径、配置参数1:1可复刻解决新手配置报错、注册失败、事务不持久化等问题。5.3.1 版本选择与官方下载固定稳定版统一使用生产稳定版本Seata 2.6.0完美适配 Nacos2.5.3、Spring Cloud Alibaba 主流版本无兼容BUG。官方下载地址https://dlcdn.apache.org/incubator/seata/2.6.0/apache-seata-2.6.0-incubating-bin.tar.gz下载文件seata-server-2.0.0.zipWindows/Linux通用压缩包解压规范解压至纯英文、无空格、无中文目录示例D:\software\seata-2.6.05.3.2 Seata服务端核心目录结构说明解压后核心目录仅需关注以下路径所有配置、启动、日志均在此范围内seata-2.6.0/conf/【核心配置目录】存放所有服务端配置文件seata-2.6.0/conf/file.conf事务存储、数据源、超时核心配置seata-2.6.0/bin/启动脚本目录seata-2.6.0/logs/日志目录排查启动报错、事务异常专用5.3.3 第一核心配置application.yml注册配置中心文件绝对路径Seata根目录/conf/registry.conf作用配置Seata服务端注册到Nacos、从Nacos读取配置是客户端与服务端联动的核心配置错误直接导致服务注册失败、事务失效。完整可直接复制配置适配本地Nacosserver: port: 7091 spring: application: name: seata-server logging: config: classpath:logback-spring.xml file: path: ${log.home:${user.home}/logs/seata} extend: logstash-appender: destination: 127.0.0.1:4560 kafka-appender: bootstrap-servers: 127.0.0.1:9092 topic: logback_to_logstash console: user: # seata的登录账号 username: seata password: seata seata: config: # support: nacos, consul, apollo, zk, etcd3 type: nacos nacos: server-addr: 127.0.0.1:8848 group: SEATA_GROUP #nacos的登录账号 username: nacos password: nacos registry: # support: nacos, eureka, redis, zk, consul, etcd3, sofa type: nacos nacos: server-addr: 127.0.0.1:8848 group: SEATA_GROUP username: nacos password: nacos store: # support: file 、 db 、 redis 、 raft mode: db关键配置释义必须保证服务端、客户端namespace、cluster、serverAddr完全一致否则无法通信本地测试禁止修改自定义命名空间统一使用public。5.3.4 第二核心配置file.conf事务存储数据源文件绝对路径Seata根目录/conf/file.conf作用配置事务持久化模式、数据库连接、事务超时、锁机制生产必须改为DB模式默认内存模式重启丢失所有事务数据。完整可直接复制配置生产DB持久化模式# 事务存储模式file-文件 db-数据库 redis-缓存 store.modedb # 关闭异步存储保证事务可靠 store.async.discard-branch-logfalse # DB数据源配置对接前面创建的seata_server库 store.db.datasourcedruid store.db.db-typemysql # MySQL8.0固定驱动 store.db.driver-class-namecom.mysql.cj.jdbc.Driver # 数据库地址、库名、时区必须完整配置 store.db.urljdbc:mysql://127.0.0.1:3306/seata_server?useUnicodetruecharacterEncodingutf-8serverTimezoneGMT%2B8allowMultiQueriestrue # 你的数据库账号密码 store.db.userroot store.db.password123456 # 数据库连接池参数 store.db.min-conn5 store.db.max-conn100 store.db.max-wait3000 # 事务超时、重试配置 service.transaction-groupdefault_tx_group service.disable-global-transactionfalse service.default-timeout60000核心参数重点说明store.modedb开启数据库持久化生产唯一可用模式重启服务事务不丢失service.transaction-groupdefault_tx_group事务分组名称必须与客户端yml配置完全一致数据库URL必须携带serverTimezone否则MySQL8.0直接报错无法启动。5.3.5 环境前置校验启动前必做修改完配置后启动前必须校验以下3项规避90%启动报错MySQL中已创建seata_server数据库并执行完全局/分支/锁三张数据表SQLNacos已正常启动8848端口监听正常file.conf中数据库账号密码与本地MySQL完全一致、数据库可正常连接。5.3.6 Seata服务端启动步骤Windows/Linux双适配启动脚本路径Seata根目录/bin/Windows系统双击执行seata-server.batLinux/Mac系统终端执行sh seata-server.sh自定义启动参数可选默认端口7091如需修改可启动时指定# 指定端口、IP、集群启动 sh seata-server.sh -p 7091 -h 127.0.0.1 -m dbWindow系统下通过seata-server.bat启动的时候会报无web容器的问题需要在bat文件中在%JAVACMD%命令后面添加-Dspring.main.web-application-typeNONE再通过seata-server.bat 启动5.3.7 启动成功校验三步落地验证端口校验7091端口正常监听无端口占用报错日志校验logs目录无ERROR错误日志打印register to nacos successNacos控制台校验最核心进入Nacos服务管理-服务列表出现seata-server服务在线实例正常代表服务端部署Nacos联动完全成功。5.3.8 服务端默认核心参数汇总对接客户端必备Seata服务端口7091默认事务分组default_tx_group默认集群名称default默认命名空间public存储模式DB持久化生产模式六、微服务客户端完整实战代码搭建订单服务库存服务双服务测试场景通过OpenFeign远程调用实现跨服务分布式事务一致性。6.1 项目核心依赖所有参与事务服务引入!--使用最新的seata引入方式旧版的alibaba已经不维护 -- dependency groupIdorg.apache.seata/groupId artifactIdseata-spring-boot-starter/artifactId version2.6.0/version /dependency !-- Nacos注册中心 -- dependency groupIdcom.alibaba.cloud/groupId artifactIdspring-cloud-starter-alibaba-nacos-discovery/artifactId version2025.0.0.0/version /dependency !-- OpenFeign远程调用 -- dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-openfeign/artifactId version2025.0.0/version /dependency !-- Web核心依赖 -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency6.2 客户端统一配置application.yml6.2 客户端统一配置application.ymlNacosSeata联动完整版该配置为生产级动态多数据源适配Seata完整配置彻底替代原生单数据源支持多数据源切换、自动代理数据源、自动生成undo_log回滚日志兼容Seata AT模式无需手动改造代码仅修改服务名、数据源信息即可直接落地。spring: application: name: service-order # 动态多数据源配置dynamic-datasource 核心 datasource: dynamic: primary: master # 默认主库 strict: true # 严格模式找不到数据源直接抛异常 atomikos: enabled: false # ✅开启Atomikos XA分布式事务 unique-resource-name-prefix: db- local-transaction-mode: false # ❗必须false开启XA全局事务 datasource: master: url: jdbc:mysql://172.17.0.1:3306/db_name?useUnicodetruecharacterEncodingutf-8zeroDateTimeBehaviorconvertToNulltransformedBitIsBooleantrueallowMultiQueriestrueuseSSLfalseserverTimezoneAsia/Shanghai username: root password: 你的数据库密码 driver-class-name: com.mysql.cj.jdbc.Driver cloud: nacos: discovery: server-addr: 127.0.0.1:8848 enabled: true # 本机开发推荐开启自动使用本机IP注册 prefer-ip-address: true # 新增 nacos登录账号密码 username: nacos password: nacos config: server-addr: 127.0.0.1:8848 enabled: false # 暂时不用nacos配置中心关闭避免额外连接报错 # 新增 nacos登录账号密码 username: nacos password: nacos seata: enabled: true #使用对应配套的dynamic建议开启自动代理手动创建datasource会有循环嵌套引用问题 enable-auto-data-source-proxy: true application-id: ${spring.application.name} tx-service-group: default_tx_group service: vgroupMapping: default_tx_group: default registry: type: nacos nacos: server-addr: 127.0.0.1:8848 username: nacos password: nacos namespace: public #与seata服务注册时填写的nacos注册服务要一致要不然会因为找不到对应服务导致启动失败 group: SEATA_GROUP # ⚠️ 重点全部注释config节点不要开启seata config nacos 使用注册方式就不用使用config要不然会因为双重启动方式导致系统配置读取异常启动失效 # config: # type: nacos # nacos: # server-addr: 127.0.0.1:8848 # username: nacos # password: nacos核心适配说明动态数据源专属enable-auto-data-source-proxy: trueSeata自动拦截 dynamic-datasource 所有数据源SQL自动生成undo_log回滚日志无需手动注入数据源多数据源场景下所有数据源自动纳入Seata分布式事务管控跨数据源、跨服务事务均可保证原子性保留dynamic-datasource原生所有特性数据源切换、读写分离、多库隔离同时兼容Seata AT事务每个业务数据库仍需提前执行undo_log回滚日志表SQL保证回滚正常生效。6.3 启动类配置使用dynamic-datasource必须排除原生数据源自动配置防止与动态数据源冲突启动类完整配置如下import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; // 排除原生DataSource自动配置适配dynamic-datasource SpringBootApplication(exclude DataSourceAutoConfiguration.class) EnableDiscoveryClient EnableFeignClients(basePackages com.cfm.micro_common.foreign) MapperScan(com.cfm.micro_order.mapper) public class SeataOrderApplication { public static void main(String[] args) { SpringApplication.run(SeataOrderApplication.class, args); } }6.4 库存服务接口被调用方import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; RestController public class StockController { // 扣减库存接口 GetMapping(/stock/deduct) public String deductStock(){ // 模拟库存扣减业务 System.out.println(库存扣减成功); return 库存扣减成功; } }6.5 Feign远程调用接口import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; FeignClient(seata-stock-service) public interface StockFeignClient { GetMapping(/stock/deduct) String deductStock(); }6.6 订单服务事务核心业务全局事务注解import io.seata.spring.annotation.GlobalTransactional; import org.springframework.stereotype.Service; import javax.annotation.Resource; Service public class OrderService { Resource private StockFeignClient stockFeignClient; // 开启全局分布式事务捕获所有异常触发全局回滚 GlobalTransactional(rollbackFor Exception.class) public void createOrder(){ // 1. 模拟创建订单业务 System.out.println(订单创建成功); // 2. 远程调用库存服务扣减库存 stockFeignClient.deductStock(); // 3. 模拟业务异常触发分布式事务回滚 int num 1 / 0; } }6.7 测试接口Controllerimport org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; RestController public class OrderController { Resource private OrderService orderService; GetMapping(/order/create) public String createOrder(){ orderService.createOrder(); return 下单成功; } }以上只是抽取核心流程的伪代码具体的实现方式需要自己根据要求去实现七、全套步骤化测试流程可直接复刻严格按照以下步骤测试完整验证分布式事务成功提交和异常回滚两大核心场景。7.1 测试前置准备启动本地MySQL提前创建业务库并执行上文undo_log回滚日志表SQL启动Nacos服务8848控制台确认服务正常运行启动Seata服务端Nacos服务列表确认seata-server注册成功启动seata-stock-service库存服务、seata-order-service订单服务Nacos服务列表校验两个微服务注册成功无异常报错环境就绪。7.2 场景一事务异常全局回滚核心测试保持代码中int num 1 / 0;异常代码不注释浏览器/Postman访问接口http://localhost:端口/order/create观察控制台订单创建、库存扣减执行完成后抛出异常Seata感知异常触发全局事务回滚undo_log日志自动生成并清理结果验证所有分支业务全部回滚无脏数据事务保持原子性。7.3 场景二事务正常全局提交注释掉模拟异常代码// int num 1 / 0;重新访问测试接口所有业务正常执行无异常Seata全局事务提交异步清理undo_log日志结果验证订单、库存业务全部生效事务执行成功。八、Seata 生产核心问题与解决方案8.1 AT模式三大经典问题及规避方案空回滚分支事务未执行业务但收到TC回滚指令解决方案通过分支状态校验、本地事务锁拦截空回滚Seata新版已默认优化悬挂二阶段回滚请求先于一阶段业务执行解决方案事务超时控制、请求时序校验杜绝悬挂问题幂等性防止重复提交、重复回滚解决方案Seata原生支持分支事务幂等校验自动过滤重复请求。8.2 生产最佳实践Seata服务端必须开启DB持久化集群部署彻底杜绝TC单点故障全局事务注解统一使用GlobalTransactional(rollbackFor Exception.class)捕获所有异常纯查询、只读接口禁止添加全局事务减少锁竞争、提升集群吞吐量合理配置事务超时时间避免长事务占用数据库锁引发业务阻塞对接日志监控与告警实时监控事务失败、回滚、超时异常快速排查数据不一致问题。九、Seata 适用场景微服务跨库事务场景下单、支付、库存、积分、账户联动业务保障数据强一致性电商高并发场景秒杀、大促、限时活动依托AT模式高性能特性支撑海量并发事务金融支付场景资金流转、账单记录、账户变动杜绝资损与脏数据长链路异步场景订单履约、流程审批、超时关闭使用SAGA模式适配长事务老旧系统改造场景兼容XA模式、自定义TCC补偿适配传统项目微服务改造。十、全文总结1. Seata 是微服务架构下分布式事务唯一通用、高性能、低侵入的标准化解决方案彻底解决微服务拆分后的跨服务、跨库数据一致性难题。2. 核心架构由 TC协调器、TM事务发起者、RM资源执行者组成通过两阶段提交机制在保证高性能的同时实现事务原子性。3.AT模式是90%生产场景的首选零业务侵入、性能优异TCC、SAGA、XA分别适配特殊复杂、长事务、老旧系统兼容场景。4. 本文提供全套可复刻运行环境包含服务端部署、数据库脚本、客户端完整代码、步骤化测试流程可直接落地到企业微服务项目完美适配Spring Cloud Alibaba全家桶技术体系。
seata 零基础入门实战
发布时间：2026/7/26 23:58:22
前言微服务架构最大的数据一致性难题就是分布式事务。单体项目中我们依靠Transactional即可保证数据库事务原子性要么全部成功、要么全部回滚。但微服务拆分后一次业务操作会跨多个服务、多个数据库本地事务彻底失效极易出现部分成功、部分失败、数据脏写、数据不一致问题引发资损、业务异常。Seata是阿里开源、Apache 顶级开源的一站式高性能分布式事务解决方案彻底解决微服务跨库、跨服务事务一致性问题是 Spring Cloud Alibaba 体系中解决分布式事务的行业标准组件。本文从零搭建全套运行环境包含Seata服务端部署、Nacos联动配置、客户端完整代码、步骤化测试、原理详解、优缺点、生产实践与适用场景全程可直接复刻运行风格统一适配微服务全家桶系列博客。一、Seata 技术背景与发展历程1.1 为什么必须用分布式事务微服务拆分后业务链路被拆解为多个独立服务每个服务独立数据库本地事务无法跨服务生效。经典电商下单场景创建订单(订单服务) → 扣减库存(库存服务) → 扣减余额(账户服务)。若前两个服务执行成功最后扣减余额异常会出现订单生成、库存减少、用户余额未扣的数据不一致问题直接造成平台资损、脏数据堆积是生产环境绝对无法容忍的问题。1.2 传统分布式事务方案缺陷在Seata出现之前行业主流分布式事务方案均存在明显短板无法适配微服务高并发、低侵入、易维护的核心需求原生XA2PC强一致性但性能极差、长事务阻塞数据库完全不适合高并发微服务场景手写TCC补偿代码侵入极高、开发成本巨大每个业务需单独实现Try/Confirm/Cancel无通用性本地消息表业务与事务逻辑强耦合需维护额外消息表状态机复杂最终一致性保障弱RabbitMQ可靠消息强依赖MQ中间件、事务延迟高仅适配非实时最终一致场景无法满足金融、交易类强一致需求。1.3 Seata 发展与核心定位Seata 源自阿里双十一高并发分布式事务实战打磨专为微服务架构设计核心目标低侵入、高性能、易落地、多场景适配。目前支持 AT、TCC、SAGA、XA 四大事务模式全覆盖高并发、长事务、强一致、老旧系统兼容场景是国内微服务分布式事务唯一主流标准化解决方案无缝适配Spring Cloud Alibaba全套生态。二、Seata 核心架构与三大核心角色Seata 采用经典的协调器客户端架构整体由 TC、TM、RM 三大核心组件协同工作所有分布式事务的开启、注册、提交、回滚均由三者联动完成。2.1 TCTransaction Coordinator 事务协调器独立部署的Seata Server服务端是全局事务的调度中枢与核心管控节点全局唯一。核心职责统一维护全局事务、分支事务的状态、生命周期接收TM的全局事务开启、提交、回滚指令调度所有RM分支事务实现统一提交或统一回滚支持事务日志持久化、集群高可用、故障恢复保障事务可靠性。2.2 TMTransaction Manager 事务管理器嵌入在业务发起方微服务中的客户端组件是全局事务的创建者与终结者。核心职责向TC申请开启全局事务生成全局唯一事务IDXID业务链路执行完毕后根据执行结果通知TC全局提交或全局回滚。2.3 RMResource Manager 资源管理器嵌入在所有参与分布式事务的微服务中是分支事务的实际执行者。核心职责向TC注册本地分支事务关联全局XID拦截业务SQL记录事务快照与回滚日志接收TC调度指令执行分支事务提交或回滚操作。2.4 完整事务调用链路TM开启全局事务生成XID → 所有微服务RM注册分支事务 → 各服务执行业务SQL → 全部成功则TC调度全局提交 / 任意分支异常则TC调度全局回滚三、Seata 四大事务模式详解核心重点3.1 AT 模式Auto Transaction 自动事务·生产首选定位Seata默认模式、零业务侵入、性能接近本地事务、适配90%以上微服务高并发场景企业落地主流方案。3.1.1 两阶段核心原理第一阶段执行阶段RM自动拦截业务SQL解析数据库数据前后镜像生成并写入undo_log回滚日志执行本地业务SQL并提交本地事务同时占用全局行锁无需阻塞等待。第二阶段决议阶段根据全局事务结果执行不同逻辑全局成功TC下发提交指令RM异步清理undo_log日志、释放全局锁性能极高全局失败TC下发回滚指令RM解析undo_log镜像反向生成回滚SQL精准恢复事务前数据状态杜绝脏数据。核心特点业务零改造、无需手动补偿、无人工代码侵入、高并发友好、隔离性可控。3.2 TCC 模式手动补偿模式定位高自定义、强可控、适配非数据库事务、复杂特殊业务场景。需开发者手动实现三段式接口完全脱离数据库本地事务纯代码实现事务补偿Try资源校验/锁定检查业务资源、锁定资源完成预执行业务Confirm确认提交全局事务成功确认执行业务、释放锁定资源Cancel回滚补偿全局事务失败撤销Try操作、释放资源、数据回滚。优缺点可控性最强、适配特殊场景代码侵入极高、开发维护成本大。3.3 SAGA 模式长事务模式定位适配长耗时、长链路、异步化事务场景无锁、最终一致性。核心原理为每一个正向业务接口配置对应的反向补偿接口事务链路执行异常时逆向依次执行补偿逻辑回滚整条链路数据适用于订单履约、流程审批、超时关闭等长事务场景。3.4 XA 模式原生强一致模式定位兼容数据库原生XA二阶段协议强一致性、无脏数据。核心缺陷事务全程阻塞、数据库锁持有时间长、性能极低完全不适合高并发微服务仅用于老旧传统项目兼容改造。四、Seata 优缺点全面总结4.1 核心优点极低业务侵入AT模式仅需一行全局事务注解无需改动核心业务代码高性能高并发一阶段本地事务立即提交二阶段异步清理性能无限接近本地事务全场景覆盖四大事务模式适配高并发、长事务、强一致、老旧系统各类场景生态无缝适配完美整合Nacos、Gateway、Sentinel、OpenFeign全套Spring Cloud Alibaba生态生产高可用支持DB/Redis/Raft事务持久化、TC集群部署杜绝单点故障工业级稳定经过阿里双十一亿级流量验证社区活跃、企业落地成熟。4.2 核心缺点AT模式存在经典问题存在空回滚、悬挂、重复执行风险需通过配置与机制规避强依赖TC节点TC服务故障会导致分布式事务无法正常执行需集群保障AT模式隔离性有限存在全局行锁竞争超高并发场景需针对性优化TCC/SAGA成本高需手动编写补偿逻辑开发与维护成本远高于AT模式。五、全套运行环境搭建服务端数据库配置本节搭建可直接生产使用的完整Seata运行环境包含Nacos依赖、Seata服务端部署、数据库初始化、服务端配置全程无遗漏。5.1 全套前置环境搭建Nacos基础环境从零落地本文所有实战内容无需任何前置环境本节手把手完成 Nacos 服务端搭建、初始化配置、环境校验搭配后续 Seata 部署实现整套分布式事务环境从零搭建、可直接用于开发与测试。5.1.1 基础软件版本规范统一落地版本为避免版本报错、兼容问题统一使用稳定生产版本与Spring Cloud Alibaba生态完美适配JDK17企业通用稳定版Maven3.6MySQL8.0支持undo_log大字段、事务日志存储Nacos2.5.2Seata2.0.05.1.2 Nacos服务端下载与启动Nacos作为注册中心配置中心是Seata服务注册、客户端联动的核心依赖必须优先搭建。1、下载安装包Nacos官网下载nacos-server-2.5.3.zip解压至纯英文无空格目录。下载路径https://github.com/alibaba/nacos/releases/tag/v2.5.32、启动Nacos单机模式必选禁止集群启动新手统一单机测试。Windows进入nacos/bin执行startup.cmd -m standaloneLinux/Mac执行sh startup.sh -m standalone3、访问控制台浏览器打开 http://localhost:8848/nacos默认账号密码nacos / nacos(提示密码错误可以查看控制台密码信息)5.1.3 Nacos环境校验关键落地步骤启动完成后必须校验避免后续Seata、微服务注册失败访问控制台正常登录无报错端口8848正常监听无端口占用冲突默认命名空间public存在Seata默认绑定此命名空间。5.1.4 Nacos核心配置适配Seata无需额外复杂配置保持默认即可核心适配规则关闭认证本地测试环境避免服务注册鉴权失败保留默认端口8848全文所有配置统一复用此端口事务分组、服务注册全部挂载public命名空间统一环境隔离。环境落地结论Nacos搭建完成后后续Seata服务端、订单服务、库存服务均可自动完成注册与发现实现分布式联动。也可以使用官网提供的一键安装脚本官网地址Nacos Server 下载 | Nacos 官网powershell -NoProfile -ExecutionPolicy Bypass -Command iwr -UseBasicParsing https://nacos.io/nacos-installer.ps1 | iex使用官网的一键安装脚本默认安装最新版本需要使用下列脚本设置为对应的版本不要使用上面的一键安装脚本nacos-setup -v 2.5.3安装完成之后启动方式与上述一致但是脚本安装的登录密码不是默认的nacos得修改conf/application.properties的配置信息# 开启鉴权 nacos.core.auth.enabledtrue nacos.core.auth.system.typenacos # 服务内部通信密钥必须成对填写自定义即可 nacos.core.auth.server.identity.keynacos nacos.core.auth.server.identity.valuenacos # JWT token密钥不要使用默认值复制下面这段 nacos.core.auth.plugin.nacos.token.secret.keyVGhpc0lzTXlDdXN0b21TZWNyZXRLZXkwMTIzNDU2Nzg # 【关键】预置管理员账号明文nacos自动BCrypt匹配 nacos.core.auth.default.usernamenacos nacos.core.auth.default.password$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuSwc2TlQxOqnJRtXG.O5.2 数据库初始化生产必备从零执行5.2 数据库初始化生产必备需要初始化服务端事务库和业务库回滚日志表两套SQL缺一不可。5.2.1 Seata服务端数据库seata_serverCREATE DATABASE IF NOT EXISTS seata_server DEFAULT CHARSET utf8mb4; USE seata_server; -- Seata服务端事务日志、分支、全局事务表 CREATE TABLE global_table ( xid VARCHAR(128) NOT NULL, transaction_id BIGINT, status TINYINT NOT NULL, application_id VARCHAR(32), transaction_group VARCHAR(32), transaction_name VARCHAR(128), timeout INT, begin_time BIGINT, begin_timestamp BIGINT, end_time BIGINT, end_timestamp BIGINT, server_addr VARCHAR(128), client_ip VARCHAR(128), retry INT, PRIMARY KEY (xid), KEY idx_status (status), KEY idx_transaction_id (transaction_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; CREATE TABLE branch_table ( xid VARCHAR(128) NOT NULL, branch_id BIGINT NOT NULL, transaction_id BIGINT, resource_group_id VARCHAR(32), resource_id VARCHAR(256), branch_type TINYINT, status TINYINT, client_ip VARCHAR(128), application_id VARCHAR(32), gmt_create DATETIME, gmt_modified DATETIME, PRIMARY KEY (xid,branch_id), KEY idx_status (status) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; CREATE TABLE lock_table ( row_key VARCHAR(128) NOT NULL, xid VARCHAR(128), transaction_id BIGINT, branch_id BIGINT, resource_id VARCHAR(256), table_name VARCHAR(32), pk VARCHAR(128), gmt_create DATETIME, gmt_modified DATETIME, PRIMARY KEY (row_key), KEY idx_xid (xid) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;5.2.2 业务库回滚日志表每个业务库都需执行CREATE TABLE IF NOT EXISTS undo_log ( id BIGINT NOT NULL AUTO_INCREMENT, branch_id BIGINT NOT NULL, xid VARCHAR(128) NOT NULL, context VARCHAR(128) NOT NULL, rollback_info LONGBLOB NOT NULL, log_status INT NOT NULL, log_created DATETIME NOT NULL, log_modified DATETIME NOT NULL, PRIMARY KEY (id), UNIQUE KEY ux_undo_log (xid,branch_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;5.3 Seata服务端完整部署与精细化配置从零落地·超详细本节为生产级完整版Seata服务端部署教程包含精准版本下载、目录结构说明、核心配置文件路径、全量参数配置、Nacos联动、DB持久化开启、启动校验所有步骤、文件路径、配置参数1:1可复刻解决新手配置报错、注册失败、事务不持久化等问题。5.3.1 版本选择与官方下载固定稳定版统一使用生产稳定版本Seata 2.6.0完美适配 Nacos2.5.3、Spring Cloud Alibaba 主流版本无兼容BUG。官方下载地址https://dlcdn.apache.org/incubator/seata/2.6.0/apache-seata-2.6.0-incubating-bin.tar.gz下载文件seata-server-2.0.0.zipWindows/Linux通用压缩包解压规范解压至纯英文、无空格、无中文目录示例D:\software\seata-2.6.05.3.2 Seata服务端核心目录结构说明解压后核心目录仅需关注以下路径所有配置、启动、日志均在此范围内seata-2.6.0/conf/【核心配置目录】存放所有服务端配置文件seata-2.6.0/conf/file.conf事务存储、数据源、超时核心配置seata-2.6.0/bin/启动脚本目录seata-2.6.0/logs/日志目录排查启动报错、事务异常专用5.3.3 第一核心配置application.yml注册配置中心文件绝对路径Seata根目录/conf/registry.conf作用配置Seata服务端注册到Nacos、从Nacos读取配置是客户端与服务端联动的核心配置错误直接导致服务注册失败、事务失效。完整可直接复制配置适配本地Nacosserver: port: 7091 spring: application: name: seata-server logging: config: classpath:logback-spring.xml file: path: ${log.home:${user.home}/logs/seata} extend: logstash-appender: destination: 127.0.0.1:4560 kafka-appender: bootstrap-servers: 127.0.0.1:9092 topic: logback_to_logstash console: user: # seata的登录账号 username: seata password: seata seata: config: # support: nacos, consul, apollo, zk, etcd3 type: nacos nacos: server-addr: 127.0.0.1:8848 group: SEATA_GROUP #nacos的登录账号 username: nacos password: nacos registry: # support: nacos, eureka, redis, zk, consul, etcd3, sofa type: nacos nacos: server-addr: 127.0.0.1:8848 group: SEATA_GROUP username: nacos password: nacos store: # support: file 、 db 、 redis 、 raft mode: db关键配置释义必须保证服务端、客户端namespace、cluster、serverAddr完全一致否则无法通信本地测试禁止修改自定义命名空间统一使用public。5.3.4 第二核心配置file.conf事务存储数据源文件绝对路径Seata根目录/conf/file.conf作用配置事务持久化模式、数据库连接、事务超时、锁机制生产必须改为DB模式默认内存模式重启丢失所有事务数据。完整可直接复制配置生产DB持久化模式# 事务存储模式file-文件 db-数据库 redis-缓存 store.modedb # 关闭异步存储保证事务可靠 store.async.discard-branch-logfalse # DB数据源配置对接前面创建的seata_server库 store.db.datasourcedruid store.db.db-typemysql # MySQL8.0固定驱动 store.db.driver-class-namecom.mysql.cj.jdbc.Driver # 数据库地址、库名、时区必须完整配置 store.db.urljdbc:mysql://127.0.0.1:3306/seata_server?useUnicodetruecharacterEncodingutf-8serverTimezoneGMT%2B8allowMultiQueriestrue # 你的数据库账号密码 store.db.userroot store.db.password123456 # 数据库连接池参数 store.db.min-conn5 store.db.max-conn100 store.db.max-wait3000 # 事务超时、重试配置 service.transaction-groupdefault_tx_group service.disable-global-transactionfalse service.default-timeout60000核心参数重点说明store.modedb开启数据库持久化生产唯一可用模式重启服务事务不丢失service.transaction-groupdefault_tx_group事务分组名称必须与客户端yml配置完全一致数据库URL必须携带serverTimezone否则MySQL8.0直接报错无法启动。5.3.5 环境前置校验启动前必做修改完配置后启动前必须校验以下3项规避90%启动报错MySQL中已创建seata_server数据库并执行完全局/分支/锁三张数据表SQLNacos已正常启动8848端口监听正常file.conf中数据库账号密码与本地MySQL完全一致、数据库可正常连接。5.3.6 Seata服务端启动步骤Windows/Linux双适配启动脚本路径Seata根目录/bin/Windows系统双击执行seata-server.batLinux/Mac系统终端执行sh seata-server.sh自定义启动参数可选默认端口7091如需修改可启动时指定# 指定端口、IP、集群启动 sh seata-server.sh -p 7091 -h 127.0.0.1 -m dbWindow系统下通过seata-server.bat启动的时候会报无web容器的问题需要在bat文件中在%JAVACMD%命令后面添加-Dspring.main.web-application-typeNONE再通过seata-server.bat 启动5.3.7 启动成功校验三步落地验证端口校验7091端口正常监听无端口占用报错日志校验logs目录无ERROR错误日志打印register to nacos successNacos控制台校验最核心进入Nacos服务管理-服务列表出现seata-server服务在线实例正常代表服务端部署Nacos联动完全成功。5.3.8 服务端默认核心参数汇总对接客户端必备Seata服务端口7091默认事务分组default_tx_group默认集群名称default默认命名空间public存储模式DB持久化生产模式六、微服务客户端完整实战代码搭建订单服务库存服务双服务测试场景通过OpenFeign远程调用实现跨服务分布式事务一致性。6.1 项目核心依赖所有参与事务服务引入!--使用最新的seata引入方式旧版的alibaba已经不维护 -- dependency groupIdorg.apache.seata/groupId artifactIdseata-spring-boot-starter/artifactId version2.6.0/version /dependency !-- Nacos注册中心 -- dependency groupIdcom.alibaba.cloud/groupId artifactIdspring-cloud-starter-alibaba-nacos-discovery/artifactId version2025.0.0.0/version /dependency !-- OpenFeign远程调用 -- dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-openfeign/artifactId version2025.0.0/version /dependency !-- Web核心依赖 -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency6.2 客户端统一配置application.yml6.2 客户端统一配置application.ymlNacosSeata联动完整版该配置为生产级动态多数据源适配Seata完整配置彻底替代原生单数据源支持多数据源切换、自动代理数据源、自动生成undo_log回滚日志兼容Seata AT模式无需手动改造代码仅修改服务名、数据源信息即可直接落地。spring: application: name: service-order # 动态多数据源配置dynamic-datasource 核心 datasource: dynamic: primary: master # 默认主库 strict: true # 严格模式找不到数据源直接抛异常 atomikos: enabled: false # ✅开启Atomikos XA分布式事务 unique-resource-name-prefix: db- local-transaction-mode: false # ❗必须false开启XA全局事务 datasource: master: url: jdbc:mysql://172.17.0.1:3306/db_name?useUnicodetruecharacterEncodingutf-8zeroDateTimeBehaviorconvertToNulltransformedBitIsBooleantrueallowMultiQueriestrueuseSSLfalseserverTimezoneAsia/Shanghai username: root password: 你的数据库密码 driver-class-name: com.mysql.cj.jdbc.Driver cloud: nacos: discovery: server-addr: 127.0.0.1:8848 enabled: true # 本机开发推荐开启自动使用本机IP注册 prefer-ip-address: true # 新增 nacos登录账号密码 username: nacos password: nacos config: server-addr: 127.0.0.1:8848 enabled: false # 暂时不用nacos配置中心关闭避免额外连接报错 # 新增 nacos登录账号密码 username: nacos password: nacos seata: enabled: true #使用对应配套的dynamic建议开启自动代理手动创建datasource会有循环嵌套引用问题 enable-auto-data-source-proxy: true application-id: ${spring.application.name} tx-service-group: default_tx_group service: vgroupMapping: default_tx_group: default registry: type: nacos nacos: server-addr: 127.0.0.1:8848 username: nacos password: nacos namespace: public #与seata服务注册时填写的nacos注册服务要一致要不然会因为找不到对应服务导致启动失败 group: SEATA_GROUP # ⚠️ 重点全部注释config节点不要开启seata config nacos 使用注册方式就不用使用config要不然会因为双重启动方式导致系统配置读取异常启动失效 # config: # type: nacos # nacos: # server-addr: 127.0.0.1:8848 # username: nacos # password: nacos核心适配说明动态数据源专属enable-auto-data-source-proxy: trueSeata自动拦截 dynamic-datasource 所有数据源SQL自动生成undo_log回滚日志无需手动注入数据源多数据源场景下所有数据源自动纳入Seata分布式事务管控跨数据源、跨服务事务均可保证原子性保留dynamic-datasource原生所有特性数据源切换、读写分离、多库隔离同时兼容Seata AT事务每个业务数据库仍需提前执行undo_log回滚日志表SQL保证回滚正常生效。6.3 启动类配置使用dynamic-datasource必须排除原生数据源自动配置防止与动态数据源冲突启动类完整配置如下import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; // 排除原生DataSource自动配置适配dynamic-datasource SpringBootApplication(exclude DataSourceAutoConfiguration.class) EnableDiscoveryClient EnableFeignClients(basePackages com.cfm.micro_common.foreign) MapperScan(com.cfm.micro_order.mapper) public class SeataOrderApplication { public static void main(String[] args) { SpringApplication.run(SeataOrderApplication.class, args); } }6.4 库存服务接口被调用方import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; RestController public class StockController { // 扣减库存接口 GetMapping(/stock/deduct) public String deductStock(){ // 模拟库存扣减业务 System.out.println(库存扣减成功); return 库存扣减成功; } }6.5 Feign远程调用接口import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; FeignClient(seata-stock-service) public interface StockFeignClient { GetMapping(/stock/deduct) String deductStock(); }6.6 订单服务事务核心业务全局事务注解import io.seata.spring.annotation.GlobalTransactional; import org.springframework.stereotype.Service; import javax.annotation.Resource; Service public class OrderService { Resource private StockFeignClient stockFeignClient; // 开启全局分布式事务捕获所有异常触发全局回滚 GlobalTransactional(rollbackFor Exception.class) public void createOrder(){ // 1. 模拟创建订单业务 System.out.println(订单创建成功); // 2. 远程调用库存服务扣减库存 stockFeignClient.deductStock(); // 3. 模拟业务异常触发分布式事务回滚 int num 1 / 0; } }6.7 测试接口Controllerimport org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; RestController public class OrderController { Resource private OrderService orderService; GetMapping(/order/create) public String createOrder(){ orderService.createOrder(); return 下单成功; } }以上只是抽取核心流程的伪代码具体的实现方式需要自己根据要求去实现七、全套步骤化测试流程可直接复刻严格按照以下步骤测试完整验证分布式事务成功提交和异常回滚两大核心场景。7.1 测试前置准备启动本地MySQL提前创建业务库并执行上文undo_log回滚日志表SQL启动Nacos服务8848控制台确认服务正常运行启动Seata服务端Nacos服务列表确认seata-server注册成功启动seata-stock-service库存服务、seata-order-service订单服务Nacos服务列表校验两个微服务注册成功无异常报错环境就绪。7.2 场景一事务异常全局回滚核心测试保持代码中int num 1 / 0;异常代码不注释浏览器/Postman访问接口http://localhost:端口/order/create观察控制台订单创建、库存扣减执行完成后抛出异常Seata感知异常触发全局事务回滚undo_log日志自动生成并清理结果验证所有分支业务全部回滚无脏数据事务保持原子性。7.3 场景二事务正常全局提交注释掉模拟异常代码// int num 1 / 0;重新访问测试接口所有业务正常执行无异常Seata全局事务提交异步清理undo_log日志结果验证订单、库存业务全部生效事务执行成功。八、Seata 生产核心问题与解决方案8.1 AT模式三大经典问题及规避方案空回滚分支事务未执行业务但收到TC回滚指令解决方案通过分支状态校验、本地事务锁拦截空回滚Seata新版已默认优化悬挂二阶段回滚请求先于一阶段业务执行解决方案事务超时控制、请求时序校验杜绝悬挂问题幂等性防止重复提交、重复回滚解决方案Seata原生支持分支事务幂等校验自动过滤重复请求。8.2 生产最佳实践Seata服务端必须开启DB持久化集群部署彻底杜绝TC单点故障全局事务注解统一使用GlobalTransactional(rollbackFor Exception.class)捕获所有异常纯查询、只读接口禁止添加全局事务减少锁竞争、提升集群吞吐量合理配置事务超时时间避免长事务占用数据库锁引发业务阻塞对接日志监控与告警实时监控事务失败、回滚、超时异常快速排查数据不一致问题。九、Seata 适用场景微服务跨库事务场景下单、支付、库存、积分、账户联动业务保障数据强一致性电商高并发场景秒杀、大促、限时活动依托AT模式高性能特性支撑海量并发事务金融支付场景资金流转、账单记录、账户变动杜绝资损与脏数据长链路异步场景订单履约、流程审批、超时关闭使用SAGA模式适配长事务老旧系统改造场景兼容XA模式、自定义TCC补偿适配传统项目微服务改造。十、全文总结1. Seata 是微服务架构下分布式事务唯一通用、高性能、低侵入的标准化解决方案彻底解决微服务拆分后的跨服务、跨库数据一致性难题。2. 核心架构由 TC协调器、TM事务发起者、RM资源执行者组成通过两阶段提交机制在保证高性能的同时实现事务原子性。3.AT模式是90%生产场景的首选零业务侵入、性能优异TCC、SAGA、XA分别适配特殊复杂、长事务、老旧系统兼容场景。4. 本文提供全套可复刻运行环境包含服务端部署、数据库脚本、客户端完整代码、步骤化测试流程可直接落地到企业微服务项目完美适配Spring Cloud Alibaba全家桶技术体系。
在电商数据中台的应用实践)
