IBM MQ远程队列消息随机滞留排查与解决咨询（Selector场景）

我们遇到远程队列消息随机滞留问题：

• 应用使用Message Selector消费消息时，会出现消息滞留，重启客户端后消息可被重新消费；不使用Selector则无此问题。
• 20个Listener指向同一队列，各配置不同Selector，故障发生时仅部分Listener受影响，客户端无错误日志。
• 环境信息：IBM MQ 9.3、Spring Boot 3.0、com.ibm.mq.jakarta.client 9.4.0.0
• 核心代码实现：

DefaultMessageListenerContainer listenerContainer = new DefaultMessageListenerContainer();
listenerContainer.setConnectionFactory(cachingConnectionFactory);
listenerContainer.setMessageListener(eventListener);
listenerContainer.setDestinationName(queueName);
listenerContainer.setConcurrency(String.valueOf(getConcurrency(containerSuffix)));
listenerContainer.setMessageSelector(buildSelector(containerSuffix, tableName));
jmsContainerMap.put(containerSuffix, listenerContainer);
context.registerBean("container" + containerSuffix, DefaultMessageListenerContainer.class, () -> listenerContainer);
context.getBean("container" + containerSuffix, DefaultMessageListenerContainer.class).start();

根因排查方法 #

• 验证Selector与消息属性的匹配有效性
  1. 提取受影响Listener的Selector表达式，直接在MQ控制台（如MQ Explorer）对目标队列执行查询，确认是否能匹配到滞留消息。
  2. 查看滞留消息的实际属性值，检查是否存在属性类型不匹配（比如用字符串匹配数字属性）、属性名大小写不一致（MQ属性名大小写敏感）的情况。
• 排查MQ端Selector处理逻辑
  1. 开启MQ客户端DEBUG日志（日志级别设为DEBUG，包路径com.ibm.mq.jakarta），查看Selector解析、消息过滤的详细过程，确认客户端是否正确应用了规则。
  2. 检查MQ服务端日志（如AMQERR01.LOG），排查是否存在Selector相关的警告或兼容性异常。
• 检查Listener容器的连接会话状态
  1. 查看CachingConnectionFactory配置，确认是否开启了会话/消费者缓存，缓存的旧会话可能未加载最新Selector规则，导致无法匹配新消息。
  2. 通过MQ控制台查看受影响Listener对应的会话状态，确认会话是否绑定了预期的Selector。
• 排查并发消费资源竞争
  1. 核对各Listener的concurrency配置，检查是否有Listener并发数过高，抢占了队列消费资源，导致其他Listener无法获取匹配消息。
  2. 验证队列MAXDEPTH和MAXMSGL设置，排除因队列满导致的消息滞留（该情况通常有日志提示）。

解决方案 #

• 规范Selector与消息属性匹配规则
  1. 确保Selector的属性名、类型与消息实际属性完全一致，避免类型不匹配（比如不用字符串匹配数字属性）。
  2. 动态生成Selector时，添加单元测试验证表达式正确性，避免生成无效或歧义规则。
• 调整连接工厂缓存策略
  1. 针对CachingConnectionFactory，关闭消费者缓存（设置setCacheConsumers(false)），或调整缓存过期时间，确保Listener能重新创建带正确Selector的会话。
  2. 若必须用缓存，可在出现滞留时手动触发连接重置（调用connectionFactory.resetConnection()），替代客户端重启。
• 优化Listener容器配置
  1. 改用@JmsListener注解的自动配置方式，让Spring管理容器生命周期，减少手动初始化导致的会话异常。
  2. 为每个Listener配置独立会话（设置listenerContainer.setCacheLevel(DefaultMessageListenerContainer.CACHE_NONE)），避免共享会话引发Selector干扰。
• 升级MQ版本或应用补丁
  1. 核对IBM MQ版本兼容性矩阵，确认9.4.0.0客户端与9.3服务端是否存在Selector相关已知BUG，如有则升级到兼容版本（比如客户端降级到9.3.x，或服务端升级到9.4）。
  2. 应用IBM MQ官方最新补丁，修复已知的Selector处理问题。

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