Spring整合RabbitMQ动态创建队列添加到监听器报错及监听器定义问询

报错原因 #

你遇到的NullPointerException根本原因是rabbitListenerEndpointRegistry.getListenerContainer(listenerId)返回了null，导致后续调用addQueueNames方法时空指针。触发这个问题的直接错误在你的addNewQueue方法中：
你调用addQueueToListener时传入的第一个参数是交换机名称exchangeName，但这个参数要求的是RabbitMQ监听器的唯一ID，两者完全不匹配，自然查不到对应的监听器容器。

正确定义RabbitMQ监听器的方法 #

要实现动态添加队列到监听器，你需要先定义带明确ID的Rabbit监听器，示例如下：
首先配置监听器容器工厂（如果未提前配置）：

@Configuration
public class RabbitMqConfig {
    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        // 开启自动启动，保证服务启动后监听器容器就初始化完成
        factory.setAutoStartup(true);
        // 可根据业务需求调整并发消费数
        factory.setConcurrentConsumers(2);
        factory.setMaxConcurrentConsumers(5);
        return factory;
    }
}

然后定义消息监听器，指定唯一ID：

@Component
public class ActivityMessageConsumer {
    // 此处id属性的值就是你后续调用addQueueToListener时要传入的listenerId
    // 不需要提前指定queues属性，后续可以动态添加队列
    @RabbitListener(id = "activityMsgListener", containerFactory = "rabbitListenerContainerFactory")
    public void consumeActivityMsg(String msgContent) {
        // 此处编写你的业务消息处理逻辑
        System.out.println("接收到活动队列消息：" + msgContent);
    }
}

现有代码修复 #

1. 修改addNewQueue方法的调用参数，把原来传入的exchangeName替换为你定义监听器时设置的ID：

// 原来的错误写法
// this.addQueueToListener(exchangeName,queueName);
// 修正后的写法，参数值要和@RabbitListener的id属性完全一致
this.addQueueToListener("activityMsgListener",queueName);

2. 给getMessageListenerContainerById方法添加空校验，避免未捕获的空指针：

private AbstractMessageListenerContainer getMessageListenerContainerById(String listenerId) {
    log.info("getting message listener container by id : " + listenerId);
    MessageListenerContainer container = this.rabbitListenerEndpointRegistry.getListenerContainer(listenerId);
    if (container == null) {
        log.error("未找到ID为{}的监听器容器，请检查监听器配置是否正确", listenerId);
        throw new IllegalArgumentException("不存在ID为" + listenerId + "的监听器容器");
    }
    return (AbstractMessageListenerContainer) container;
}

注意事项 #

• 监听器的ID必须全局唯一，不能和其他@RabbitListener的id重复
• 如果你的项目中需要多个不同的监听器处理不同业务的队列，可以定义多个带不同ID的@RabbitListener，调用时传入对应业务的监听器ID即可

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