如何配置多JmsListener监听多Topic？单Topic无消费者问题咨询

先给你个明确结论：不一定必须为每个JmsListener配置独立的jmsListenerContainerFactory，但如果你的两个Listener有不同的配置需求，或者当前共用工厂的配置导致其中一个无法正常注册，那独立配置工厂就成了必要操作。

常见导致问题的原因 #

• Destination类型不匹配：比如一个监听Topic，一个监听Queue，但你的默认工厂只配置了适配其中一种类型（比如默认pubSubDomain=false适配Queue，那Topic的Listener就无法正确注册消费者）。
• 配置参数冲突：如果两个Listener共用同一个工厂，但其中一个需要特定的并发数、消息选择器或会话模式，全局的工厂配置可能会导致另一个Listener无法正常初始化。
• Listener注解配置失误：比如其中一个Listener的destination名称拼写错误，或者当你有多个工厂时，没在注解里指定对应的containerFactory（默认只会用名为jmsListenerContainerFactory的Bean）。
• 持久化订阅的客户端ID冲突：如果是Topic的持久化订阅，两个Listener用了相同的客户端ID，会导致第二个订阅被覆盖，控制台自然看不到第二个消费者。

什么时候需要独立的容器工厂？ #

当你的两个Listener有不同的配置需求时，就需要分别配置：
比如一个是Queue监听，一个是Topic的持久化订阅，那你可以这么配置：

1. 定义多个容器工厂Bean：

@Bean
public DefaultJmsListenerContainerFactory queueContainerFactory(ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setPubSubDomain(false); // 适配Queue
    factory.setConcurrency("1-3"); // 设置并发数
    return factory;
}

@Bean
public DefaultJmsListenerContainerFactory topicContainerFactory(ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setPubSubDomain(true); // 适配Topic
    factory.setSubscriptionDurable(true); // 开启持久化订阅
    factory.setClientId("unique-client-id"); // 唯一客户端ID
    return factory;
}

2. 在Listener注解中指定对应的工厂：

@JmsListener(destination = "order-queue", containerFactory = "queueContainerFactory")
public void handleOrderQueue(String message) {
    // 处理队列消息逻辑
}

@JmsListener(destination = "notification-topic", containerFactory = "topicContainerFactory")
public void handleNotificationTopic(String message) {
    // 处理主题消息逻辑
}

额外排查建议 #

如果两个Listener配置相同还是出现问题，可以检查：

• 确认Topic/Queue名称完全正确，没有拼写错误
• 刷新ActiveMQ控制台页面，有时候控制台会有显示延迟
• 查看项目启动日志，是否有某个Listener初始化失败的报错信息

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