如何在 JMS 队列中搜索特定消息

Question

我正在向 JMS 队列发送一些消息。有哪些可能的方法可以在队列中搜索要消费的特定消息？

我尝试了以下方式：我在向队列发送消息时设置JMSCorrelationID：

 public void createDQueue(String queuename, String json, Integer userid) {
          try {

                QueueSession.AUTO_ACKNOWLEDGE );
                Queue queue = session.createQueue(queuename);
                ObjectMessage objectMessage = session.createObjectMessage();
                objectMessage.setJMSCorrelationID(String.valueOf(userid));
                objectMessage.setObject(json);
                session.createSender(queue).send(objectMessage);
                session.close();
                connection.close();
          }catch(Exception e){
              e.printStackTrace();
          }
      }

在消费者代码中，我想根据JMSCorrelationID 获取特定消息。我无法收到该特定消息。你能提出一个解决方案吗？

public void getSpecificMessage(String queuename, Integer userid) {

         try {
            QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory( "tcp://localhost:61616");
                ((ActiveMQConnectionFactory) connectionFactory).setUseAsyncSend(true);
                QueueConnection connection = connectionFactory.createQueueConnection();
                connection.start();
                QueueSession session = connection.createQueueSession( false,
                     QueueSession.AUTO_ACKNOWLEDGE );
                String id = String.valueOf(userid);
            Queue queue = session.createQueue(queuename);
            QueueReceiver receiver = session.createReceiver(queue, "JMSCorrelationID="+id);
             Message message = receiver.receive();              
        } catch (JMSException e) {              
            e.printStackTrace();
        }
      }

Answer 1

您的第一个问题是您试图将消息代理视为数据库，您必须始终记住这条明智的建议，“消息代理不是数据库”。

在代理不会从磁盘分页更多消息之前，消费者或队列浏览器可以进入目的地的深度有一定的限制，因此您需要检查您的深度并查看它是否大于您的 maxPageSize 设置并进行调整根据需要，但请记住，分页的消息会保留在内存中，直到被使用。

Answer 2

只需将 id 值用单引号括起来

"JMSCorrelationID='"+id+"'"

不建议使用此功能，正如 Tim 所解释的，还有很多复杂性，但如果您想彻底使用它，请进行更改

Answer 3

您可以使用邮件的MeessageID 搜索邮件。这会很快，因为消息传递提供者在消息 id 上索引消息。还有其他基于CorrelationId、元数据等的搜索方式。

但请记住，使用消息传递提供程序的主要目标是以独立于时间的方式连接应用程序。接收应用程序必须尽快收到消息。如果消息在队列中堆积，则表明存在必须解决的问题。