ActiveMQ Artemis选择器可浏览消息但无法接收的问题排查求助

核心问题 #

使用ActiveMQ Artemis 2.18.0及对应版本客户端依赖时，出现低概率异常：约每10万条消息中有30条，通过JMSMessageID='some-id'选择器可通过QueueBrowser浏览到，但MessageConsumer.receive()返回null，无法接收。

可能的根因方向 #

1. 事务会话的消息可见性冲突：使用SESSION_TRANSACTED会话时，浏览器的浏览操作可能导致消息临时状态变更，或后续消费者创建时服务端未正确匹配选择器。
2. JMSMessageID匹配精度问题：构造选择器时的ID与实际消息的JMSMessageID存在细微差异（比如前缀、大小写、特殊字符转义），导致消费者选择器匹配失败。
3. 消息状态异常：消息可能处于未投递、锁定或半处理状态，浏览器能读取但消费者无法获取。
4. 版本已知bug：Artemis 2.18.0存在选择器匹配、事务会话消息路由的已知问题，后续版本已修复。

调试步骤 #

• 校验ID一致性：浏览消息时打印message.getJMSMessageID()，与构造选择器的id完全对比，确认无格式、大小写、前缀差异（Artemis的JMSMessageID通常以ID:开头）。
• 排除事务干扰：临时将会话改为非事务性（createSession(false, Session.AUTO_ACKNOWLEDGE)），测试是否能正常接收，定位是否为事务机制导致。
• 延长接收超时：将receive(1000)改为receive(5000)，排除网络延迟或服务端处理慢导致的超时问题。
• 查看服务端日志：开启Artemis调试日志（配置logging.properties中org.apache.activemq.artemis.core.server为DEBUG），查看消息路由、选择器匹配、消息状态变更的详细记录，确认服务端是否将消息推送给消费者。
• 检查服务端消息状态：用Artemis CLI命令（./artemis browse --queue hospital --filter "JMSMessageID='some-id'"）查看消息的详细属性，包括是否被锁定、过期、是否有活跃消费者。
• 复用会话资源：在同一个会话中，浏览后不关闭浏览器直接创建消费者，或创建消费者后再浏览，测试是否能匹配到消息。

代码调整尝试 #

修改代码增加ID校验、二次确认逻辑，排查中间状态变化：

Connection connection = null;
Session session = null;
String selector = "JMSMessageID='" + id + "'";
try {
    connection = activeMQJMSConnectionFactory.createConnection();
    session = connection.createSession(true, Session.SESSION_TRANSACTED);
    Queue deadQueue = session.createQueue("hospital");
    connection.start();

    // 浏览并校验消息ID
    QueueBrowser browser = session.createBrowser(deadQueue, selector);
    Enumeration<?> e = browser.getEnumeration();
    Message foundMessage = null;
    while (e.hasMoreElements()) {
        foundMessage = (Message) e.nextElement();
        String browsedId = foundMessage.getJMSMessageID();
        System.out.println("Browsed message ID: " + browsedId);
        System.out.println("Target selector ID: " + id);
        if (!browsedId.equals(id)) {
            throw new IllegalStateException("ID mismatch: browsed vs selector");
        }
    }
    browser.close();
    if (foundMessage == null) {
        throw new IllegalStateException("No message found via browser");
    }

    // 创建消费者并延长超时接收
    MessageConsumer messageConsumer = session.createConsumer(deadQueue, selector);
    Message receive = messageConsumer.receive(5000);
    if (receive == null) {
        // 二次浏览确认消息是否仍存在
        browser = session.createBrowser(deadQueue, selector);
        e = browser.getEnumeration();
        int remainingCount = 0;
        while (e.hasMoreElements()) {
            e.nextElement();
            remainingCount++;
        }
        browser.close();
        throw new IllegalStateException(
            String.format("Receive returned null, but browser found %d remaining messages", remainingCount)
        );
    }
    System.out.println("Received message ID: " + receive.getJMSMessageID());
    messageConsumer.close();

    session.commit();
    session.close();
} catch (Exception e) {
    try {
        if (session != null) {
            session.rollback();
            session.close();
        }
    } catch (JMSException e1) {
        e1.printStackTrace();
    }
    throw new RuntimeException(e);
} finally {
    if (connection != null) {
        try {
            connection.close();
        } catch (JMSException e) {
            throw new RuntimeException(e);
        }
    }
}

版本升级建议 #

ActiveMQ Artemis 2.18.0是2021年发布的旧版本，存在多个已知的选择器匹配、事务会话处理的bug。建议升级到最新稳定版本（如2.30.0+），多数类似问题已在后续版本中修复。

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