Spring Boot集成IBM MQ时@JmsListener方法未触发问题求助

以下是排查和解决的核心关键点：

1. 补全队列名称配置 #

你的监听器使用了${mq.queue-name}占位符，但application.properties中未定义该属性，导致监听器无法绑定到正确队列。在配置文件中添加：

mq.queue-name=你的目标队列名称

2. 修正消息转换器配置 #

MappingJackson2MessageConverter默认要求消息携带content-type属性为application/json，但IBM MQ发送的消息往往未设置该属性，会导致转换失败，进而静默跳过监听器方法执行。可以修改转换器配置使其兼容普通文本消息：

@Bean
public MessageConverter messageConverter() {
    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
    converter.setTargetType(MessageType.TEXT);
    converter.setTypeIdPropertyName("_type");
    return converter;
}

也可以暂时移除自定义消息转换器，使用默认转换器测试监听器是否能正常触发。

3. 配置IBM MQ专属监听器容器工厂 #

IBM MQ的JMS连接工厂需要适配特定的容器工厂配置，在配置类中添加以下Bean：

@Bean
public JmsListenerContainerFactory<?> mqListenerContainerFactory(ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setConcurrency("1-3");
    factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
    return factory;
}

然后在监听器注解中指定该工厂：

@JmsListener(destination = "${mq.queue-name}", containerFactory = "mqListenerContainerFactory")

4. 提升日志级别排查细节 #

默认日志级别无法展示JMS连接和订阅的关键细节，在application.properties中添加日志配置：

logging.level.org.springframework.jms=DEBUG
logging.level.com.ibm.mq=DEBUG

启动应用后查看日志，确认是否成功连接到MQ队列管理器，以及是否正确订阅了目标队列。

5. 检查MQ队列权限 #

确保配置的ibm.mq.user账号拥有目标队列的GET读取权限，可通过MQ控制台或命令行工具检查队列的权限配置。

6. 调整监听器方法参数类型 #

如果队列中的消息不是TextMessage类型（比如BytesMessage），强制转换会引发异常且可能被Spring JMS静默处理。可以先修改方法参数为通用Message类型，打印消息类型排查：

@JmsListener(destination = "${mq.queue-name}")
public void receive(Message message) throws JMSException {
    System.out.println("Received message type: " + message.getClass().getName());
    if (message instanceof TextMessage) {
        TextMessage textMessage = (TextMessage) message;
        System.out.println("Message content: " + textMessage.getText());
        // 业务逻辑
    } else if (message instanceof BytesMessage) {
        BytesMessage bytesMessage = (BytesMessage) message;
        byte[] data = new byte[(int) bytesMessage.getBodyLength()];
        bytesMessage.readBytes(data);
        System.out.println("Bytes message content: " + new String(data));
    }
}

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