函数调用事务一致性难题：如何实现a函数调用b函数后的协同回滚

1次阅读

没有评论

共计 1734 个字符，预计需要花费 5 分钟才能阅读完成。

在分布式系统中，函数调用链中的事务一致性是一个常见但棘手的问题。特别是当 a 函数调用 b 函数，b 函数已经完成数据库插表操作，而后续 a 函数却出现异常时，如何确保 ab 操作的原子性回滚成为开发者面临的典型难题。

典型场景：假设 a 函数负责订单创建，b 函数负责库存扣减。如果 b 函数扣减库存成功，但 a 函数在后续处理中失败，此时库存已经扣减，但订单并未创建，导致数据不一致。
现有方案的局限性：
try-catch 回滚：手动在 catch 块中调用 b 函数的回滚逻辑，但这种方式侵入性强，且难以处理嵌套调用。
补偿事务：通过记录操作日志，在失败时执行反向操作，但实现复杂，且无法保证原子性。

XA 协议：适用于强一致性场景，但性能开销大，且对数据库和中间件支持要求高。
本地消息表：通过将事务操作记录到本地表中，结合定时任务或消息队列实现最终一致性，适用于大多数分布式场景。

Spring 的 @Transactional(propagation=REQUIRES_NEW) 可以确保 b 函数在一个独立的事务中执行，但需要注意事务的隔离级别和超时设置。

通过引入消息队列，可以将 b 函数的操作异步化，并在 a 函数失败时发送补偿消息，确保数据最终一致。

以下是一个 Spring Boot + MyBatis 的完整示例代码：

@Service
public class OrderService {
    @Autowired
    private InventoryService inventoryService;

    @Transactional
    public void createOrder(Order order) {
        try {
            // 扣减库存
            inventoryService.deductInventory(order.getProductId(), order.getQuantity());
            // 创建订单
            orderMapper.insert(order);
        } catch (Exception e) {
            // 记录失败日志，触发补偿流程
            log.error("创建订单失败", e);
            throw e;
        }
    }
}

@Service
public class InventoryService {@Transactional(propagation = Propagation.REQUIRES_NEW)
    public void deductInventory(Long productId, int quantity) {inventoryMapper.deduct(productId, quantity);
    }
}

CREATE TABLE transaction_message (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    message_id VARCHAR(64) NOT NULL,
    topic VARCHAR(128) NOT NULL,
    content TEXT NOT NULL,
    status TINYINT NOT NULL DEFAULT 0,
    create_time DATETIME NOT NULL,
    update_time DATETIME NOT NULL,
    UNIQUE KEY uk_message_id (message_id)
);