如何延迟JMS消息发送？

Question

如何延迟JMS消息发送或在不确定的时间内继续？

我使用的是Weblogic，正如您所知，在JMS发送之后，接收方将异步处理消息，但是，此时或有时外部资源还没有为接收方做好准备，因此，我想使用一些检查逻辑来延迟发送或处理消息。我猜例如：我将消息放入挂起队列，然后频繁检查资源可用性，一旦发送或继续消息？

大家都知道Weblogic是否支持这一点，或者如何实现它吗？

Answer 1

假设您使用Websphere MQ，我认为它不受支持。

JMS2.0确实支持消息的延迟传递，但是如果没有更多的信息，就很难回答。

[1]https://java.net/projects/jms-spec/pages/JMS20FinalRelease#What_s_new_in_JMS_2.0?

Answer 2

通常情况下，为了延迟消息的接收，直到资源准备就绪，连接将中断。未调用start（）方法。逻辑如下：

1. 接收器启动并建立连接，并设置所有JMS资源。
2. 不调用connection.start（）。
3. 等待其他资源初始化
4. 使用connection.start（）启动JMs连接

您甚至可以使用此方法暂停消息侦听器接收的消息。这种技术在使用JMS的GUI工具中非常常见。

Answer 3

您完全可以在JMS中实现这一点，只需使用本地队列来存储消息；当接收器可用时发送到远程队列。

1）首先，在WebLogic中创建一个JMS服务器，LocalJMSServer。

2） 确保此资源仅针对本地WebLogic实例。

3）为LocalJMSServer创建一个队列，temQueue。

4）您的应用程序总是将消息发送到temQueue。由于该队列是本地的，消息只是放在队列中，并且它们也被持久化，这在服务器崩溃的情况下是很好的。

5） 您需要在WebLogic中使用单独的JMSServer配置来托管remoteQueue，因为该队列将以远程WebLogic实例为目标。

6） 应用程序会定期检查远程接收器的可用性：

   if( receiverIsAvailable()){
    ...
   }

...当接收器可用时，从temQueue中取出消息并将其发送到Remote teQueue...

Queue tempQueue = (Queue) ctx.lookup("tempQueue");
QueueSession queueLocalSession = 
  queueConn.createQueueSession(false,
     Session.CLIENT_ACKNOWLEDGE);  
QueueReceiver queueReceiver = queueLocalSession.createReceiver(tempQueue);
TextMessage localMessage = (TextMessage) queueReceiver.receive();

//send to remote queue
Queue remoteQueue = (Queue) ctx.lookup("remoteQueue");
QueueSender queueSender = queueRemoteSession.createSender(remoteQueue);
Message newMessage = queueRemoteSession.createTextMessage(
  localMessage.getText());
queueSender.send( newMessage);

//now acknowledge the message since we safely sent to remoteQueue
localMessage.acknowledge(); 

我喜欢这种方法，因为它完全是事务性的；如果出现任何问题，只要使用持久模式，就不会丢失消息。此外，从tempQueue提取消息时，必须使用同步接收器（如上所述），不能使用onMessage（），因为它会立即处理来自本地队列的消息。

您还可以使用内存队列（而不是JMS）在本地存储消息内容：

ArrayBlockingQueue queue = new ArrayBlockingQueue<String>();
queue.add(messageContents1);
queue.add(messageContents2);
...

您的应用程序在接收端检查资源可用性，如果可用，只需退出队列，毫不延迟地发送真正的JMS消息：

if( receiverIsAvailable()){
   while(!queue.isEmpty()){
      Message message = session.createTextMessage();
      message.setText(queue.take());
      queueSender.send(message);
   }
}

这种方法的问题是存储在队列中的消息驻留在内存中；如果发送方崩溃，您将丢失这些消息。

希望有帮助！