Spring Cloud Alibaba Seata安装+微服务实战
目录
- 介绍
- 核心功能
- 三层核心架构
- 安装
- 微服务实战
- 创建三个业务数据库
- 编写库存和账户两个Feign接口
- 订单微服务 seata-order-service9701
- 库存微服务 seata-store-service9702
- 账户微服务 seata-account-service9703
- 测试结果
- 总结
介绍
Spring Cloud Alibaba Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 为用户提供了AT(自动事务)、TCC(补偿事务)、SAGA(长事务) 和 XA(强一致性) 四种事务模式，为用户打造一站式的分布式解决方案。
核心功能
1. 分布式事务支持
- AT 模式： 基于 SQL 解析自动生成回滚日志，适合高频事务场景(如订单支付)。
- TCC 模式： 通过 Try-Confirm-Cancel 三阶段操作实现灵活控制，适合金融等强一致性场景。
- SAGA 模式： 通过编排长流程事务，支持跨系统长时间运行的任务(如物流跟踪)。
- XA 模式： 依赖数据库的 XA 协议，提供强一致性保障。
2. 高可用与可扩展性
- 支持多节点部署，通过注册中心 (如 Nacos) 动态管理服务实例。
- 提供灵活的配置方式，支持文件、数据库、Nacos 等多种配置源。
三层核心架构
1. TC(Transaction Coordinator，事务协调器)
- 独立部署的服务端，负责全局事务的协调、提交和回滚。
- 通过状态机维护事务生命周期，确保跨服务一致性。
2. TM(Transaction Manager，事务管理器)
- 嵌入在客户端应用中，负责开启、提交或回滚全局事务。
- 通过注解 (如 @GlobalTransactional) 标记需要分布式事务的方法。
3. RM(Resource Manager，资源管理器)
- 管理本地事务，与 TC 交互注册分支事务并上报状态。
- 支持主流数据库 (MySQL、Oracle 等) 和缓存 (Redis)。
安装
1. 官网下载
下载地址：Seate 下载
2. mysql8数据库中建库建表
创建seata库
CREATE DATABASE seata;
USE seata;
在seata数据库中建表，当seata的存储模式为db时才需要以下的建表操作。
建表脚本地址：建表脚本
-- -------------------------------- 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_status_gmt_modified` (`status` , `gmt_modified`),KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;-- 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 = InnoDBDEFAULT CHARSET = utf8mb4;-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(`row_key` VARCHAR(128) NOT NULL,`xid` VARCHAR(128),`transaction_id` BIGINT,`branch_id` BIGINT NOT NULL,`resource_id` VARCHAR(256),`table_name` VARCHAR(32),`pk` VARCHAR(36),`status` TINYINT NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',`gmt_create` DATETIME,`gmt_modified` DATETIME,PRIMARY KEY (`row_key`),KEY `idx_status` (`status`),KEY `idx_branch_id` (`branch_id`),KEY `idx_xid` (`xid`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;CREATE TABLE IF NOT EXISTS `distributed_lock`
(`lock_key` CHAR(20) NOT NULL,`lock_value` VARCHAR(20) NOT NULL,`expire` BIGINT,primary key (`lock_key`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
3. 修改seata配置
在 seata-server-2.0.0 的 conf 目录下，先备份 application.yml 文件，再参考 application.example.yml 模板修改原来的 application.yml 文件，修改后的内容如下：
server:port: 7091spring:application:name: seata-serverlogging:config: classpath:logback-spring.xmlfile:path: ${log.home:${user.home}/logs/seata}extend:logstash-appender:destination: 127.0.0.1:4560kafka-appender:bootstrap-servers: 127.0.0.1:9092topic: logback_to_logstashconsole:user:username: seatapassword: seataseata:config:type: nacosnacos:server-addr: 127.0.0.1:8848namespace:group: SEATA_GROUP #后续自己在nacos里面新建,不想新建SEATA_GROUP，就写DEFAULT_GROUPusername: nacospassword: nacosregistry:type: nacosnacos:application: seata-serverserver-addr: 127.0.0.1:8848group: SEATA_GROUP #后续自己在nacos里面新建,不想新建SEATA_GROUP，就写DEFAULT_GROUPnamespace:cluster: defaultusername: nacospassword: nacos store:mode: dbdb:datasource: druiddb-type: mysqldriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/seata?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&allowPublicKeyRetrieval=trueuser: rootpassword: rootmin-conn: 10max-conn: 100global-table: global_tablebranch-table: branch_tablelock-table: lock_tabledistributed-lock-table: distributed_lockquery-limit: 1000max-wait: 5000# server:# service-port: 8091 #If not configured, the default is '${server.port} + 1000'security:secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017tokenValidityInMilliseconds: 1800000ignore:urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.jpeg,/**/*.ico,/api/v1/auth/login,/metadata/v1/**
4. 启动 nacos-server-2.5.1 在 bin 目录下执行 startup.cmd -m standalone
5. 启动 seata-server-2.0.0 在 bin 目录下执行 seata-server.bat
- 访问地址： http://localhost:7091
- 用户名 / 密码： seata / seata
微服务实战
创建三个业务数据库
1. 订单数据库 seata_order，创建 t_order 和 undo_log 表
CREATE DATABASE seata_order;USE seata_order;CREATE TABLE t_order(`id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,`user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',`product_id` BIGINT(11)DEFAULT NULL COMMENT '产品id',`count` INT(11) DEFAULT NULL COMMENT '数量',`money` DECIMAL(11,0) DEFAULT NULL COMMENT '金额',`status` INT(1) DEFAULT NULL COMMENT '订单状态: 0:创建中; 1:已完结'
)ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;SELECT * FROM t_order;-- 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';ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);
2. 库存数据库 seata_store，创建 t_store 和 undo_log 表
CREATE DATABASE seata_store;USE seata_store;CREATE TABLE t_store(`id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,`product_id` BIGINT(11) DEFAULT NULL COMMENT '产品id',`total` INT(11) DEFAULT NULL COMMENT '总库存',`used` INT(11) DEFAULT NULL COMMENT '已用库存',`residue` INT(11) DEFAULT NULL COMMENT '剩余库存'
)ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;INSERT INTO t_store(`id`,`product_id`,`total`,`used`,`residue`)VALUES('1','1','100','0','100');SELECT * FROM t_store;-- 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';ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);
3. 账户数据库 seata_account，创建 t_account 和 undo_log 表
CREATE DATABASE seata_account;USE seata_account;CREATE TABLE t_account(`id` BIGINT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'id',`user_id` BIGINT(11) DEFAULT NULL COMMENT '用户id',`total` DECIMAL(10,0) DEFAULT NULL COMMENT '总额度',`used` DECIMAL(10,0) DEFAULT NULL COMMENT '已用余额',`residue` DECIMAL(10,0) DEFAULT '0' COMMENT '剩余可用额度'
)ENGINE=INNODB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;INSERT INTO t_account(`id`,`user_id`,`total`,`used`,`residue`)VALUES('1','1','1000','0','1000');SELECT * FROM t_account;-- 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';ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);
undo_log回滚日志表脚本地址：undo_log建表脚本
编写库存和账户两个Feign接口
1. 通用模块 cloud-common-api 新增 StoreFeignApi 接口
@FeignClient("seata-store-service")
public interface StoreFeignApi {// 扣减库存@PostMapping(value = "/store/decrease")Result decrease(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
}
2. 通用模块 cloud-common-api 新增 AccountFeignApi 接口
@FeignClient("seata-account-service")
public interface AccountFeignApi {// 扣减账户余额@PostMapping("/account/decrease")Result decrease(@RequestParam("userId") Long userId, @RequestParam("money") Long money);
}
订单微服务 seata-order-service9701
1. 引入依赖
<!-- nacos -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- alibaba-seata -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
<!-- openfeign -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!-- loadbalancer -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<!-- cloud-common-api -->
<dependency><groupId>com.zzyy.cloud</groupId><artifactId>cloud-common-api</artifactId><version>1.0-SNAPSHOT</version>
</dependency>
<!-- web + actuator -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Swagger3 调用方式 http://你的主机IP地址:5555/swagger-ui/index.html -->
<dependency><groupId>org.springdoc</groupId><artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
</dependency>
<!-- mybatis和springboot整合 -->
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-spring-boot3-starter</artifactId>
</dependency>
<!-- Mysql8数据库驱动 -->
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- lombok -->
<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional>
</dependency>
<!--test-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope>
</dependency>
2. yml配置
server:port: 9701# =============== applicationName + mysql8 driver ===============
spring:application:name: seata-order-servicecloud:nacos:discovery:server-addr: localhost:8848datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/seata_order?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&allowPublicKeyRetrieval=trueusername: rootpassword: root# =============== mybatis-plus ===============
mybatis-plus:mapper-locations: classpath:mapper/*.xmlconfiguration:# mybatis日志log-impl: org.apache.ibatis.logging.stdout.StdOutImpl# =============== seata ===============
seata:registry:type: nacosnacos:server-addr: 127.0.0.1:8848namespace: ""group: SEATA_GROUPapplication: seata-servertx-service-group: default_tx_group # 事务组，由它获得TC服务的集群名称service:vgroup-mapping:default_tx_group: default # 事务组与TC服务集群的映射关系data-source-proxy-mode: ATlogging:level:io:seata: info
3. 主启动类
@SpringBootApplication
@EnableDiscoveryClient //服务注册与发现
@EnableFeignClients
@MapperScan("com.zzyy.cloud.mapper")
public class SeataOrderMain9701 {public static void main(String[] args) {SpringApplication.run(SeataOrderMain9701.class, args);}
}
4. 控制层 OrderController
@RestController
public class OrderController {@Resourceprivate OrderService orderService;//创建订单@GetMapping("/order/create")public Result create(Order order) {orderService.create(order);return Result.success(order);}
}
5. 服务层 OrderServiceImpl
@Service
@Slf4j
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService{@Resourceprivate OrderMapper orderMapper;@Resource //库存微服务Feign接口private StoreFeignApi storeFeignApi;@Resource //账户微服务Feign接口private AccountFeignApi accountFeignApi;@Override@GlobalTransactional(name = "zzyy-create-order", rollbackFor = Exception.class) //ATpublic void create(Order order) {// xid全局事务id的检查，重要String xid = RootContext.getXID();//1.创建订单log.info("------------创建订单-开始-xid: " + xid);Order orderFromDB = null;//初始创建订单时默认订单状态为0order.setStatus(0);int i = orderMapper.insert(order);if (i > 0) {//从mysql中查出刚创建的订单记录orderFromDB = orderMapper.selectById(order.getId());//2.扣减库存storeFeignApi.decrease(orderFromDB.getProductId(), orderFromDB.getCount());//3.扣减账户余额accountFeignApi.decrease(orderFromDB.getUserId(), orderFromDB.getMoney());//4.修改订单状态，将订单状态由0修改为1，表示已完成log.info("------------修改订单状态-开始");orderFromDB.setStatus(1);orderMapper.updateById(orderFromDB);log.info("------------修改订单状态-结束");}log.info("------------创建订单-结束-xid: " + xid);}
}
库存微服务 seata-store-service9702
1. 引入依赖
库存微服务所需依赖可直接复制上述订单微服务相关依赖
2. yml配置
server:port: 9702# =============== applicationName + mysql8 driver ===============
spring:application:name: seata-store-servicecloud:nacos:discovery:server-addr: localhost:8848datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/seata_store?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&allowPublicKeyRetrieval=trueusername: rootpassword: root# =============== mybatis-plus ===============
mybatis-plus:mapper-locations: classpath:mapper/*.xmlconfiguration:# mybatis日志log-impl: org.apache.ibatis.logging.stdout.StdOutImpl# =============== seata ===============
seata:registry:type: nacosnacos:server-addr: 127.0.0.1:8848namespace: ""group: SEATA_GROUPapplication: seata-servertx-service-group: default_tx_group # 事务组，由它获得TC服务的集群名称service:vgroup-mapping:default_tx_group: default # 事务组与TC服务集群的映射关系data-source-proxy-mode: ATlogging:level:io:seata: info
3. 主启动类
@SpringBootApplication
@EnableDiscoveryClient //服务注册与发现
@EnableFeignClients
@MapperScan("com.zzyy.cloud.mapper")
public class SeataStoreMain9702 {public static void main(String[] args) {SpringApplication.run(SeataStoreMain9702.class, args);}
}
4. 控制层 StoreController
@RestController
public class StoreController {@Resourceprivate StoreService storeService;//扣减库存@PostMapping("/store/decrease")public Result decrease(@RequestParam("productId") Long productId,@RequestParam("count") Integer count) {storeService.decrease(productId, count);return Result.success("扣减库存成功");}
}
5. 服务层 StoreServiceImpl
@Service
@Slf4j
public class StoreServiceImpl extends ServiceImpl<StoreMapper, Store> implements StoreService{@Resourceprivate StoreMapper storeMapper;@Overridepublic void decrease(Long productId, Integer count) {log.info("------------扣减库存-开始");QueryWrapper<Store> wrapper = new QueryWrapper<>();wrapper.eq("product_id", productId);Store store = storeMapper.selectOne(wrapper);Integer used = store.getUsed() + count;store.setUsed(used);store.setResidue(store.getTotal() - used);storeMapper.updateById(store);log.info("------------扣减库存-结束");}
}
账户微服务 seata-account-service9703
1. 引入依赖
库存微服务所需依赖可直接复制上述订单微服务相关依赖
2. yml配置
server:port: 9703# =============== applicationName + mysql8 driver ===============
spring:application:name: seata-account-servicecloud:nacos:discovery:server-addr: localhost:8848datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/seata_account?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&allowPublicKeyRetrieval=trueusername: rootpassword: root# =============== mybatis-plus ===============
mybatis-plus:mapper-locations: classpath:mapper/*.xmlconfiguration:# mybatis日志log-impl: org.apache.ibatis.logging.stdout.StdOutImpl# =============== seata ===============
seata:registry:type: nacosnacos:server-addr: 127.0.0.1:8848namespace: ""group: SEATA_GROUPapplication: seata-servertx-service-group: default_tx_group # 事务组，由它获得TC服务的集群名称service:vgroup-mapping:default_tx_group: default # 事务组与TC服务集群的映射关系data-source-proxy-mode: ATlogging:level:io:seata: info
3. 主启动类
@SpringBootApplication
@EnableDiscoveryClient //服务注册与发现
@EnableFeignClients
@MapperScan("com.zzyy.cloud.mapper")
public class SeataAccountMain9703 {public static void main(String[] args) {SpringApplication.run(SeataAccountMain9703.class, args);}
}
4. 控制类 AccountController
@RestController
public class AccountController {@Resourceprivate AccountService accountService;//扣减账户余额@PostMapping("/account/decrease")public Result decrease(@RequestParam("userId") Long userId,@RequestParam("money") Integer money){accountService.decrease(userId, money);return Result.success("扣减账户余额成功");}
}
5. 服务层 AccountServiceImpl
@Service
@Slf4j
public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> implements AccountService{@Resourceprivate AccountMapper accountMapper;@Overridepublic void decrease(Long userId, Integer money) {log.info("------------扣减账户余额-开始");QueryWrapper<Account> wrapper = new QueryWrapper<>();wrapper.eq("user_id", userId);Account account = accountMapper.selectOne(wrapper);Integer used = account.getUsed() + money;account.setUsed(used);account.setResidue(account.getTotal() - used);accountMapper.updateById(account);//模拟超时
// try {
// // 暂停62秒
// TimeUnit.SECONDS.sleep(62);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }log.info("------------扣减账户余额-结束");}
}
测试结果
启动 Nacos、Seata、以及三个业务微服务
测试一
访问： http://localhost:9701/order/creata?userId=1&productId=1&count=10&money=100
返回： {“code”:“200”, “msg”: “success”, “data”: {“id”: 6, “userId”: 1, “productId”: 1, “count”: 10, “money”: 100, “status”: 0}, “timestamp”: 1748786900259}
结果： 订单、库存、账户表都新增1条记录，库存和账户余额都已扣减，订单状态为1表示已完成。
测试二
未使用@GlobalTransactional注解，在账户余额扣减逻辑后添加模拟超时逻辑，等待62秒(Feign的超时时间默认是60秒)
访问： http://localhost:9701/order/creata?userId=1&productId=1&count=10&money=100
返回： {“code”: “500”, “msg”: “Read timed out executing POST http://seata-account-service/account/decrease?userId=1&money=100”, “data”: null, “timestamp”: 1748788205704}
结果： 订单、库存、账户表都新增1条记录，库存和账户余额都已扣减，但订单状态为0表示未完成。
测试三
使用@GlobalTransactional注解，在账户余额扣减逻辑后添加模拟超时逻辑，等待62秒(Feign的超时时间默认是60秒)
访问： http://localhost:9701/order/creata?userId=1&productId=1&count=10&money=100
返回： {“code”: “500”, “msg”: “Read timed out executing POST http://seata-account-service/account/decrease?userId=1&money=100”, “data”: null, “timestamp”: 1748789082880}
结果： 超时触发事务回滚，订单、库存、账户表数据最终都未发生变化。
总结
以上主要介绍了 Seata 安装、微服务实战的相关知识，想了解更多 Seata 知识的小伙伴请参考 Seata 官网 和 Spring Cloud Alibaba 官网 进行学习，学习更多 Spring Cloud 实战实用技巧的小伙伴，请关注后期发布的文章，认真看完一定能让你有所收获。