Spring Boot中@Transactional如何手动强制提交 跨服务调用获取最新数据

核心原因说明 #

Spring声明式事务@Transactional默认会在被修饰的方法全部执行完成后才提交事务，因此方法内部先执行数据库操作、再调用跨服务接口时，数据库修改尚未落库，第三方服务自然无法查询到最新数据。

可选实现方案 #

方案1：拆分事务边界（最推荐） #

将数据库保存逻辑单独抽离到独立的@Transactional方法，调用该方法后事务会自动提交，再执行跨服务调用即可。需要注意必须通过Spring代理对象调用抽离的方法，否则事务注解不生效：

@Service
public class BizService {
    // 注入自身代理，搭配@Lazy避免循环依赖问题
    @Lazy
    @Autowired
    private BizService bizServiceProxy;
    @Autowired
    private ServiceA serviceA;

    // 外层业务方法不需要加@Transactional
    public void processBiz(X x) {
        // 调用代理方法，执行完成后事务自动提交
        bizServiceProxy.saveXData(x);
        // 此时数据已落库，再调用跨服务接口
        syncToOtherServiceWithAPI(x.getId());
    }

    @Transactional(rollbackFor = Exception.class)
    public void saveXData(X x) {
        serviceA.save(x);
    }

    private void syncToOtherServiceWithAPI(Long xId) {
        // 第三方接口调用逻辑
    }
}

方案2：注册事务提交后回调 #

如果不想拆分方法，可以通过Spring事务同步器注册回调，将跨服务调用逻辑放到事务提交完成后执行：

@Transactional(rollbackFor = Exception.class)
public void processBiz(X x) {
    serviceA.save(x);
    // 校验当前处于事务上下文
    if (TransactionSynchronizationManager.isActualTransactionActive()) {
        // 注册事务提交后回调
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCommit() {
                // 事务提交成功后才会执行接口调用
                syncToOtherServiceWithAPI(x.getId());
            }
        });
    }
}

注意：该方案下回调逻辑的异常不会触发原有事务回滚，因为执行回调时事务已经提交完成，需要自行添加重试、兜底补偿逻辑保证接口调用可靠性。

方案3：编程式事务手动控制提交 #

如果需要灵活控制事务提交时机，可以放弃声明式事务，改用PlatformTransactionManager手动管理事务：

@Autowired
private PlatformTransactionManager transactionManager;
@Autowired
private ServiceA serviceA;

public void processBiz(X x) {
    DefaultTransactionDefinition txDef = new DefaultTransactionDefinition();
    txDef.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
    TransactionStatus txStatus = transactionManager.getTransaction(txDef);
    try {
        serviceA.save(x);
        // 手动提交事务
        transactionManager.commit(txStatus);
    } catch (Exception e) {
        // 异常时手动回滚
        transactionManager.rollback(txStatus);
        throw e;
    }
    // 提交完成后调用接口
    syncToOtherServiceWithAPI(x.getId());
}

内容的提问来源于stack exchange，提问作者devina thessalonica