SourcePollingChannelAdapterSpec的sendTimeout失效，手动创建适配器正常

问题分析 #

你遇到的核心问题是：IntegrationFlow DSL中通过Pollers.sendTimeout()设置的超时，和手动创建SourcePollingChannelAdapter时调用setSendTimeout()的作用完全不同，导致配置失效、轮询线程阻塞。

• 手动创建时的spcAdapter.setSendTimeout(500)：控制适配器向输出通道发送消息的超时，当通道是有界队列且无消费者时，超时后会抛出异常，避免线程阻塞。
• DSL中Pollers.sendTimeout(1)：控制的是轮询任务本身的执行超时（从启动轮询到任务结束的最长时间），而非发送消息到通道的超时，因此无法解决队列满时的阻塞问题。

解决方案 #

在IntegrationFlow的配置回调中，直接通过SourcePollingChannelAdapterSpec.sendTimeout()设置发送到输出通道的超时，而非在Poller配置中设置：

修改后的DSL配置代码：

@Configuration
public class JdbcDSLConfig {

    @Bean
    public QueueChannelSpec jdbcInboundChannel() {
        return MessageChannels.queue(1);
    }

    @Bean
    public MessageSource<Object> jdbcMessageSource(final DataSource dataSource) {
        return new CustomJdbcPollingChannelAdapter(dataSource, "select dp_id, dp_payload from data_packets");
    }

    @Bean
    public ThreadPoolTaskScheduler jdbcTaskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(1);
        taskScheduler.initialize();
        return taskScheduler;
    }

    @Bean
    public IntegrationFlow jdbcInboundFlow(final MessageSource<Object> jdbcMessageSource,
                                           final QueueChannelSpec jdbcInboundChannel,
                                           @Qualifier("jdbcTaskScheduler") final ThreadPoolTaskScheduler jdbcTaskScheduler) {
        return IntegrationFlow.from(jdbcMessageSource,
                        c -> c.poller(Pollers
                                .fixedDelay(2000)
                                .taskScheduler(jdbcTaskScheduler))
                              .sendTimeout(1)) // 此处设置发送到通道的超时
                .channel(jdbcInboundChannel)
                .get();
    }
}

额外说明 #

1. 配置项区分：
   • SourcePollingChannelAdapterSpec.sendTimeout()：对应手动创建时的setSendTimeout()，专门处理消息向输出通道发送的超时逻辑。
   • Pollers.sendTimeout()：用于限制轮询任务的整体执行时长，不影响消息发送到通道的操作。
2. 线程池适配：建议使用ThreadPoolTaskScheduler而非ThreadPoolTaskExecutor，与手动配置保持一致，避免Spring内部适配带来的潜在问题。

内容的提问来源于stack exchange，提问作者D-Dᴙum