10

我的任务是为 JMS 客户端评估 ActiveMQ Artemis。我有 RabbitMQ 经验，但没有使用 ActiveMQ Artemis。

我在本地机器上安装了 Artemis，按照说明创建了一个新代理，并将其设置为 Windows 服务。Windows 服务可以正常启动和停止。我没有对broker.xml文件进行任何更改。

对于我的第一个测试，我试图从一个独立的 Java 程序执行 JMS 队列生产/消费。我正在使用“使用 JMS”部分的 Artemis 用户手册中的代码（不使用 JNDI）：

TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName());
ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF,transportConfiguration);

Queue orderQueue = ActiveMQJMSClient.createQueue("OrderQueue");
Connection connection = cf.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
MessageProducer producer = session.createProducer(orderQueue);
MessageConsumer consumer = session.createConsumer(orderQueue);

connection.start();

TextMessage message = session.createTextMessage("This is an order");
producer.send(message);

TextMessage receivedMessage = (TextMessage)consumer.receive();
System.out.println("Got order: " + receivedMessage.getText());

当我运行此代码时，我收到以下错误：

WARN: AMQ212054: Destination address=jms.queue.OrderQueue is blocked. If the system is configured to block make sure you consume messages on this configuration.

我的研究还没有确定这是服务器端设置，还是让生产者无阻塞地发送。我一直无法找到具有阻塞布尔值的生产者发送方法，只有持久性。关于重点放在哪里的任何想法？

编辑：添加到专用于此队列的新address-setting元素：broker.xml

<address-setting match="jms.queue.OrderQueue">
    <max-size-bytes>104857600</max-size-bytes>
    <page-size-bytes>10485760</page-size-bytes>
    <address-full-policy>PAGE</address-full-policy>
</address-setting>
4

2 回答 2

21

我在用户手册的进一步研究中发现了这一点：

max-disk-usage 我们应该从磁盘使用的数据的最大百分比。磁盘已满时系统将阻塞。默认=100

并在服务启动后的日志中尚未发布任何消息：

WARN [org.apache.activemq.artemis.core.server] AMQ222210：存储使用量超出最大磁盘使用量。系统将开始阻止生产者。

所以我认为无论我的地址设置如何，它都会开始阻塞。查看 broker.xml 中的 max-disk-usage 设置，它设置为 90。文档默认设置为 100，我设置为该值，没有启动日志警告，我的测试 pub/sub 代码现在可以工作。

于 2017-06-29T22:25:32.520 回答
0

当地址策略设置为 BLOCK 并达到内存时，会出现此警告消息。检查在 broker.xml 中设置的地址策略。如果设置为 BLOCK，请将其更改为 PAGE。或者使用 OrderQueue 中的待处理消息。

于 2017-06-26T17:37:57.760 回答