如何配置等价于@Transactional的TransactionInterceptor并解决Poller事务顺序问题

问题现象 #

基于Spring Boot + Spring Data JPA全自动配置环境，尝试通过自定义PollerMetaData Bean为JdbcPollingChannelAdapter的UPDATE查询添加事务控制，但实际执行时UPDATE操作完成后才触发事务拦截器，开启TRACE日志后看到如下提示：

无需为 [org.springframework.integration.endpoint.AbstractPollingEndpoint$$Lambda$861/0x0000000800832520.call] 创建事务：此方法非事务性方法。

问题原因 #

1. 未明确配置TransactionInterceptor的事务属性匹配规则，导致拦截器无法识别需要事务包裹的目标方法
2. 事务拦截器未正确绑定到JdbcPollingChannelAdapter的核心轮询执行逻辑（receive()方法）

解决方案 #

修改PollerMetaDataConfigurer配置，为TransactionInterceptor添加明确的方法匹配规则，确保事务包裹轮询查询+UPDATE的完整流程：

@Configuration
public class PollerMetaDataConfigurer {
    private final PlatformTransactionManager transactionManager;

    public PollerMetaDataConfigurer(PlatformTransactionManager transactionManager) {
        this.transactionManager = transactionManager;
    }

    @Bean("CustomPoller")
    PollerMetadata getCustomPollermetaData(){
        PollerMetadata transactionConfiguredPoller = new PollerMetadata();
        
        // 配置事务基础属性：设置传播行为为REQUIRED
        DefaultTransactionAttribute transactionAttribute = new DefaultTransactionAttribute();
        transactionAttribute.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        
        TransactionInterceptor transactionInterceptor = new TransactionInterceptor();
        transactionInterceptor.setTransactionManager(transactionManager);
        
        // 指定拦截规则：匹配MessageSource的receive开头方法
        Properties transactionAttributes = new Properties();
        transactionAttributes.setProperty("receive*", transactionAttribute.toString());
        transactionInterceptor.setTransactionAttributes(transactionAttributes);

        List<Advice> pollerAdvice = new LinkedList<>();
        pollerAdvice.add(transactionInterceptor);
        transactionConfiguredPoller.setAdviceChain(pollerAdvice);
        transactionConfiguredPoller.setTrigger(new PeriodicTrigger(2000));
        return transactionConfiguredPoller;
    }
}

关键说明 #

• 改用构造注入替代字段注入，符合Spring依赖注入的最佳实践
• 通过transactionAttributes配置receive*方法匹配规则，确保事务拦截器作用于JdbcPollingChannelAdapter的核心轮询方法
• 设置事务传播行为为PROPAGATION_REQUIRED，保证每次轮询操作都在独立事务中执行，查询和UPDATE操作同属一个事务

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