分布式事务限时活动

@GlobalTransactional(timeoutMills = 30000) // 设置事务超时时间为30秒
public void createOrder() {
    // 创建订单逻辑
    orderService.create(order);
    // 扣减库存逻辑
    inventoryService.reduceStock(productId, quantity);
    // 支付逻辑
    paymentService.processPayment(order.getId());
}

RetryPolicy retryPolicy = new RetryPolicy()
    .retryOn(Exception.class)
    .withMaxRetries(3)
    .withDelay(1, TimeUnit.SECONDS);

Failsafe.with(retryPolicy).run(() -> {
    // 执行可能失败的操作
});

TransactionMonitor monitor = new TransactionMonitor();
monitor.startMonitoring(transactionId, () -> {
    // 检查事务状态的逻辑
});

public void compensateTransaction(String transactionId) {
    // 根据事务ID查找需要补偿的操作
    List<CompensableOperation> operations = findOperations(transactionId);
    for (CompensableOperation op : operations) {
        op.compensate();
    }
}