Spring集成Pub/Sub使用QueueChannel报无轮询器定义错误如何解决？

QueueChannel是Spring Integration提供的异步缓冲队列通道，消息存入队列后需要消费端主动轮询拉取才能处理。你当前的@ServiceActivator消费注解没有绑定轮询器，Spring上下文也不存在默认轮询器，因此启动时抛出该异常。

共有两种可选方案，按需选择即可：

方案1：为当前消费端单独配置轮询器 #

直接修改@ServiceActivator注解，添加poller属性指定轮询规则：

// 导入Poller注解：import org.springframework.integration.annotation.Poller;
@ServiceActivator(inputChannel = "inputMessageQueueChannel", poller = @Poller(fixedDelay = "100", maxMessagesPerPoll = "1"))
public void messageReceiver(
        String payload,
        @Header(GcpPubSubHeaders.ORIGINAL_MESSAGE) BasicAcknowledgeablePubsubMessage message) {
    log.info("Payload: " + payload);
    message.ack();
}

参数说明：

• fixedDelay：两次轮询的间隔时间，单位为毫秒，可根据消费速度调整
• maxMessagesPerPoll：每次轮询拉取的消息条数，设置为1可以严格控制消费速率，避免批量处理压力

方案2：配置全局默认轮询器 #

如果项目中多个地方用到QueueChannel，可直接配置全局默认轮询器，不需要每个@ServiceActivator单独配置：

import org.springframework.integration.scheduling.PollerMetadata;
import org.springframework.scheduling.support.PeriodicTrigger;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerMetadata defaultPoller() {
    PollerMetadata poller = new PollerMetadata();
    // 每100ms轮询一次
    poller.setTrigger(new PeriodicTrigger(100));
    // 每次轮询最多拉1条消息
    poller.setMaxMessagesPerPoll(1);
    // 可选：配置消费线程池，控制并发处理量
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(2);
    executor.setMaxPoolSize(5);
    executor.setQueueCapacity(10);
    executor.initialize();
    poller.setTaskExecutor(executor);
    return poller;
}

配置完成后所有没有单独指定poller的QueueChannel消费端，都会自动使用该默认轮询器。

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