如何在ActiveMQ中获取所有排队的消息？

Question

我想构建一个简单的消费者程序(java ),以获取ActiveMQ主题中存储的所有消息。我有一个在队列中发送文本消息的生成器。

但我不知道如何开始写我的消费者来检索旧消息并等待新消息。

如果你有一个例子，谢谢！

这是我的制片人：http://pastebin.com/uRy9D8mY

这是我的消费者：http://pastebin.com/bZh4r66e

当我先于消费者运行生产者，然后运行消费者时，我什么也没得到。当我运行我的使用者然后是我的生产者时，我在队列中添加了72条消息，但我的使用者只收到了24条消息......

Answer 1

使用下面给出的代码，您可以读取队列中排队的所有消息。

• 在此代码中，while 循环是一个无端循环，它将循环访问队列中的所有消息。
• 一旦队列中没有消息，它将等待5秒，然后自动停止连接并中断循环。

如果您需要一个无止境的使用者，每当新添加到队列中时，该使用者将读取所有消息，然后删除else部分，这样程序将不会终止。

    ConnectionFactory factory =  new ActiveMQConnectionFactory("tcp://localhost:61616");
    Connection con = factory.createConnection();
    Session session =   con.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createQueue("tmp_queue2");
    MessageConsumer consumer = session.createConsumer(queue);
    con.start();     
    while (true) {     
        Message msg = consumer.receive(5000); 
        if (msg instanceof TextMessage) {
            TextMessage tm = (TextMessage) msg;
            System.out.println(tm.getText());       
        }
        else{
            System.out.println("Queue Empty"); 
            con.stop();
            break;
        }
    }

希望这个消费者计划能够帮助刚接触ActiveMQ的人。

Answer 2

我建议阅读本教程（如Apache ActiveMQ）SUN Jms教程

有很多方法可以编写JMS/ActiveMQ程序，使用各种框架，例如Spring，或者使用纯java。

基本上，编写一个这样的侦听器类：

public class MyListener implements MessageListener{
   public void onMessage(Message message){
      // Read and handle message here.
   }
}

因为您已经在生成消息，所以我假设您已经建立并运行了连接。

session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
consumer = session.createConsumer("MyQueue");
listener = new MyListener ();
consumer.setMessageListener(listener);
connection.start(); 
// At this point, messages should arrive from the queue to your listener.

还有一些错误处理代码没有包含在本示例中，但是您应该能够在教程和JMS文档的帮助下找到它们。