如何从 Web 应用程序监听消息队列？ （汤姆猫、ActiveMQ）

我很高兴改善我的Web应用程序运行在 Apache 上Tomcat. An ActiveMQ添加JMS服务器来发送和接收消息。

我已经可以发送和接收消息，但需要接收方的帮助。

我的网络应用程序应该如何持续监听一个队列来接收消息？

新消息到达，服务器应对它们采取行动。例如：向数据库添加数据或发回消息。

我已经可以发送消息了。这是代码。

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = factory.createConnection();
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("clientQueue");
MessageProducer publisher = session.createProducer(queue);
connection.start();

Message message = null;
message = session.createTextMessage("Text Message");
publisher.send(message);

我已经可以在请求后收到消息（单击;-)）

connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("serverQueue");
consumer = session.createConsumer(destination);

while (true) {
    Message message = consumer.receive(300000);
    //Do message stuff
}

我应该如何让Web应用程序持续监听队列？建议的方式是什么？

热烈感谢所有帮助。谢谢。

编辑 - 解决方案

目前的工作解决方案以及来自DaveH https://stackoverflow.com/users/53300/daveh

我添加了一个 ServletContextListener 来连续监听我的消息。

web.xml

<listener>
    <listener-class>com.test.JMSContextListener</listener-class>
</listener>

听者：

public class JMSContextListener implements ServletContextListener {
    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        Thread thread = new Thread(new JMSConnector());
        thread.start();
    }

    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        //Nothing
    }
}

连接：

public class JMSConnector implements Runnable {
    public void run() {
        try {
            Context context = new InitialContext();
            QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup("java:comp/env/jms/ConnectionFactory");            
            Connection connection = factory.createConnection();
            Queue queue = (javax.jms.Queue) context.lookup("java:comp/env/jms/serverQueue");
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

            MessageConsumer consumer = session.createConsumer(queue);

            //This MessageListener will do stuff with the message
            MessageListenerImpl messageListener = new MessageListenerImpl();
            consumer.setMessageListener(messageListener);
            connection.start();

            // Start connection or nothing will happen!!!
            connection.start();
        } catch (JMSException ex) {
            //TODO
        } catch (NamingException ex) {
            //TODO
        }
    }
}

这是一种建议的方式还是应该改进？

热烈感谢所有帮助。谢谢。

如果您的代码已经可以使用队列中的消息（看来您确实这样做了），那么我认为您的问题归结为如何运行该代码段。

看来您没有使用任何框架，所以我认为我将采取的方法是采用可以从队列中检索消息的代码并在应用程序服务器中的单独线程中运行它。让该线程在应用程序服务器启动时启动，并在应用程序服务器关闭时自行清理。

在应用程序服务器启动时启动线程的最简单方法是引入 ServletContextListener （示例here http://www.mkyong.com/servlet/what-is-listener-servletcontextlistener-example/.) 在上下文侦听器中，在单独的线程中启动队列侦听代码。

EDIT:我使用了这个建议的解决方案并将上面的代码添加到问题中。