TCC并不不支持OpenFeign？来看松哥如何填坑

2023-12-30 03:14:42

Seata 的 TCC 模式：与 Spring Boot 和 Feign 的无缝整合

摘要

分布式事务处理在现代软件系统中至关重要，而 Seata 的 TCC 模式提供了一种简单、高效且可靠的解决方案。本文将深入探讨 Seata 的 TCC 模式，重点关注其与 Spring Boot 和 Feign 的无缝整合，从而为读者提供一个全面的指南，帮助他们轻松掌握 TCC 分布式事务的实现。

Seata 的 TCC 模式

TCC（Try-Confirm-Cancel）模式是一种分布式事务处理方法，它将事务分解为三个阶段：Try、Confirm 和 Cancel。在 Try 阶段，参与者执行本地操作但不提交。在 Confirm 阶段，如果所有 Try 操作都成功，则提交事务。在 Cancel 阶段，如果 Try 操作失败，则回滚事务。

Seata 的 TCC 模式优势

Seata 的 TCC 模式提供了以下优势：

简单易用： Seata 提供了简洁的 API，使开发人员可以轻松集成 TCC 模式。
高性能： 异步执行机制确保了卓越的性能。
可靠性强： 分布式锁机制保证了事务的一致性和完整性。

Seata TCC 模式与 Spring Boot 和 Feign 的整合

1. 依赖引入

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

2. 配置 Seata

# Seata 服务端地址
seata.server.ip=127.0.0.1
seata.server.port=8091

# 集群名称
seata.cluster.name=default

# 事务组名称
seata.tx-service-group=my_tx_group

3. 配置 Feign

# 启用 Hystrix 支持
feign.hystrix.enabled=true

4. 编写 TCC 接口

public interface OrderService {
    void createOrder(Order order);
    void confirmOrder(String orderId);
    void cancelOrder(String orderId);
}

5. 编写 TCC 实现类

public class OrderServiceImpl implements OrderService {
    // Try 阶段
    public void createOrder(Order order) {
        orderMapper.insert(order);
        order.setStatus("已创建");
        orderMapper.update(order);
    }
    // Confirm 阶段
    public void confirmOrder(String orderId) {
        Order order = orderMapper.selectById(orderId);
        order.setStatus("已确认");
        orderMapper.update(order);
        order.setStatus("已完成");
        orderMapper.update(order);
    }
    // Cancel 阶段
    public void cancelOrder(String orderId) {
        Order order = orderMapper.selectById(orderId);
        order.setStatus("已取消");
        orderMapper.update(order);
        order.setStatus("已取消");
        orderMapper.update(order);
    }
}

6. 测试

@RunWith(SpringRunner.class)
@SpringBootTest
public class OrderServiceTests {
    @Autowired
    private OrderService orderService;

    @Test
    public void testCreateOrder() {
        Order order = new Order();
        order.setUserId(1);
        order.setProductId(1);
        order.setQuantity(1);

        orderService.createOrder(order);

        Assert.assertEquals(order.getStatus(), "已创建");
    }
}