对于独立应用程序（对于 Spring JMS），Java main 方法应该是什么？

Question

我有兴趣创建一个 Spring 独立应用程序，该应用程序将运行并等待使用 Spring JMS 从 ActiveMQ 队列接收消息。我搜索了很多地方，但找不到一致的方式来实现这样一个独立应用程序的主要方法。 Spring 独立应用程序的示例似乎很少。我从网上查看了 Tomcat、JBoss、ActiveMQ 和其他示例，但我还没有得出结论，所以......

为 Java 应用程序（特别是 Spring with JMS）实现 main 方法的最佳实践是什么？

更新： 下面是一个例子：http://forum.springsource.org/showthread.php?t=48197 这是最好的方法吗？

public static void main(String args[]) {
        try {
           ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
            . . . . .
            Object lock = new Object();
            synchronized (lock) {
                lock.wait();  
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
}

Answer 1

尝试循环读取。如果找到一条消息，则对其进行处理，然后休眠并再次迭代。还要在其中放置某种终结符逻辑（中断线程）。您可以在 X 次尝试后终止、从文件中读取、终止 JVM、从队列中读取终止符消息等等。

public static void main(String[] args) {
    while(true) {
        // look for some terminator
        // attempt to read off queue
        // process message
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (Exception e) {
            break;
        }
    }
}

Answer 2

在你的 main() 中做这样的事情：

// gather config files
String[] configs = { "classpath:applicationContext-myutil.xml" };

// create the app context
ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(configs);

// obtain reference to your utility bean
MyUtilityBean utility = (MyUtilityBean) ctx.getBean("utility");

// invoke methods on your utility bean
utility.doSomething()

您可以使用Spring's JMS template 注入您的实用程序bean 来为您的用例完成繁琐的工作。

Answer 3

这就是我们所拥有的，在 app-context.xml 中，我们使用 spring JMS 类（如 org.springframework.jms.listener.DefaultMessageListenerContainer 来管理消费者数量并使用 提供自定义监听器） >org.springframework.jms.listener.adapter.MessageListenerAdapter)

app-context.xml 包含所有 spring bean 侦听器和其他内容，下面的代码是引导 Spring 在队列中提供的侦听器。所以想法是使用Spring类来管理多个消费者。让我知道这是否是您需要的，并且需要有关配置 MessageListenerAdapter 的更多信息。

public static void main(String[] args)
{

    try
    {
        new ClassPathXmlApplicationContext("app-context.xml");

    }
    catch (Throwable e)
    {
        e.printStackTrace();
        System.exit(-1);
    }

}

Answer 4

主要思想是让主线程等到应用程序完成。 while(!finished) 是等待主线程被唤醒的正确方法。

finishEventHandler - 是一种处理完成/退出事件的方法。

我认为 JMS 初始化是在 Spring conf 中完成的。并在“……”中部分。

public static void main(String args[]) {

try {
        ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
        lock = new Object();

        while(!finished) {
           synchronized (lock) {
               lock.wait();  
           }
        }

    } catch (Exception e) {
        e.printStackTrace();
    }

}

 public void finishEventHandler() {
     finished = true;
     lock.notify();
}

Answer 5

使用 Spring JMS 时，您已经在配置中使用了组件/bean，这些组件/bean 会自动启动，并且会保持活动状态（订阅并从队列/主题中读取），直到您停止应用程序。

因此，要启动并保持应用程序运行，加载应用程序上下文就足够了。 好的做法是同时调用 registerShutdownHook，因此在应用程序停止时（即通过控制台中的 ctrl+c），您的所有 bean 都会正常关闭和处理:)

public static void main(String args[]) {
    AbstractApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
    context.registerShutdownHook();
}