你好,我正在编写一些简单的测试场景,我在其中执行以下源代码:
这是我的 send() 方法:
public void send() throws JMSException {
Session session = null;
MessageProducer producer = null;
try {
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TEST.FOO");
producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
byte[] uselessData = new byte[1024];
BytesMessage message = session.createBytesMessage();
message.writeBytes(uselessData);
producer.send(message);
} finally {
producer.close();
session.close();
}
}
这是我的 receive() 方法:
public void receive() throws JMSException {
Session session = null;
MessageConsumer consumer = null;
try {
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TEST.FOO");
consumer = session.createConsumer(destination);
Message hugeMessage = consumer.receiveNoWait();
if (hugeMessage == null) {
System.out.println("Message was not received");
unsucsesfullCount++;
} else {
if (hugeMessage instanceof BytesMessage) {
System.out.println("Message received");
}
}
} finally {
consumer.close();
session.close();
}
}
我执行:
send();
receive();
receiveNoWait() 之后的消息值总是null。
我的问题是当代理中有消息时,receiveNoWait() 是否保证消息传递? send() 已成功执行,因此目标中至少有一条消息。
我在规范中进行了搜索,但对于在代理端可用的消息是否应由客户端的 receiveNoWait() 显式接收,并没有真正明确的定义。
另外我想问一下,如果receiveNoWait()没有可用的消息,是否会在broker中触发一些刷新消费者进程,那么接下来的receiveNoWait()会收到消息吗?
我提供的示例代码在 ActiveMQ 上运行,但我的问题更概念化而不是特定于提供者,因为我对其他 JMS 提供者有相同的观察。
最佳答案
不,规范不保证对 receiveNoWait
的任何调用都会返回一条消息,可能会,也可能不会。使用 receiveNoWait
时,您必须始终检查空返回值并采取相应措施。
在 ActiveMQ 的情况下,如果代理已向其发送一条消息,则客户端将返回一条消息,并且该消息在消费者预取缓冲区中立即可用,否则它只会返回 null。
其他实现我确实向代理发送轮询请求,例如 Qpid JMS 使用 AMQP 链接耗尽请求要求代理向其发送任何可用于分派(dispatch)的消息,代理将发送它们或发出信号链接已耗尽,没有准备好消息。
简而言之,这完全取决于客户和代理人如何实现 receiveNoWait
,但无论怎样,您始终需要考虑到您不会从该方法收到返回消息的可能性.
关于java - 当消息可用时,JMS receiveNoWait() 是否保证消息传递?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36626634/