使用ActiveMQ和Spring的JMS Standalone消费者

Question

从历史上看,我已经将我的JMS使用者应用程序部署为在Tomcat(Windows框)下部署的Spring webapps.然后,这些消费者将在同一个Tomcat实例下与我的其他Web应用程序一起运行.然而,随着我使用的消费者数量的增长,我意识到这将成为一种维护噩梦.

我的解决方案是将这些webapps转换为部署为jar的"main method"独立应用程序.实际上,我能够成功地将它们打包在一起,以尝试尽可能多地重用资源(DAO,依赖项等).

这是我的主要方法:

public static void main(String[] args) {

    ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");

    try {
        FooListener fooListener = (FooListener) context.getBean("fooListener");

        fooListener.start();
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
    }

    try {
        BarListener barListener = (BarListener) context.getBean("barListener");

        barListener.start();
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
    }
}

我的问题:

1. 我是否需要在主方法应用程序中执行任何特殊操作来关闭我的JMS连接,或者在应用程序终止时它们会关闭吗？
2. 有没有人有任何个人偏好或其他关于是否使用tomcat或作为独立应用部署jms消费者？

编辑:

更多信息:FooListener和BarListener扩展了以下抽象类.它们从applicationContext.xml文件中的相应bean继承它们的值,并且它们都覆盖onMessage()方法以异步使用消息.

public abstract class TextMessageListener implements MessageListener {

    protected ConnectionFactory connectionFactory;

    protected String queueName;

    protected String selectors;

    public void start() throws JMSException {
        Connection connection = connectionFactory.createConnection();

        Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

        MessageConsumer consumer = session.createConsumer(session.createQueue(queueName), selectors);

        consumer.setMessageListener(this);

        connection.start();
    }

    public abstract void onMessage(Message message);
}

Answer 1

您必须以这种方式为您的应用程序上下文注册一个关闭钩子：

context.registerShutdownHook();

这将确保当 jvm 关闭时，上下文也会正常关闭。

我个人的偏好始终是将其部署到容器中 - 即使是像这样的独立应用程序，这是因为以下原因：

• 管理更容易 - 部署/取消部署应用程序战争，启动/停止容器运行时。
• 如果您需要构建任何类型的监控 - 正在消耗多少消息，则使用此设置会更容易，您只需添加提供相关信息的网页即可，而不是在独立应用程序中使用 jmx。

另外，为什么你要显式调用listener.start()，Spring容器无论如何都会自动执行此操作？