Spring Boot集成ActiveMQ：message.acknowledge()无法删除已读消息

你用QueueBrowser浏览消息的方式本身存在误区——QueueBrowser是只读组件，仅用于查看队列中的消息，不会将消息标记为待消费状态。这就是为什么调用message.acknowledge()时acknowledgeCallback为null的核心原因：浏览得到的消息并没有被任何消费会话"认领"，自然没有对应的确认回调逻辑，无论怎么调用ack都无法让消息出队。

以下两种方式可以实现「根据requestId获取消息并出队」的需求：

方式一：直接用receiveSelected消费消息 #

Spring JmsTemplate提供了receiveSelected方法，可直接根据消息选择器获取并消费消息，消息会自动出队（具体行为取决于会话确认模式）：

// 设置接收超时时间，避免线程无限阻塞
jmsTemplate.setReceiveTimeout(1000);

Message message = jmsTemplate.receiveSelected("responses", "requestId='"+id+"'");
if (message != null) {
    if (message instanceof ActiveMQObjectMessage objectMessage) {
        try {
            QueueResponse queueResponse = (QueueResponse) objectMessage.getObject();
            String requestId = queueResponse.getRequestId();
            // 执行你的业务逻辑...

            // 若使用CLIENT_ACKNOWLEDGE模式，需手动确认消息
            if (jmsTemplate.getSessionAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE) {
                message.acknowledge();
            }
            return new ResponseEntity<>(... , HttpStatus.OK);
        } catch (Exception exception) {
            return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
        }
    }
}
return new ResponseEntity<>(HttpStatus.NOT_FOUND);

方式二：先浏览再精准消费（适合需先验消息内容的场景） #

如果必须先浏览消息内容再决定是否消费，可以在同一个会话中，先通过浏览器拿到目标消息的JMSMessageID，再用这个ID作为选择器精准消费该消息：

ResponseEntity<OperationResultResponse> result = jmsTemplate.execute(session -> {
    Queue queue = session.createQueue("responses");
    // 第一步：浏览找到目标消息的JMSMessageID
    QueueBrowser browser = session.createBrowser(queue, "requestId='"+id+"'");
    Enumeration<?> enumeration = browser.getEnumeration();
    String targetMessageId = null;
    if (enumeration.hasMoreElements()) {
        Message message = (Message) enumeration.nextElement();
        targetMessageId = message.getJMSMessageID();
    }
    browser.close();

    if (targetMessageId != null) {
        // 第二步：根据JMSMessageID精准消费消息
        Message targetMessage = session.createConsumer(queue, "JMSMessageID='"+targetMessageId+"'").receive(1000);
        if (targetMessage != null) {
            if (targetMessage instanceof ActiveMQObjectMessage objectMessage) {
                QueueResponse queueResponse = (QueueResponse) objectMessage.getObject();
                // 执行你的业务逻辑...

                // 若使用CLIENT_ACKNOWLEDGE模式，手动确认消息
                if (session.getAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE) {
                    targetMessage.acknowledge();
                }
                return new ResponseEntity<>(... , HttpStatus.OK);
            }
        }
    }
    return new ResponseEntity<>(HttpStatus.NOT_FOUND);
}, true); // true表示使用事务会话，提交时会自动确认消息（未使用CLIENT模式时）

• 规避选择器注入风险：直接拼接id可能引发JMS选择器注入问题，建议用工具类转义特殊字符，比如org.apache.commons.text.StringEscapeUtils.escapeEcmaScript(id)。
• 匹配确认模式：若会话为AUTO_ACKNOWLEDGE，消费后自动确认出队；若为CLIENT_ACKNOWLEDGE，必须手动调用acknowledge()；若使用事务会话，需调用session.commit()才会确认消息。
• 合理设置超时：receive或receiveSelected必须设置超时时间，避免线程长期阻塞。

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