如何用Spring Tx同步多资源事务？规避已弃用ChainTransactionManager

问题场景与初始实现 #

需要同步操作三个资源：关联JpaRepository的Oracle数据库、关联MongoRepository的MongoDB、配置好的Kafka主题，已分别配置对应的JpaTransactionManager、MongoTransactionManager和自动创建的KafkaTransactionManager。

初始实现思路：

1. 控制器注入SimpleService，调用其事务方法

@RestController
public class SimpleController {

    @Autowired
    private SimpleService simpleService;

    @PostMapping("/doTx")
    public Response doTx() {
        simpleService.doTx();
        return Response.success();
    }
}

2. SimpleService注入三个资源服务，通过声明式事务控制全局流程

@Service
public class SimpleService {

    @Autowired
    private OracleService oracleService;
    @Autowired
    private MongoService mongoService;
    @Autowired
    private KafkaService kafkaService;

    @Transactional
    public void doTx() {
        oracleService.doTx();
        mongoService.doTx();
        kafkaService.doTx();
    }
}

3. 各资源服务方法也标注@Transactional，期望加入主事务

@Service
public class OracleService {

    @Autowired
    private JpaRepository jpaRepository;

    @Transactional
    public void doTx() {
        jpaRepository.save(...);
    }
}

遇到的问题 #

上述方案无法实现预期：子服务的事务会在方法调用完成后立即提交，而非等待SimpleService.doTx()执行完毕后统一提交。仅当所有资源操作放在同一方法中时才能同步，但无法自定义提交顺序。

问题分析 #

Spring声明式事务默认的传播行为是REQUIRED，但不同事务管理器的事务无法自动纳入同一个全局事务。子服务方法标注的@Transactional会因为指定（或默认）的事务管理器与主事务不同，创建独立的事务上下文，导致操作执行后立即提交。

你参考的Spring Kafka示例中，dstm是一个复合事务管理器（如早期的ChainedTransactionManager），它能整合多个事务管理器的事务生命周期，从而实现嵌套事务的同步效果，但该类已被弃用。

解决方案（不使用弃用的ChainTransactionManager） #

要实现Best Effort 1 Phase Commit（允许数据不一致，可补偿，核心是主方法末尾依次提交），可以通过编程式事务管理手动控制各个资源事务的生命周期，自定义提交/回滚顺序。

具体实现 #

1. 修改SimpleService，手动管理事务

@Service
public class SimpleService {

    @Autowired
    private PlatformTransactionManager oracleTxManager;
    @Autowired
    private PlatformTransactionManager mongoTxManager;
    @Autowired
    private PlatformTransactionManager kafkaTxManager;

    @Autowired
    private OracleService oracleService;
    @Autowired
    private MongoService mongoService;
    @Autowired
    private KafkaService kafkaService;

    public void doTx() {
        TransactionStatus oracleStatus = null;
        TransactionStatus mongoStatus = null;
        TransactionStatus kafkaStatus = null;

        try {
            // 开启各资源的独立事务
            oracleStatus = oracleTxManager.getTransaction(new DefaultTransactionDefinition());
            mongoStatus = mongoTxManager.getTransaction(new DefaultTransactionDefinition());
            kafkaStatus = kafkaTxManager.getTransaction(new DefaultTransactionDefinition());

            // 执行所有资源操作（此时操作未提交）
            oracleService.doTx();
            mongoService.doTx();
            kafkaService.doTx();

            // 按自定义顺序提交事务（Best Effort 1PC：提交失败时已提交的资源无法回滚，需后续补偿）
            oracleTxManager.commit(oracleStatus);
            mongoTxManager.commit(mongoStatus);
            kafkaTxManager.commit(kafkaStatus);
        } catch (Exception e) {
            // 异常时回滚已开启的事务，回滚顺序建议与提交顺序相反
            if (kafkaStatus != null) {
                try {
                    kafkaTxManager.rollback(kafkaStatus);
                } catch (Exception rollbackEx) {
                    // 记录回滚异常，后续通过补偿机制处理
                }
            }
            if (mongoStatus != null) {
                try {
                    mongoTxManager.rollback(mongoStatus);
                } catch (Exception rollbackEx) {
                    // 记录回滚异常，后续通过补偿机制处理
                }
            }
            if (oracleStatus != null) {
                try {
                    oracleTxManager.rollback(oracleStatus);
                } catch (Exception rollbackEx) {
                    // 记录回滚异常，后续通过补偿机制处理
                }
            }
            throw new RuntimeException("事务执行失败，已尝试回滚", e);
        }
    }
}

2. 修改子服务，移除@Transactional

@Service
public class OracleService {

    @Autowired
    private JpaRepository jpaRepository;

    // 移除@Transactional，由上层SimpleService统一控制事务
    public void doTx() {
        jpaRepository.save(...);
    }
}

MongoService和KafkaService做同样修改，确保操作在SimpleService开启的事务上下文中执行。

方案说明 #

• 手动控制每个事务的开启、执行、提交/回滚流程，确保所有资源操作完成后再按自定义顺序提交，符合Best Effort 1PC的要求。
• 异常时尽量回滚所有已开启的事务，但如果某资源回滚失败，需要通过补偿机制（如重试、人工介入）处理数据不一致问题。

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