分布式事务saga实战

### 关于分布式事务 Saga 模式的实际应用案例

在电子商务平台中，当处理复杂的业务流程如创建订单时，涉及多个微服务之间的协调工作。为了确保数据一致性，在此过程中可以采用 Saga 模式来管理跨服务的操作序列[^1]。

#### Java 中的 Saga 模式实现示例

下面是一个简单的 Java 代码片段展示如何通过编程方式定义并执行一系列补偿动作：

public class OrderService {
    private InventoryClient inventoryClient;
    private PaymentClient paymentClient;

    public void placeOrder(Order order) throws Exception {
        try {
            // Step 1: Reserve stock
            boolean reservedStock = reserveStock(order);
            
            if (!reservedStock) throw new RuntimeException("Failed to reserve stock");

            // Step 2: Charge customer's account
            chargeCustomerAccount(order);

            System.out.println("Order placed successfully.");
        } catch (Exception e) {
            rollbackTransaction(order); // If any step fails, initiate compensation transactions.
            throw e;                    // Re-throw exception after attempting recovery.
        }
    }

    private void rollbackTransaction(Order order){
        refundPaymentIfNecessary(order);
        releaseReservedItems(order);
    }

    private boolean reserveStock(Order order){...}
    
    private void chargeCustomerAccount(Order order){...}

    private void refundPaymentIfNecessary(Order order){...}
    
    private void releaseReservedItems(Order order){...}
}

在这个例子中，`placeOrder()` 方法代表了一个典型的 Saga 流程，它包含了两个主要的服务调用：预留商品库存 (`reserveStock`) 和扣除顾客账户余额 (`chargeCustomerAccount`)。如果任何一个步骤失败，则会触发 `rollbackTransaction()` 函数来回滚之前已完成的动作，从而保持整个系统的最终一致状态。

#### 使用 Seata 实现分布式事务控制

对于更复杂的应用场景，可以借助像 Seata 这样的框架简化 Saga 的开发过程。Seata 提供了一套完整的 API 来帮助开发者构建可靠的分布式应用程序，并且内置了对多种数据库和技术栈的支持[^2]。

例如，利用 Seata 可以为上述 Java 类添加 @GlobalTransactional 注解以声明全局事务边界：

import io.seata.spring.annotation.GlobalTransactional;

@Service
public class OrderServiceImpl implements IOrderService {

    @Autowired
    private InventoryFeignClient inventoryFeignClient;

    @Autowired
    private AccountFeignClient accountFeignClient;

    /**
     * 下单接口
     */
    @Override
    @GlobalTransactional(name = "fx-seata-order", rollbackFor = Exception.class)
    public Boolean create(Long userId, Integer commodityCode, Integer count, int money) {
        // 扣减库存
        inventoryFeignClient.decrease(commodityCode, count);
        
        // 扣钱
        accountFeignClient.decrease(userId, money);

        return true;
    }
}

这段代码展示了如何在一个 Spring Boot 应用程序里集成 Seata 并配置一个全局事务。一旦发生异常情况，Seata 将自动回滚所有参与方的状态变更，而无需手动编写额外的日志记录或恢复逻辑。