java– 使用ActiveMQ和Spring的JMS Standalone使用者

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

从历史上看,我已经将我的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);    }}

我的问题：

>我是否需要在主方法应用程序中执行任何特殊 *** 作来关闭我的JMS连接,或者在应用程序终止时它们会关闭吗？
>有没有人有任何个人偏好或其他关于是使用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);}

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

context.registerShutdownHook();

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

我个人的偏好总是将它部署到容器 – 甚至是像这样的独立应用程序,这是由于以下原因：

>管理更容易 – 部署/取消部署应用程序之战,启动/停止容器运行时.
>如果您需要构建任何类型的监控 – 消耗了多少消息,使用此设置将更容易,您可以添加显示相关信息的网页,而不是使用jmx与独立应用程序.

另外,为什么要显式调用Listener.start(),spring容器会自动执行此 *** 作？ 总结

以上是内存溢出为你收集整理的java – 使用ActiveMQ和Spring的JMS Standalone使用者全部内容，希望文章能够帮你解决java – 使用ActiveMQ和Spring的JMS Standalone使用者所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。