java - 发送方/接收方之间的 JMS 消息流

Question

如果我使用下面的代码创建发送者和接收者

qsender = qsession.createSender((Queue)msg.getJMSDestination());
qreceiver=qsession.createReceiver((Queue)msg.getJMSDestination());

然后这样做

qsender.send(msg);

它是否只是将消息发送到队列并且它会永远保留在队列中？我是否需要调用接收方的 receive() 方法或实现 MessageListener 接口(interface)才能将其发送到接收方？

编辑:更多信息

qsender = qsession.createSender((Queue)msg.getJMSDestination());
qreceiver=qsession.createReceiver((Queue)msg.getJMSDestination());

temp1 = qsession.createTemporaryQueue();
responseConsumer = qsession.createConsumer(temp1);
msg.setJMSReplyTo(temp1);

responseConsumer.setMessageListener(responseListener);
msg.setJMSCorrelationID(msg.getJMSCorrelationID()+i);

qsender.send(msg);

在上面的代码中，临时队列是做什么用的呢？是用来接收消息的吗？是接收器吗？如果是，msg.setJMSReplyTo(temp1) 有什么用？

Answer 1

是的，send(..) 方法会将消息发送到目标队列。并且此消息将保留在队列中，直到您的程序使用接收器接收它或直到您的消息代理正在运行(据我所知)。

关于你的第二个问题，那么两种方法之间的区别在于:

receive(..) 方法是同步的(这是这种方法的缺点)。这意味着接收方必须耐心等待消息到达，因为 receive() 消息将阻塞直到消息可用(或直到出现超时条件)。从另一端使用监听器消费消息是异步过程。您的接收器不会等待。只有当消息将被放入查询时，监听器才会调用您的接收方法。

更新:

临时目的地用于发送消费者对消息的回复。例如，您的服务器可能会收到来自客户端的消息，您需要向他发送响应。在这种情况下，您应该使用临时目的地。服务器应用程序将使用此临时目的地(在您的情况下为队列)向客户端发送响应消息。此类队列的范围仅限于创建它的连接，并在连接关闭后立即在服务器端删除。

您可以在 this article 中找到更多详细信息在officila java tutorial .在第二篇文章中还介绍了如何以及何时使用 JMSCorrelationID。

这是来自官方文档的有趣部分，描述了如何使用临时目的地发送响应消息:

You can use temporary destinations to implement a simple request/reply mechanism. If you create a temporary destination and specify it as the value of the JMSReplyTo message header field when you send a message, then the consumer of the message can use the value of the JMSReplyTo field as the destination to which it sends a reply. The consumer can also reference the original request by setting the JMSCorrelationID header field of the reply message to the value of the JMSMessageID header field of the request. For example, an onMessage method can create a session so that it can send a reply to the message it receives. It can use code such as the following:

producer = session.createProducer(msg.getJMSReplyTo());
replyMsg = session.createTextMessage("Consumer " +
    "processed message: " + msg.getText());
replyMsg.setJMSCorrelationID(msg.getJMSMessageID());
producer.send(replyMsg);

更新 2:

我想澄清一下我对队列(或主题)中消息过期时间的回答。默认消息永远不会过期。但是你可以设置消息的过期时间:

producer.setTimeToLive(60000);

在此之后，此 MessageProducer 生成的所有消息都将具有指定的过期时间。

您还可以在发送具体消息时指定过期时间:

producer.send(message, DeliveryMode.NON_PERSISTENT, 3, 10000);

其中 10000 表示 10 秒