TomcatでバックグラウンドJavaプログラムを実行する

Question

誰でもアドバイスできますか？私は、ユーザーがデータマイニング要求をJava JSPとサーブレットを介してインタラクティブにアプリケーションのアプリケーションに送信し、データのアソシエーションルールを動的に処理する状況があります。

このようなジョブはしばらく時間がかかる可能性があります。私はバックグラウンドでこのような要求を実行するためにサーバー上で何らかのプロセスを考えていますので、セッションをロックしたり、メモリをシステムに損害を与えます。

システムは、一連のJava JSPとサーブレットがMySQLデータベース上でTomcatコンテナ内で実行されているため、誰も手伝ってくれますか？

おかげ

氏モルガン

Answer 1

私はクォーツスケジューラは、あなたがここで何をしたいのかを達成することができるはずだと思います。ここにはexamples from Quartzの一部があります。これを使用すると、着信要求を処理するために迅速にポーリングするcronを開始できます。私は実際に私のプロジェクトの1つのためにそれをしました。

Answer 2

クォーツのようなスケジューラを使用するのではなく、軽量のソリューションは、処理をバックグラウンドスレッドに入れて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

Answer 3

たぶん、JMSは、しかし、それが唯一のサーブレットコンテナであるため、Tomcat上でそれを使用するために余分な労力を必要とし、あなたが本当に探しています。あなたは

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

Answer 4

使用ExecutorService GlassfishのかJBossのような本当のAppServerにスイッチをeigherまたは（リンクの下に）自分自身でTomcatにJMS機能を追加することがあります。

スレッドをデーモンスレッドとしてマークすると、エラーシナリオでは少なくともtomcatと結びついていないので、サーブレットコンテキストが破棄されたときにexecutorを停止する必要があります（たとえば、再デプロイ時。またはこれを行うには、あなたのアプリケーションを停止、の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> 

サーブレットからエグゼキュータにアクセスし、それにジョブを送信：あなたが春を使用している場合

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

、このすべては、おそらくsimpler