SpringBoot中@JmsListener调用机制及监听方法不触发问题排查

• 注解解析阶段：启动类添加的@EnableJms，会触发Spring注册专门的注解后置处理器，扫描容器内所有Bean的方法，识别标注了@JmsListener的方法，为每个方法生成独立的监听端点。
• 容器创建阶段：Spring会根据端点指定的containerFactory，创建对应的JMS监听器容器实例，和手动编写代码创建的消费容器逻辑完全一致，只是完成了自动装配。
• 实际触发时机：等Spring容器完成所有Bean初始化、完全就绪后，所有监听器容器才会正式启动——通过配置的连接工厂建立MQ连接，拉起独立的消费线程，专门盯着目标队列拉取消息。一旦队列有匹配的消息，容器会完成消息格式转换，反射调用编写的监听方法，整个过程不需要手动编写拉取逻辑。

没有任何报错但方法不触发，本质都是上述某个环节没有正确执行，不存在“机制本身不触发”的情况。

对照贴出的代码，有几个实锤的配置错误，直接会导致监听器不工作：

• 属性注入语法错误：MQConfiguration类中写的@Value("{mq.queueName}") 缺少开头的$符号，正确写法是@Value("${mq.queueName}")。这个错误会把字面字符串{mq.queueName}直接注入到queueName属性，根本读不到配置文件的真实值，属于明显的配置隐患。
• 缺失核心的监听器容器工厂配置：仅自定义了和MQ通信的MQQueueConnectionFactory连接工厂，但没有显式提供供@JmsListener使用的JmsListenerContainerFactory Bean。Spring Boot的JMS自动配置虽然会自动装配默认容器工厂，但自定义连接工厂后，如果没有显式对齐，会出现监听器容器无法正确关联到自定义连接工厂、根本不启动消费线程的情况——这也是进程一直挂着但完全没有消费动作的核心原因。
• 异常吞掉导致配置不完整：初始化MQQueueConnectionFactory的时候，把所有可能的异常都catch住只打印栈信息，没有中断流程。如果中间设置通道、端口、队列管理器参数时抛了异常，连接工厂的配置其实是不完整的，但Spring容器还是会把这个有问题的Bean返回，导致后续建立MQ连接时静默失败，不会抛出明显的启动错误。

• 第一步，补全默认的监听器容器工厂Bean，直接复用自定义的MQ连接工厂，不依赖Spring的自动探测逻辑：

@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory mqQueueConnectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    // 绑定自定义的MQ连接工厂
    factory.setConnectionFactory(mqQueueConnectionFactory);
    // 设置单线程消费，避免多线程并发处理消息出问题
    factory.setConcurrency("1");
    // 设置接收超时，避免线程无限阻塞
    factory.setReceiveTimeout(30000L);
    return factory;
}

这个Bean的默认名字和@JmsListener注解上的默认containerFactory参数完全匹配，不需要在注解上额外指定工厂名称。

• 第二步，修正之前提到的@Value注入语法错误，把缺少$的注解改成Spring能识别的属性占位符写法。
• 第三步，打开JMS模块的调试日志，确认监听器容器真的启动了。在application.properties中加入配置：

logging.level.org.springframework.jms.listener=DEBUG

启动应用后查看日志，如果没有打印“启动JMS监听容器、绑定目标队列XXX”的内容，说明容器根本没被加载，需要回去检查MQListener类有没有被组件扫描到、@EnableJms注解有没有生效。

• 第四步，单独验证自定义的连接工厂连通性：写一个单元测试，注入定义的MQQueueConnectionFactory，手动创建连接、创建会话、拉取一条消息，确认连接参数没有问题。不要假设catch块吞掉异常的连接工厂是正常工作的。
• 第五步，非Web应用的保活验证：因为做的是非Web应用，没有内置Web容器维持主线程运行，要确保主线程不会提前退出，导致消费线程被终止。可以在启动类的main方法里加上阻塞逻辑：

public static void main(String[] args) throws InterruptedException {
    SpringApplication.run(Application.class, args);
    // 阻塞主线程，保持应用持续运行
    new CountDownLatch(1).await();
}

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