4. 事务超时与回滚策略

事务超时与回滚策略是保证分布式系统数据一致性的关键防线。超时配置防止长时间锁竞争，回滚策略则定义了异常发生时的补偿行为。本节从配置、实现方式到最佳实践，系统梳理事务边界调试的核心规则。

4.1 事务超时配置

事务超时（Transaction Timeout）指从事务开始到提交或回滚的最大允许时间。超过该时间，事务管理器自动触发回滚，防止资源无限期占用。

4.1.1 超时配置层级

4.1.2 超时配置示例

// 声明式超时配置
@Transactional(timeout = 10, rollbackFor = Exception.class)
public Order createOrder(OrderRequest request) {
    // 业务逻辑：库存扣减、支付、积分更新
    inventoryService.deduct(request.getSkuId(), request.getQuantity());
    paymentService.charge(request.getUserId(), request.getAmount());
    pointService.add(request.getUserId(), request.getAmount() / 10);
    return orderRepository.save(buildOrder(request));
}

// 编程式超时配置
public Order createOrderWithTimeout(OrderRequest request) {
    TransactionTemplate template = new TransactionTemplate(transactionManager);
    template.setTimeout(5); // 5秒超时
    return template.execute(status -> {
        inventoryService.deduct(request.getSkuId(), request.getQuantity());
        paymentService.charge(request.getUserId(), request.getAmount());
        pointService.add(request.getUserId(), request.getAmount() / 10);
        return orderRepository.save(buildOrder(request));
    });
}

4.2 声明式回滚与编程式回滚

回滚策略决定了事务在何种异常条件下撤销已执行的操作。Spring 提供了声明式和编程式两种回滚控制方式，各有适用场景。

4.2.1 声明式回滚

通过 @Transactional 注解的 rollbackFor、noRollbackFor 属性声明回滚规则，代码侵入性低，适合大多数业务场景。

@Transactional(rollbackFor = {BusinessException.class, DataIntegrityViolationException.class},
               noRollbackFor = {OptimisticLockException.class})
public void updateInventory(Long skuId, Integer quantity) {
    Inventory inventory = inventoryRepository.findBySkuId(skuId);
    if (inventory.getStock() < quantity) {
        throw new BusinessException("库存不足");
    }
    inventory.setStock(inventory.getStock() - quantity);
    inventoryRepository.save(inventory);
}

4.2.2 编程式回滚

通过 TransactionStatus.setRollbackOnly() 或 TransactionTemplate 的 TransactionCallback 返回值控制回滚，适合需要精细控制回滚边界的场景。

public void batchProcess(List<Order> orders) {
    TransactionTemplate template = new TransactionTemplate(transactionManager);
    template.execute(status -> {
        for (Order order : orders) {
            try {
                processSingleOrder(order);
            } catch (BusinessException e) {
                // 记录失败订单，继续处理其他订单
                log.warn("订单 {} 处理失败: {}", order.getId(), e.getMessage());
                failedOrders.add(order.getId());
                // 不设置 rollbackOnly，当前订单回滚但事务继续
                status.setRollbackOnly(); // 实际需要根据业务决定
            }
        }
        return null;
    });
}

4.2.3 两种方式对比

4.3 回滚规则最佳实践

回滚规则的设计直接影响事务边界调试的效率。以下实践基于生产环境经验总结，帮助你在开发阶段建立正确的回滚策略。

4.3.1 回滚规则决策流程

4.3.2 回滚规则配置清单

4.3.3 常见回滚陷阱

4.3.4 可观测性集成建议

在开发环境调试事务回滚时，结合可观测性工具可以快速定位问题根因：

• 日志标记：在事务开始和结束处打印 transactionId、timeout、rollback 状态，便于链路追踪。
• 指标监控：记录事务执行时间、回滚次数、超时次数等指标，通过 Prometheus + Grafana 可视化。
• 分布式追踪：使用 OpenTelemetry 或 SkyWalking 标记事务边界，观察跨服务调用的事务传播行为。

// 可观测性增强的事务模板
public <T> T executeWithObservability(String transactionName, TransactionCallback<T> action) {
    long start = System.currentTimeMillis();
    String transactionId = UUID.randomUUID().toString();
    log.info("事务开始: id={}, name={}", transactionId, transactionName);
    try {
        T result = transactionTemplate.execute(action);
        long duration = System.currentTimeMillis() - start;
        log.info("事务成功: id={}, name={}, duration={}ms", transactionId, transactionName, duration);
        metricsCollector.recordTransaction(transactionName, duration, true);
        return result;
    } catch (Exception e) {
        long duration = System.currentTimeMillis() - start;
        log.error("事务回滚: id={}, name={}, duration={}ms, error={}", 
                   transactionId, transactionName, duration, e.getMessage());
        metricsCollector.recordTransaction(transactionName, duration, false);
        throw e;
    }
}

4.4 事务边界调试实战

在开发环境调试事务超时与回滚时，建议遵循以下步骤：

1. 配置最小超时：将全局超时设置为 3-5 秒，快速暴露慢事务。
2. 启用 SQL 日志：通过 spring.jpa.show-sql=true 或 MyBatis 日志观察实际 SQL 执行时间。
3. 模拟异常场景：使用 Mock 框架模拟远程服务超时、数据库锁等待等异常。
4. 验证回滚行为：检查数据库数据是否恢复到事务开始前的状态。
5. 分析链路追踪：通过 Jaeger 或 Zipkin 查看事务的完整调用链，确认超时节点。