Seata 是一个开源的分布式事务解决方案,旨在为微服务架构中的分布式事务提供统一的事务管理功能。它通过全局事务和分支事务的概念,解决了跨服务和跨数据库的一致性问题。接下来我们将深入探讨如何配置和使用 Seata 的事务管理功能,重点介绍全局事务 ID、分支事务、事务状态等核心概念,并通过多个代码示例展示如何在 Spring Boot 和 Spring Cloud 中使用 Seata。
在 Seata 中,分布式事务被分为两大类:
1、全局事务(Global Transaction) 全局事务是一个跨多个微服务或系统的事务,它由一个全局事务 ID 唯一标识。全局事务可以包括多个分支事务,它的目标是确保多个分支事务在最终提交或回滚时保持一致性。
2、分支事务(Branch Transaction) 分支事务是全局事务的一部分,通常对应于具体的操作,如调用远程服务、访问数据库等。分支事务通常是短时间的,并由具体的资源管理器(如数据库或消息队列)负责处理。
3、事务状态(Transaction Status) Seata 中的事务状态包括:
Begin:事务开始
Commit:事务提交
Rollback:事务回滚
4、Seata 的角色
TC(Transaction Coordinator):负责全局事务的协调
RM(Resource Manager):管理和操作分支事务,通常是数据库、消息队列等
TM(Transaction Manager):负责发起全局事务,通常集成在服务代码中
在 Spring Boot 项目中,可以通过以下 Maven 依赖来引入 Seata 相关依赖:
<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>1.6.1</version></dependency>
Seata 需要一个配置中心来存储全局事务的状态。最常见的配置是通过 Nacos 或 Zookeeper 实现。下面是一个典型的 application.yml
配置示例:
server: port: 8080 spring: application: name: seata-demo seata: tx-service-group: my_test_tx_group # 设置全局事务组名 config: type: nacos nacos: server-addr: localhost:8848 namespace: public group: SEATA_GROUP transport: type: TCP server: 127.0.0.1:8091
Seata 服务端需要配置数据库或其他存储系统来管理事务。以 Nacos 为例,配置项如下:
transport: type: TCP server: 127.0.0.1:8091 store: mode: db db: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/seata user: root password: root
在 Spring Boot 中,你可以使用 @GlobalTransactional
注解来启用全局事务。例如,下面的代码展示了一个简单的全局事务管理:
importio.seata.spring.annotation.GlobalTransactional;importorg.springframework.stereotype.Service;@ServicepublicclassOrderService{@GlobalTransactionalpublicvoidcreateOrder(){// 模拟创建订单操作System.out.println("Order Created");}}
Seata 提供了多种 API 来操作全局事务,例如提交事务、回滚事务等。以下是如何使用 Seata API 来管理事务。
当你调用 @GlobalTransactional
注解的服务时,Seata 会自动启动全局事务并生成一个全局事务 ID。在代码中,你不需要手动创建事务,Seata 会自动管理它。
如果所有的分支事务都成功执行,Seata 会尝试提交全局事务。你可以通过调用 GlobalTransactionContext
来手动提交事务。
importio.seata.core.context.GlobalTransactionContext;importio.seata.tm.api.GlobalTransaction;publicclassOrderService{publicvoidcommitTransaction(){GlobalTransactionglobalTransaction=GlobalTransactionContext.getCurrentOrCreate();globalTransaction.commit();}}
如果出现任何错误,或者你需要回滚整个事务,可以调用 GlobalTransactionContext
提供的 rollback()
方法来回滚全局事务。
publicvoidrollbackTransaction(){GlobalTransactionglobalTransaction=GlobalTransactionContext.getCurrentOrCreate();globalTransaction.rollback();}
在 Seata 中,分支事务是由 Resource Manager (RM) 进行管理的。一个分支事务通常会在服务调用或数据库操作之前进行注册。你可以通过 Seata 提供的 API 注册分支事务。
假设我们在做一个订单和支付的操作,订单服务和支付服务是两个分支事务。
importio.seata.rm.datasource.DataSourceProxy;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service;@ServicepublicclassOrderService{@AutowiredprivateDataSourceProxydataSource;publicvoidcreateOrderAndPay(){// 先创建订单createOrder();// 然后支付makePayment();}privatevoidcreateOrder(){// 订单创建逻辑System.out.println("Creating Order");}privatevoidmakePayment(){// 支付逻辑System.out.println("Making Payment");}}
分支事务的提交和回滚通常是由 RM
管理器根据全局事务的状态进行的。如果所有分支事务都成功,Seata 会提交这些事务;如果某个分支事务失败,Seata 会回滚所有相关事务。
如果你在使用 Spring Cloud 微服务框架,Seata 提供了与 Spring Cloud 的集成支持。以下是如何配置 Spring Cloud 和 Seata。
首先,在 Spring Cloud 的 application.yml
中添加 Seata 的配置:
seata: tx-service-group: my_test_tx_group config: type: nacos nacos: server-addr: localhost:8848 namespace: public group: SEATA_GROUP transport: type: TCP server: 127.0.0.1:8091
然后,像 Spring Boot 一样,通过 @GlobalTransactional
注解来启动全局事务。
在微服务架构中,你可能会有多个服务进行分布式事务的管理。例如,订单服务和支付服务的事务可以通过 Seata 进行跨服务的全局事务管理。你只需要确保每个微服务都启用了 Seata 并配置了正确的事务组名。
importio.seata.spring.annotation.GlobalTransactional;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;@RestControllerpublicclassOrderController{@AutowiredprivateOrderServiceorderService;@AutowiredprivatePaymentServicepaymentService;@GlobalTransactional@RequestMapping("/createOrder")publicStringcreateOrder(){// 创建订单并支付orderService.createOrder();paymentService.makePayment();return"Order Created and Payment Made";}}
Seata 作为一个分布式事务管理工具,为微服务架构提供了一种高效、简单的事务管理解决方案。通过配置 Seata 的全局事务和分支事务,并结合 Spring Boot 或 Spring Cloud,可以帮助开发人员轻松管理跨服务和跨数据库的事务一致性。
关键点回顾:
全局事务 和 分支事务 是 Seata 事务模型的核心。
@GlobalTransactional 注解可以自动启动全局事务。
事务的提交和回滚通过 Seata API 进行管理。
Seata 可以与 Spring Boot 和 Spring Cloud 平台进行无缝集成。
通过本文的示例代码,你可以在实际项目中轻松实现 Seata 的分布式事务管理,并确保多个微服务之间的事务一致性。