在Tomcat中运行后台Java程序

Question

在Tomcat中运行后台Java程序

javatomcatbatch-processing

43

有人能给些建议吗？我有这样一种情况，用户将通过Java JSP和servlet交互式提交数据挖掘请求到我的应用程序中，该应用程序将动态地处理数据关联规则等内容。

由于这样的任务可能需要一些时间，我正在考虑在服务器上运行一些进程来在后台运行此类请求，以避免“锁定”会话并可能对系统造成大量内存使用的不利影响。

由于该系统是由一系列运行在Tomcat容器中的Java JSP和servlet组成的，并且使用MySQL数据库，有人可以提出解决方案吗？

谢谢

Morgan先生

- mr morgan

你期望回复吗？此外，Tomcat使用线程池，可以在需要时扩展以服务多个同时请求。 - Johan Sjöberg

您是否需要向用户显示“数据挖掘请求”的结果（或至少通知他们已完成的作业）？那么您需要如何做到这一点？ - Costi Ciudatu

我在考虑，当一个任务完成时，可以通过电子邮件通知用户结果已经可用。 - mr morgan

4个回答

5

我认为Quartz调度程序应该能够完成你想要做的事情。以下是来自Quartz的一些示例链接：Quartz示例。使用这个工具，你可以启动一个cron定时任务，快速轮询以处理传入的请求。我曾经在一个项目中使用过这种方法。

- limc

我在系统的其他地方使用Quartz进行每小时定时作业，但这也是一种可能性。 - mr morgan

3

石英是个不错的选择。它可以很好地执行“现在运行一次作业”的任务。另一个优点是它提供了重启功能。当您启动作业时，石英可以“保存”请求，并在系统崩溃后再次启动作业。您可以免费获得所有这些功能，而且既然您已经拥有它，那么您已经知道如何使用它了。如果不必添加新的工具包，为什么要这样做呢？ - Will Hartung

4

一种轻量级的解决方案（与像Quartz这样的调度程序相反）是将处理放入后台线程，并通过ExecutorService运行该线程。 http://download.oracle.com/javase/6/docs/api/java/util/concurrent/Executors.html
http://download.oracle.com/javase/6/docs/api/java/util/concurrent/ExecutorService.html

- user330315

0

也许JMS是您真正需要的，但是在Tomcat上使用它需要额外的努力，因为它只是Servlet容器。您可以切换到真正的应用服务器，如Glassfish或JBoss，也可以自己添加JMS功能到Tomcat中（参考下面的链接）

http://blogs.captechconsulting.com/blog/jairo-vazquez/tomcat-and-jms

- Marcin Michalski

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- nos · Accepted Answer

使用ExecutorService。

但是，有几件事情需要注意，将线程标记为守护线程，这样至少在错误场景下不会阻塞Tomcat，并且在Servlet上下文被销毁时（例如重新部署或停止应用程序时）应该停止执行器。为此，请使用ServletContextListener：

public class ExecutorContextListener implements ServletContextListener {
    private  ExecutorService executor;

    public void contextInitialized(ServletContextEvent arg0) {
        ServletContext context = arg0.getServletContext();
        int nr_executors = 1;
        ThreadFactory daemonFactory = new DaemonThreadFactory();
        try {
            nr_executors = Integer.parseInt(context.getInitParameter("nr-executors"));
        } catch (NumberFormatException ignore ) {}

        if(nr_executors <= 1) {
        executor = Executors.newSingleThreadExecutor(daemonFactory);
        } else {
        executor = Executors.newFixedThreadPool(nr_executors,daemonFactory);
       }
          context.setAttribute("MY_EXECUTOR", executor);
      }

    public void contextDestroyed(ServletContextEvent arg0) {
        ServletContext context = arg0.getServletContext();
        executor.shutdownNow(); // or process/wait until all pending jobs are done
    }

}
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

/**
 * Hands out threads from the wrapped threadfactory with setDeamon(true), so the
 * threads won't keep the JVM alive when it should otherwise exit.
 */
public class DaemonThreadFactory implements ThreadFactory {

    private final ThreadFactory factory;

    /**
     * Construct a ThreadFactory with setDeamon(true) using
     * Executors.defaultThreadFactory()
     */
    public DaemonThreadFactory() {
        this(Executors.defaultThreadFactory());
    }

    /**
     * Construct a ThreadFactory with setDeamon(true) wrapping the given factory
     * 
     * @param thread
     *            factory to wrap
     */
    public DaemonThreadFactory(ThreadFactory factory) {
        if (factory == null)
            throw new NullPointerException("factory cannot be null");
        this.factory = factory;
    }

    public Thread newThread(Runnable r) {
        final Thread t = factory.newThread(r);
        t.setDaemon(true);
        return t;
    }
}

你需要将上下文监听器添加到web.xml文件中，你还可以在此处指定要运行后台作业的线程数：

  <listener>
    <listener-class>com.example.ExecutorContextListener</listener-class>
  </listener>

您可以从servlet中访问执行器并向其提交作业：

ExecutorService executor = (ExecutorService )getServletContext().getAttribute("MY_EXECUTOR");
...
executor.submit(myJob);

如果您正在使用Spring，所有这些可能都可以变得更加简单。这里有更多相关信息。