tomcat结合Java定时任务工具实现web中的定时任务

转自：http://blog.csdn.net/uhzgnaw/article/details/45939747

在Java实现简单定时任务一篇记录中描述的是Java的几种定时任务的方式，那是最基本的，仅仅是main方法里测试，用途也受限。

这里研究一下在web中怎么实现这些个定时任务，在这儿作个备忘：

在上一篇里我们都是在Java执行的主线程中以main方法的方式来手动启动和结束这些定时任务，这在web中怎么实现呢？

首先，我们先找到这个定时任务启动和结束的触发事件；

然后，这个事件放生时就启动我们的定时任务；

最后，检查一下有没有引入其他的陷阱（如果有，得解决）。

在web中有个contextListener，可以通过配置来加入到web应用中，这是个不错的入口，废话不多说，直接上菜吧：

context监听器：

[java]
view plain
copy

package abc;  
  
import javax.servlet.ServletContextEvent;  
import javax.servlet.ServletContextListener;  
  
/** 
 *  
 * @author wz 
 * API中描述：ServletContextListener继承于EventListener，其实现者会在web应用的servlet context改变的时候收到事件通知， 
 * 但是还必须要配置到web应用的部署文件中（web.xml） 
 */  
public class MyContextListener implements ServletContextListener {  
      
    private MyTimerTask3 mt3 = new MyTimerTask3();  
  
    /** 
     * 本方法的描述： 
     * 在所有的filter和servlet都destroyed后通知web应用的所有的ServletContextListeners[that“本店”即将打烊啦] 
     */  
    public void contextDestroyed(ServletContextEvent sce) {  
        System.out.println("contextDestroyed…………");  
        mt3.taskEnd();  
    }  
  
    /** 
     * 这个方法的描述： 
     * 在所有的filter和servlet初始化之前，所有的ServletContextListeners会收到[您所在的web应用的初始化工作开始啦]通知 
     */  
    public void contextInitialized(ServletContextEvent arg0) {  
        System.out.println("contextInitialized……");  
        mt3.taskBegin();  
    }  
}  

我们的任务类：

[java]
view plain
copy

package abc;  
  
import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
import java.util.concurrent.ScheduledFuture;  
import java.util.concurrent.TimeUnit;  
  
/** 
 *  
 * @author wz jdk1.5提供了支持并发的定时任务处理工具ScheduledExecutorService  
 * 1.以线程池的方式来执行任务，效率高了 
 * 2.可以设置开始延迟时间和任务取消时间 
 *  
 */  
public class MyTimerTask3 {  
    public static void main(String[] args) {  
        MyTimerTask3 mtt = new MyTimerTask3();  
        mtt.taskBegin();  
        mtt.taskEnd();  
    }  
  
    // newScheduledThreadPool(int corePoolSize),corePoolSize是线程池的大小，  
    //即保持活动或者闲置的线程，它们是任务调度时用于并发执行的线程  
    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);  
    ScheduledFuture<?> taskHandle;  
  
    /** 
     * 启动任务 
     */  
    public void taskBegin() {  
        // 定义一个任务  
        final Runnable task = new Runnable() {  
            public void run() {  
                System.out.println("执行任务");  
            }  
        };  
  
        // scheduleAtFixedRate(Runnable command, long initialDelay, long period,  
        // TimeUnit unit):  
        // 通过ScheduledExecutorService的scheduleAtFixedRate来执行任务  
        // 参数  
        // command - 要执行的任务  
        // initialDelay - 首次执行的延迟时间  
        // period - 连续执行之间的周期  
        // unit - initialDelay 和 period 参数的时间单位  
        System.out.println("任务启动………………………………");  
        taskHandle = scheduler.scheduleAtFixedRate(task, 1, 1, TimeUnit.SECONDS);  
    }  
  
    /** 
     * 结束任务 
     */  
    public void taskEnd() {  
        scheduler.shutdown();   //启动一次顺序关闭，执行以前提交的任务，但不接受新任务。如果已经关闭，则调用没有其他作用。  
//      List<Runnable> shutdownNow()试图停止所有正在执行的活动任务，暂停处理正在等待的任务，并返回等待执行的任务列表。   
    }  
  
}  

web.xml添加的配置：

[html]
view plain
copy

<listener>  
    <listener-class>abc.MyContextListener</listener-class>  
</listener>  

没错，就这样就OK啦！
但是需注意：

在结束任务处

[java]
view plain
copy

    public void taskEnd() {  
        scheduler.shutdown();   //启动一次顺序关闭，执行以前提交的任务，但不接受新任务。如果已经关闭，则调用没有其他作用。  
//      List<Runnable> shutdownNow()试图停止所有正在执行的活动任务，暂停处理正在等待的任务，并返回等待执行的任务列表。   
    }  

如果你是结束指定的任务，假设你不是在contextdestroy里结束所有任务，而是结束指定的任务，其余的任务照样继续执行，那你可以像下面这样写：

[java]
view plain
copy

public void taskEnd() {  
    taskHandle.cancel(true);   
}  

其实，调用scheduler.shutdown();时，虚拟机会去按顺序（这种多定时任务中其实是维护着一个任务队列的）调其taskHandle.cancel(true);

但是在你要停止所有任务时（就比如在整个web应用都要停止的时候），你不能只调taskHandle.cancel(true);

因为这样的话，上建立的线程池中的线程还没有关闭，会造成内存泄露一类的bug，比如它会告诉你[恭喜你，兄弟，你漏气啦！]：

2015-5-24 1:11:56 org.apache.catalina.loader.WebappClassLoader clearReferencesThreads

严重: The web application [/abcsz_mng] appears to have started a thread named [pool-1-thread-1] but has failed to stop it. This is very likely to create a memory leak.

2015-5-24 1:11:57 org.apache.coyote.http11.Http11Protocol destroy