当前位置：首页 > news >正文

基于Seata的微服务分布式事务实战经验分享

news 2025/7/25 23:10:29

基于Seata的微服务分布式事务实战经验分享

1. 业务场景描述

在电商系统中，用户下单会涉及多个微服务：订单服务（Order Service）、库存服务（Inventory Service）、账户服务（Account Service）等。一次下单操作需要同时扣减库存、创建订单、扣减账户余额等，这些操作分布在不同的微服务节点上，如何保证事务一致性成为关键问题。

在高并发、大流量的生产环境中，传统的嵌套调用或通过消息最终一致性往往带来复杂性和延迟，甚至会出现数据不一致。基于此，我们选择Seata（Simple Extensible Autonomous Transaction Architecture）来实现分布式事务，确保在分布式环境下的原子性与一致性。

2. 技术选型过程

最终一致性方案（如 TCC、可靠消息）高成本、开发复杂；
XA 方案对数据库、中间件要求高，性能开销大；
Seata 提供 AT、TCC、多模式支持，易集成，社区活跃。

因此，在追求低耦合、高性能的前提下，我们选型Seata AT模式，它通过对数据库 SQL 拦截，实现对分布式事务的统一管理。

3. 实现方案详解

3.1 Seata 架构概览

[ TC（事务协调器） ]↑ ↓
[Broker/Registry: Nacos]  ←→  [File.conf、Registry.conf]↑ ↓
[ Order Service ][ Inventory Service ][ Account Service ]| hook SQL↓数据库二阶段提交（undo log）

3.2 Seata 服务端部署

# 下载 Seata Server 包，并解压
wget https://github.com/seata/seata/releases/download/v1.5.2/seata-server-1.5.2.tar.gz
tar zxvf seata-server-1.5.2.tar.gz
cd seata-server-1.5.2# 配置注册中心 registry.conf （Nacos 示例）
vi conf/registry.conf
registry { type = "nacos"nacos { serverAddr = "127.0.0.1:8848"}
}# 配置事务协调器 file.conf
vi conf/file.conf
store { mode = "db"db { driverClass = "com.mysql.cj.jdbc.Driver"url = "jdbc:mysql://127.0.0.1:3306/seata_meta?characterEncoding=utf8"user = "seata"password = "seata123"}
}# 启动 Seata-Server
sh bin/seata-server.sh

3.3 客户端集成（Spring Boot）

1）Maven 依赖

<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>1.5.2</version>
</dependency>

2）application.yml 配置

spring:application:name: order-service
seata:enabled: truetx-service-group: my_test_tx_groupservice:vgroup-mapping:my_test_tx_group: "default"registry:type: nacosnacos:server-addr: 127.0.0.1:8848config:file:name: file.conf

3.4 核心代码示例

OrderService.java

@Service
public class OrderService {@Autowiredprivate InventoryClient inventoryClient;@Autowiredprivate AccountClient accountClient;@GlobalTransactional(name = "order-create-tx", rollbackFor = Exception.class)public void createOrder(OrderDTO order) {// 1. 扣减库存inventoryClient.decrease(order.getProductId(), order.getCount());// 2. 扣减账户余额accountClient.decrease(order.getUserId(), order.getAmount());// 3. 创建订单Order newOrder = new Order(null, order.getUserId(), order.getProductId(), order.getCount(), order.getAmount());orderRepository.save(newOrder);}
}

InventoryService.java

@Service
public class InventoryService {@Transactionalpublic void decrease(Long productId, Integer count) {Integer stock = inventoryMapper.selectStock(productId);if (stock < count) {throw new RuntimeException("库存不足");}inventoryMapper.updateStock(productId, stock - count);}
}