本文探讨了activemq artemis 2.18.0中一个特定问题：使用jms选择器可以成功浏览消息，但通过messageconsumer接收时却失败并抛出`illegalstateexception`。该问题通常与使用openwire jms客户端库有关，其根本原因是activemq artemis的已知缺陷artemis-3916。文章提供了两种解决方案：切换到activemq artemis核心jms客户端，或将broker升级至2.25.0及更高版本，并附带了验证代码示例。
问题描述
在使用ActiveMQ Artemis 2.18.0版本，并结合artemis-jms-client-all:2.18.0作为客户端依赖时，开发者可能会遇到一个令人困惑的问题：通过JMS选择器（例如JMSMessageID=’some-id’）可以成功地浏览到目标消息，但当尝试使用MessageConsumer以相同的选择器去接收消息时，却无法获取到消息，导致MessageConsumer.receive()方法返回null，进而抛出IllegalStateException。此问题并非总是发生，而是以一定的概率出现，例如在数万条消息中可能出现数十次。
以下代码片段展示了这种异常行为的核心逻辑：
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; // 注意：此依赖可能包含OpenWireimport javax.jms.*;import java.util.Enumeration;public class MessageReceiveFailureExample { public static void main(String[] args) throws JMSException { Connection connection = null; Session session = null; String messageIdToFind = "some-message-id"; // 假设这是之前发送消息的ID String selector = "JMSMessageID='" + messageIdToFind + "'"; try { ConnectionFactory activeMQJMSConnectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); connection = activeMQJMSConnectionFactory.createConnection(); session = connection.createSession(true, Session.SESSION_TRANSACTED); Queue deadQueue = session.createQueue("hospital"); connection.start(); // 步骤1：使用QueueBrowser浏览消息 // 假设此处能够成功找到一条消息 QueueBrowser browser = session.createBrowser(deadQueue, selector); Enumeration e = browser.getEnumeration(); int foundedElements = 0; while (e.hasMoreElements()) { Message message = (Message) e.nextElement(); System.out.println("Browser found message with ID: " + message.getJMSMessageID()); foundedElements++; } browser.close(); if (foundedElements != 1) { throw new IllegalStateException("Browser did not find exactly one message."); } // 步骤2：尝试使用MessageConsumer接收消息 // 在问题场景中，此处会返回null，导致抛出IllegalStateException MessageConsumer messageConsumer = session.createConsumer(deadQueue, selector); Message receivedMessage = messageConsumer.receive(1000); // 尝试接收消息，等待1秒 if (receivedMessage == null) { throw new IllegalStateException("MessageConsumer failed to receive the message."); // 此处会抛出异常 } System.out.println("MessageConsumer received message with ID: " + receivedMessage.getJMSMessageID()); messageConsumer.close(); session.commit(); session.close(); } catch (Exception e) { System.err.println("An error occurred: " + e.getMessage()); 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 Broker的核心JMS功能缺陷，而是与所使用的JMS客户端库密切相关。当使用OpenWire JMS客户端库时，该问题可以稳定复现。OpenWire是Apache ActiveMQ Classic的协议，虽然ActiveMQ Artemis兼容OpenWire协议，但在某些特定场景下，其OpenWire兼容层可能存在缺陷。
具体来说，这个问题被识别为ActiveMQ Artemis的一个已知缺陷：ARTEMIS-3916。该缺陷描述了在使用OpenWire客户端时，MessageConsumer在某些情况下无法正确接收到通过选择器已识别的消息。这意味着尽管消息确实存在于队列中且可被浏览，但OpenWire客户端在处理接收请求时可能出现逻辑错误，导致无法获取到消息。
解决方案
针对ARTEMIS-3916缺陷及其导致的浏览与接收不一致问题，主要有两种推荐的解决方案：
1. 切换到ActiveMQ Artemis核心JMS客户端
最直接且推荐的解决方案是停止使用OpenWire JMS客户端库，转而采用ActiveMQ Artemis官方提供的核心JMS客户端库。核心客户端与Broker的内部协议和实现更为匹配，能够避免因兼容层问题而引发的各种异常。
要切换客户端，通常需要修改项目的Maven或Gradle依赖。如果您当前使用的是类似artemis-jms-client-all（其中可能包含了OpenWire兼容层）或直接是OpenWire客户端（如activemq-client），则应将其替换为ActiveMQ Artemis的核心客户端依赖，例如：
Maven 依赖示例：
闪念贝壳
闪念贝壳是一款AI 驱动的智能语音笔记，随时随地用语音记录你的每一个想法。
218 查看详情 
org.apache.activemq artemis-jms-client 2.18.0
代码中的ConnectionFactory实例化：
确保使用ActiveMQ Artemis核心客户端的ActiveMQConnectionFactory，例如：
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;// ...ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
2. 升级ActiveMQ Artemis Broker
如果由于现有系统架构或第三方库的限制，无法切换JMS客户端库，那么另一种解决方案是升级您的ActiveMQ Artemis Broker。ARTEMIS-3916缺陷已在后续版本中得到修复。
推荐升级至版本：
至少 2.25.0 版本：此版本及更高版本包含了对ARTEMIS-3916的修复。最新稳定版本：为了获得最佳的性能、稳定性和最新的安全补丁，强烈建议升级到ActiveMQ Artemis的最新稳定发布版本。您可以在ActiveMQ Artemis官方下载页面找到最新版本信息。
升级Broker通常涉及停机维护、备份数据、安装新版本并迁移配置等步骤。在生产环境进行升级前，务必在测试环境中充分验证。
示例代码：使用核心客户端的正确实现
以下是一个使用ActiveMQ Artemis核心JMS客户端的示例，它演示了如何发送消息、通过选择器浏览消息，并随后通过相同的选择器成功接收消息。此代码在ActiveMQ Artemis 2.18.0及更高版本，配合核心客户端时，应能稳定运行。
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;import javax.jms.*;import java.
以上就是ActiveMQ Artemis：通过选择器浏览消息但无法接收的问题分析与解决的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/986620.html
微信扫一扫 
支付宝扫一扫 
