Spring Integration：消息无法从QueueChannel1流转到QueueChannel2问题排查

问题出在QueueChannel的特性和你的IntegrationFlow配置上：QueueChannel是异步队列通道，默认情况下，以它为起点的IntegrationFlow需要配置**轮询器（Poller）**才能主动从队列拉取消息，否则消息会一直滞留在queueChannel1中，无法触发后续的处理逻辑。

修改方法 #

在testflow2的from方法中添加轮询器配置，示例如下：

@Bean
public IntegrationFlow testflow2() {
    return IntegrationFlow.from("queueChannel1", spec -> spec.poller(Pollers.fixedDelay(100))) // 添加固定延迟轮询器，每隔100ms轮询一次
            .handle((Object payload, MessageHeaders headers) -> {
                return payload;
            })
            .channel("queueChannel2")
            .get();
}

补充说明 #

• QueueChannel基于阻塞队列实现，属于异步通道，和DirectChannel（同步直接转发）的处理逻辑不同，必须通过Poller驱动消费流程。
• 你可以根据业务需求调整轮询器的参数，比如使用Pollers.trigger(new PeriodicTrigger(100))自定义触发规则，或者设置maxMessagesPerPoll控制每次轮询拉取的消息数量。

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