seata分布式事务2.0使用

### 如何使用Seata 2.0 进行分布式事务管理 #### 部署 Seata Server 为了启动并运行 Seata，首先需要完成 Seata Server 的部署工作。这一步涉及配置 `config.txt` 文件中的属性值[^1]。 ```bash # 下载 seata-server-2.0.0 版本 wget https://github.com/seata/seata/releases/download/v2.0.0/seata-server-2.0.0.zip unzip seata-server-2.0.0.zip cd seata-server-2.0.0/ ``` 编辑 `conf/config.txt` 文件以适配环境需求。例如，可以指定注册中心、存储模式等参数： ```properties registry { type = "nacos" nacos { serverAddr = "localhost:8848" namespace = "" cluster = "default" } } store { mode = "db" # 存储模式可以选择 file 或 db } ``` 接着，在 MySQL 数据库中创建名为 `seata` 的数据库，并导入 SQL 脚本来初始化表结构[^2]： ```sql CREATE DATABASE IF NOT EXISTS seata; USE seata; -- 执行 seata 安装包内的 sql 文件 SOURCE /path/to/seata/sql/storage/db/mysql.sql; ``` 最后，通过命令行启动 Seata Server： ```bash sh bin/seata-server.sh -p 8091 -m db ``` --- #### Spring Cloud 集成 Seata 实现分布式事务 在微服务架构下，当多个服务共同参与一次业务操作时，可能面临数据一致性的挑战。Seata 提供了一种高效的解决方案——AT 模式，它能够以零侵入的方式处理分布式事务问题[^3]。 以下是基于 Spring Cloud Alibaba 集成 Seata 的具体步骤： ##### 添加依赖项 在项目的 `pom.xml` 文件中引入必要的 Maven 依赖： ```xml <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-seata</artifactId> <version>2021.1</version> </dependency> <!-- 如果使用 MyBatis，则需额外添加 --> <dependency> <groupId>io.seata</groupId> <artifactId>seata-spring-boot-starter</artifactId> <version>2.0.0</version> </dependency> ``` ##### 修改配置文件 更新 `application.yml` 文件以支持 Seata 功能： ```yaml seata: enabled: true tx-service-group: my_test_tx_group registry: type: nacos nacos: application: seata-server server-addr: localhost:8848 config: type: nacos ``` 其中，`tx-service-group` 参数定义了一个全局事务组名称，用于区分不同的事务上下文。 ##### 创建事务方法 利用 Seata 提供的注解机制标记需要加入分布式事务的方法。例如： ```java import io.seata.spring.annotation.GlobalTransactional; @Service public class OrderService { @GlobalTransactional(name = "place-order", rollbackFor = Exception.class) public void placeOrder(Order order) throws Exception { // 调用库存扣减接口 inventoryFeignClient.deductInventory(order.getProductId(), order.getCount()); // 插入订单记录到本地数据库 orderMapper.insert(order); // 可能抛出异常触发回滚逻辑 if (order.getAmount() <= 0) { throw new RuntimeException("Invalid amount"); } } } ``` 上述代码片段展示了如何在一个方法内部协调两个独立的服务（如库存管理和订单生成）。一旦发生错误，整个流程会被自动撤销以保持一致性[^5]。 --- #### 常见注意事项 为了避免潜在问题，请注意以下事项： - **传播行为**：确保各层之间的事务传播行为合理设置，比如避免误用 `PROPAGATION_NOT_SUPPORTED` 导致事务失效。 - **网络稳定性**：由于 Seata 需要频繁通信确认状态变更，因此建议优化网络延迟或切换至更可靠的传输协议。 - **性能调优**：对于高并发场景下的锁竞争现象，可以通过调整超时时间或者采用异步提交策略缓解压力。 ---