Java微服务分布式事务框架seata的TCC模式

Seata 提供了 TCC 模式用于处理微服务间的分布式事务。TCC 模式需要为每个服务编写 Try、Confirm 和 Cancel 三个操作。

以下是一个简化的 TCC 模式的示例代码：

@FeignClient(name = "storage-service", url = "localhost:8091")
public interface StorageService {
    @PostMapping(value = "/storage/debit")
    boolean debit(@RequestParam("commodityCode") String commodityCode, @RequestParam("count") int count);
 
    @PostMapping(value = "/storage/credit")
    boolean credit(@RequestParam("commodityCode") String commodityCode, @RequestParam("count") int count);
}
 
@FeignClient(name = "order-service", url = "localhost:8092")
public interface OrderService {
    @PostMapping(value = "/order/create")
    boolean createOrder(@RequestParam("userId") String userId, @RequestParam("commodityCode") String commodityCode, @RequestParam("count") int count);
 
    @PostMapping(value = "/order/cancel")
    boolean cancelOrder(@RequestParam("orderId") Long orderId);
}
 
@GlobalTransactional
public void purchase(String userId, String commodityCode, int orderCount) {
    storageService.debit(commodityCode, orderCount);
    boolean orderResult = orderService.createOrder(userId, commodityCode, orderCount);
    if (!orderResult) {
        storageService.credit(commodityCode, orderCount);
        throw new RuntimeException("Order service failed, rollbacking...");
    }
}
 
public void cancelPurchase(Long orderId) {
    boolean result = orderService.cancelOrder(orderId);
    if (result) {
        storageService.credit("commodityCode", count);
    } else {
        // 处理回滚失败的情况
    }
}

在这个例子中，purchase 方法是一个全局事务的开始，它调用了存储服务的扣款方法 debit。接着，它尝试在订单服务中创建订单。如果订单创建成功，事务会正常提交。如果创建失败，它会调用存储服务的加款方法 credit 来撤销扣款，并抛出异常导致全局事务回滚。cancelPurchase 方法则用于取消订单并相应地加款，它也需要处理回滚失败的情况。

注意：这只是一个简化的示例，实际的 TCC 模式实现需要根据业务逻辑细化每个阶段的处理，并确保其幂等性、一致性和原子性。