Spring Integration DSL中transactional()事务行为咨询

结论 #

你当前写的.transactional()配置根本达不到你要的效果：既保证不了「插入成功才提交删除」的事务原子性，甚至连「先删、后插」的执行顺序都保证不了。

问题出在哪 #

• 第一是事务挂错了位置：你把事务定义加在routeToRecipients的路由配置上，这个事务的覆盖范围只有「计算要把消息发给哪些收件人、把消息派发到各个子流入口」这一段逻辑，根本管不到两个recipientFlow里面跑的JPA操作。两个Jpa更新网关默认会自己开独立事务，执行完就直接提交，和外层路由上挂的事务完全没关系。
• 第二是组件用错了：routeToRecipients是收件人列表路由器，作用是把同一条消息广播给所有符合规则的平级分支，不是用来串顺序步骤的。你把两个操作写在两个recipientFlow里，本质是给同一条消息开了两个平行的处理分支，框架不保证两个分支的执行先后，哪怕你把事务调对了，也可能出现先插数据、再删表的离谱结果。

正确写法 #

要实现「先清空表、再写新数据，两步绑在一个事务里，写失败就回滚删除」的逻辑，别用路由器串步骤，直接把两个JPA操作按顺序写在主流上，把事务加在整个处理链路的最外层就行：

@Bean
IntegrationFlow myFlow(
        EntityManagerFactory entityManagerFactory,
        TransactionManager transactionManager
) {
    return IntegrationFlows.from(MY_CHANNEL)
            .transactional(transactionManager) // 事务包住整个处理流程
            .handle(Jpa.updatingGateway(entityManagerFactory)
                    .namedQuery(DELETE_EVERYTHING)) // 第一步：执行全表删除
            .handle(Jpa.updatingGateway(entityManagerFactory)) // 第二步：写入新数据
            .get();
}

这种配置下两个JPA操作会按顺序执行，且共用同一个事务上下文：如果写数据的时候抛了异常，整个事务直接回滚，之前的删除操作不会落到数据库里；只有两步都跑通了，事务才会统一提交。

官方文档对应说明位置 #

对应的规则在Spring Integration官方文档的两个章节可以查到：

• 事务支持（Transaction Support）章节：明确说明事务拦截器的边界和它挂载的组件位置完全绑定，只有在该组件直接管辖的处理链路里的逻辑才会被纳入事务，下游独立的子流默认不会自动继承上游的事务配置，除非手动把事务传播级别设为REQUIRED且全程在同一个线程里执行。
• 收件人列表路由器（Recipient List Router）章节：明确说明该路由器的所有分支是平级的广播分发逻辑，不承诺分支执行顺序，要做串行步骤编排直接在主流程按顺序挂处理节点就行，不要拿路由器当串联组件用。

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