分布式事务在java微服务架构中通过seata实现,主要步骤包括:一、搭建seata server,下载并配置registry.conf文件,选择注册中心如nacos或file模式,启动服务端;二、在spring boot项目中引入seata客户端,添加maven依赖并配置application.yml连接seata server;三、在业务代码中使用@globaltransactional注解实现全局事务控制,确保跨服务操作的一致性;四、注意数据库支持本地事务、创建undo_log表、保持事务分组一致、避免异步调用及合理设置超时时间。
分布式事务在Java微服务架构中是个绕不开的问题。简单来说,当一次业务操作需要跨多个数据库或服务时,如何保证数据一致性就成了关键。Seata 是目前主流的开源分布式事务解决方案之一,它提供了 AT、TCC、SAGA 和 XA 等多种模式,使用起来也比较方便。
下面我结合实际项目经验,讲讲怎么在 Spring Boot 项目中整合 Seata 来实现分布式事务。
在整合之前,首先要准备好 Seata 的服务端(即 TC,Transaction Coordinator)。
conf 目录,修改 registry.conf 文件,选择你使用的注册中心,比如 Nacos、Eureka 或者直接用 file。seata-server.bat,Linux/Unix 运行 sh seata-server.sh。8091 端口。启动成功之后,就可以开始在你的应用中集成 Seata 客户端了。
这部分主要是添加依赖和配置文件,确保你的服务能连接上 Seata Server。
Maven 依赖:
io.seata seata-spring-boot-starter1.6.1
application.yml 配置示例:
seata:
enabled: true
application-id: order-service
tx-service-group: my_test_tx_group
registry:
type: nacos
nacos:
server-addr: 127.0.0.1:8848
group: SEATA_GROUP
data-id: seataServer.properties
config:
type: nacos
nacos:
server-addr: 127.0.0.1:8848
group: SEATA_GROUP
data-id: seataServer.properties如果你是用的 file 模式,也可以不配 registry 和 config,但推荐用 Nacos 管理配置,更灵活。
这是最核心的部分,通过注解来开启全局事务。
假设你有一个订单服务调用了库存服务和账户服务,你需要保证这三个操作要么都成功,要么都失败。
示例代码如下:
@GlobalTransactional
public void placeOrder(OrderDTO dto) {
// 1. 创建订单
orderMapper.create(dto);
// 2. 扣减库存
inventoryService.decreaseStock(dto.getProductId(), dto.getCount());
// 3. 扣款
accountService.deduct(dto.getUserId(), dto.getAmount());
}只要在方法上加上 @GlobalTransactional,Seata 就会在背后帮你处理分布式事务的提交或回滚。
当然,前提是这些服务也都集成了 Seata,并且使用的是支持 AT 模式的数据库(如 MySQL)。
tx-service-group 要相同。seata:
tm:
timeout: 30000基本上就这些,Seata 整合不算特别复杂,但在实际使用中还是要注意配置的一致性和事务范围的控制。有些细节容易忽略,比如 undo_log 表没建好会导致事务无法回滚,或者注册中心配置错误导致连接不上 TC。
如果你刚开始接触分布式事务,建议先从 AT 模式入手,等熟悉后再尝试 TCC 或 SAGA。