Seata与SpringCloud实战之数据库分布式事务

2023-11-28 07:18:29

Seata介绍

Seata是一个易于使用的分布式事务解决方案，提供了高性能和强一致性的分布式事务服务。它支持多种主流数据库，包括MySQL、Oracle、PostgreSQL、SQL Server等。

Seata的核心思想是使用XA协议来实现分布式事务。XA协议是一种分布式事务标准，它定义了分布式事务的参与者（事务协调器、事务参与者和资源管理器）之间的交互过程。

Seata的架构如下图所示：

+------------------------------------------------------+
|                                                      |
|              +-------------+-------------+              |
|              | Seata TCC   | Seata AT   |              |
|              +-------------+-------------+              |
|                                                      |
|       +---------------------+----------------+       |
|       |                     |                   |       |
|       |     XA Transaction    |    TCC Transaction   |       |
|       |                     |                   |       |
|       +---------------------+-----------------+       |
|                                                      |
+------------------------------------------------------+

Seata TCC：TCC是Two-Phase Commit的缩写，是一种两阶段提交协议。TCC事务分为三个阶段：Try、Confirm和Cancel。Try阶段是预提交阶段，在这一阶段，事务参与者执行业务操作，但并不提交事务。Confirm阶段是提交阶段，在这一阶段，事务协调器通知事务参与者提交事务。Cancel阶段是回滚阶段，在这一阶段，事务协调器通知事务参与者回滚事务。
Seata AT：AT是Atomic Transaction的缩写，是一种原子事务协议。AT事务分为两个阶段：Prepare和Commit。Prepare阶段是预提交阶段，在这一阶段，事务协调器向事务参与者发送Prepare请求。事务参与者收到Prepare请求后，执行业务操作，但并不提交事务。Commit阶段是提交阶段，在这一阶段，事务协调器向事务参与者发送Commit请求。事务参与者收到Commit请求后，提交事务。

Seata在SpringCloudAlibaba中的应用

Seata可以与SpringCloudAlibaba无缝集成。SpringCloudAlibaba提供了Seata的starter，我们可以通过在项目中引入这个starter来使用Seata。

1. 依赖引入

<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  <version>2.1.0.RELEASE</version>
</dependency>

2. 配置

在application.yml文件中添加以下配置：

seata:
  enabled: true
  application-id: ${spring.application.name}
  tx-service-group: seata-group
  registry:
    type: nacos
    nacos:
      server-addr: localhost:8848
      namespace: public
  config:
    type: nacos
    nacos:
      server-addr: localhost:8848
      namespace: public
      group: SEATA_GROUP
      data-id: seata-server.conf

3. 初始化Seata

在项目启动类中添加以下代码：

@SpringBootApplication
public class SeataApplication {

    public static void main(String[] args) {
        SpringApplication.run(SeataApplication.class, args);
    }

    @Bean
    public SeataRestTemplate seataRestTemplate() {
        return new SeataRestTemplate();
    }
}

4. 使用Seata

在需要使用Seata的地方，我们可以使用@GlobalTransactional注解来标识这是一个分布式事务方法。例如：

@GlobalTransactional
public void transfer(String fromAccount, String toAccount, BigDecimal amount) {
    accountService.debit(fromAccount, amount);
    accountService.credit(toAccount, amount);
}

在上面的代码中，transfer方法被@GlobalTransactional注解标识为一个分布式事务方法。当调用这个方法时，Seata会自动创建一个全局事务，并将该方法执行期间的所有操作都纳入到这个全局事务中。如果方法执行成功，则Seata会提交这个全局事务；如果方法执行失败，则Seata会回滚这个全局事务。