Cyanix Blog

切换主题

Spring Cloud Alibaba Seata ​

字数
1789 字
阅读时间
8 分钟

Spring Cloud Alibaba Seata 是一个专门用于解决分布式事务问题的开源框架。分布式事务是指在分布式系统中跨多个服务或数据库的事务，通常很难保证数据一致性。Seata 提供了高效、简单的分布式事务解决方案，支持微服务架构中的强一致性和最终一致性。

在电商平台中，多个微服务（如订单、库存、支付等）可能需要跨服务或数据库操作。Seata 能够保证这些操作在出现异常时保持事务的一致性，避免因服务之间的部分失败而导致数据不一致。

[!summary]

Spring Cloud Alibaba Seata 提供了一个强大且易用的分布式事务解决方案，适合电商平台等分布式系统中的事务处理需求。通过 Seata 的 AT 模式，开发者可以轻松实现跨服务、跨数据库的事务管理，保证数据的一致性和系统的稳定性。

1 Seata 的分布式事务模型 ​

Seata 提供了一种AT 模式（Automatic Transaction）的分布式事务解决方案，它通过两阶段提交协议来确保事务的一致性：

  • 第一阶段：服务执行本地事务，准备提交。
  • 第二阶段：全局事务协调器（TC，Transaction Coordinator）根据各服务的提交情况决定是提交整个事务还是回滚。

Seata 的核心组件：

  • TC（Transaction Coordinator）：全局事务协调器，负责全局事务的协调和最终提交/回滚。
  • TM（Transaction Manager）：事务管理器，负责开启全局事务。
  • RM（Resource Manager）：资源管理器，负责管理本地资源和分支事务的提交/回滚。

2 Seata 的应用场景 ​

在电商平台中，常见的分布式事务场景包括：

  • 订单服务调用库存服务和支付服务，保证订单、库存扣减和支付扣款的一致性。
  • 促销活动中，多个服务如优惠券、库存、订单等需要同步操作，防止数据不一致问题。

3 Seata 的集成步骤 ​

3.1 添加 Seata 依赖 ​

在 Spring Cloud 项目中，首先需要为各个微服务添加 Seata 依赖。在 pom.xml 文件中添加如下依赖：

xml
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-all</artifactId>
    <version>1.6.0</version>  <!-- 根据Seata版本选择 -->
</dependency>

3.2 Seata 服务器的部署 ​

Seata 需要运行一个独立的**TC（Transaction Coordinator）**服务器。你可以在本地或集群环境中部署 Seata 服务器，来协调分布式事务的提交与回滚。

  1. 下载 Seata 服务器 并解压。
  2. 修改 conf 文件夹中的 file.conf 和 registry.conf，配置数据库和注册中心信息（如 Nacos）。
  3. 启动 Seata 服务器：
bash
sh ./bin/seata-server.sh -p 8091 -m file

3.3 配置 Seata 客户端 ​

在各个微服务的 application.yml 文件中配置 Seata 相关信息：

yaml
seata:
  enabled: true
  application-id: my-ecommerce-app   # 应用名称
  tx-service-group: my_tx_group      # 事务分组名
  service:
    vgroup-mapping:
      my_tx_group: "default"         # 虚拟分组名与 Seata Server 对应关系
    enable-degrade: false            # 是否开启服务降级
  registry:
    type: nacos                      # 使用 Nacos 作为注册中心
    nacos:
      application: seata-server
      server-addr: localhost:8848    # Nacos 地址
      group: SEATA_GROUP
  config:
    type: nacos                      # 使用 Nacos 作为配置中心
    nacos:
      server-addr: localhost:8848    # Nacos 地址
      group: SEATA_GROUP

3.4 使用 Seata 事务注解 ​

在涉及分布式事务的业务逻辑中，可以通过 @GlobalTransactional 注解开启 Seata 全局事务。Seata 会自动管理涉及多个服务的分布式事务。

示例：订单服务调用库存服务和支付服务

java
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class OrderService {

    @Autowired
    private InventoryService inventoryService;

    @Autowired
    private PaymentService paymentService;

    @GlobalTransactional(name = "createOrder", rollbackFor = Exception.class)
    public void createOrder(String productId, String userId, double amount) {
        // 1. 创建订单
        createOrderRecord(productId, userId, amount);

        // 2. 扣减库存
        inventoryService.deduct(productId);

        // 3. 执行支付
        paymentService.pay(userId, amount);
    }

    private void createOrderRecord(String productId, String userId, double amount) {
        // 创建订单逻辑
    }
}

在上面的例子中，createOrder 方法涉及创建订单、扣减库存和执行支付这三个步骤。Seata 将确保这三个步骤在不同服务中的操作是原子操作，即要么全部成功，要么全部回滚。如果任何步骤失败，Seata 将自动回滚所有操作，确保分布式事务的一致性。

3.5 配置数据库代理 ​

Seata 使用AT 模式管理分布式事务，需要对数据库操作进行代理。你需要配置数据库的代理，确保 Seata 能够拦截和管理数据库的事务操作。

在 application.yml 中配置数据源代理：

yaml
spring:
  datasource:
    druid:
      url: jdbc:mysql://localhost:3306/ecommerce_db
      username: root
      password: password
      driver-class-name: com.mysql.cj.jdbc.Driver
      filters: stat,wall,log4j
      proxy-filters: ['seata']

4 事务冲突与回滚 ​

在分布式事务中，事务冲突和回滚是常见问题。Seata 提供了自动回滚机制来处理失败的事务。例如，在电商平台中，如果库存不足或支付失败，整个订单事务将回滚，避免数据不一致。

Seata 的 AT 模式采用了乐观锁机制，可以减少冲突的发生。它会在事务提交时检查数据是否被修改过，如果检测到冲突，则回滚整个事务。

5 Seata 的事务模式 ​

Seata 支持多种事务模式，适用于不同的业务场景：

  • AT 模式：推荐使用的模式，自动管理事务的两阶段提交过程，适合大多数场景。
  • TCC 模式：Try-Confirm-Cancel 模式，手动管理事务的提交和回滚，适用于精细化控制的场景。
  • Saga 模式：长事务模式，适合需要最终一致性的场景，如订单长流程中的异步处理。
  • XA 模式：分布式数据库的强一致性支持，适合有分布式数据库的场景。

6 在电商平台中的应用场景 ​

在电商平台中，Seata 可以帮助处理多个服务之间的跨服务事务，常见的应用场景包括：

  • 订单服务与库存服务、支付服务的跨服务事务：保证订单创建、库存扣减和支付过程的一致性。
  • 用户服务与优惠券服务、积分服务的联合操作：确保用户优惠券发放、积分增加等操作是原子的，避免出现部分成功、部分失败的情况。
  • 促销活动中的多服务协作：在秒杀、拼团等促销活动中，多个服务之间的状态变更（如订单生成、库存扣减、优惠券发放等）需要统一管理。