Tomcat 下的定時(shí)任務(wù)

SysContextListener.java

package axtic.servlet;

import java.util.Timer;//定時(shí)器類

import axtic.bean.exportHistoryBean;

import javax.servlet.ServletContextEvent;

import javax.servlet.ServletContextListener;

public class SysContextListener implements ServletContextListener

{

private Timer timer = null;

public void contextInitialized(ServletContextEvent event)

{//在這里初始化監(jiān)聽器，在tomcat啟動(dòng)的時(shí)候監(jiān)聽器啟動(dòng)，可以在這里實(shí)現(xiàn)定時(shí)器功能

timer = new Timer(true);

event.getServletContext().log("定時(shí)器已啟動(dòng)");//添加日志，可在tomcat日志中查看到

timer.schedule(new exportHistoryBean(event.getServletContext()),0,5*1000);//調(diào)用exportHistoryBean，0表示任務(wù)無(wú)延遲，5*1000表示每隔5秒執(zhí)行任務(wù)，60*60*1000表示一個(gè)小時(shí)。

event.getServletContext().log("已經(jīng)添加任務(wù)");

}

public void contextDestroyed(ServletContextEvent event)

{//在這里關(guān)閉監(jiān)聽器，所以在這里銷毀定時(shí)器。

timer.cancel();

event.getServletContext().log("定時(shí)器銷毀");

}

}

接下來(lái)可以編寫自己的功能類，此類一定要extends定時(shí)器類中TimerTask

exportHistoryBean.java

package axtic.bean;

import java.util.Calendar;

import java.util.TimerTask;

import javax.servlet.ServletContext;

public class exportHistoryBean extends TimerTask

{

private static final int C_SCHEDULE_HOUR = 0;

private static boolean isRunning = false;

private ServletContext context = null;

public exportHistoryBean(ServletContext context)

{

this.context = context;

}

public void run()

{

Calendar c = Calendar.getInstance();

if(!isRunning)

{

if(C_SCHEDULE_HOUR == c.get(Calendar.HOUR_OF_DAY))

{

isRunning = true;

context.log("開始執(zhí)行指定任務(wù)");

//-------------------開始保存當(dāng)日歷史記錄

//在這里編寫自己的功能，例：

//File file = new File("temp");

//file.mkdir();

//啟動(dòng)tomcat，可以發(fā)現(xiàn)在tomcat根目錄下，會(huì)自動(dòng)創(chuàng)建temp文件夾

//-------------------結(jié)束

isRunning = false;

context.log("指定任務(wù)執(zhí)行結(jié)束");

}

else

{

context.log("上一次任務(wù)執(zhí)行還未結(jié)束");

}

}

}

}

Servlet偵聽器結(jié)合Java定時(shí)器實(shí)現(xiàn)任務(wù)計(jì)劃調(diào)度

好多朋友用過Windows的任務(wù)計(jì)劃，也有不少程序迷自己曾寫過時(shí)鐘報(bào)警、系統(tǒng)自動(dòng)關(guān)機(jī)等趣味程序，可卻很少有朋友在Web工程中實(shí)現(xiàn)過類似功能。今天有空把筆者先前曾在Tomcat上實(shí)現(xiàn)的類似功能，搬出來(lái)與大家共享。

早 在幾年前，我公司跟某市財(cái)政局合作項(xiàng)目開發(fā)，為加強(qiáng)財(cái)政局對(duì)所屬單位財(cái)務(wù)狀況的有效監(jiān)管，開發(fā)、實(shí)施了財(cái)政局?jǐn)?shù)據(jù)中心項(xiàng)目。此項(xiàng)目采用B/S加C/S混合 結(jié)構(gòu)模式。財(cái)政局Web服務(wù)器上架設(shè)數(shù)據(jù)同步接收裝置，由市屬單位每天下班前把財(cái)務(wù)信息通過HTTP協(xié)議上傳至財(cái)政局中心服務(wù)器，與Web服務(wù)器上的接收 裝置對(duì)接。財(cái)政局內(nèi)部各部門需要查閱大量財(cái)務(wù)信息，獲取完備的市屬單位當(dāng)前財(cái)務(wù)狀況信息，各部門按職能劃分，需要準(zhǔn)確的獲取各部門各自所關(guān)注的匯總信息， 以財(cái)政報(bào)表的形式提供。

因 財(cái)政數(shù)據(jù)量大，實(shí)時(shí)計(jì)算財(cái)政報(bào)表速度較慢，當(dāng)初就考慮用報(bào)表緩存來(lái)減輕服務(wù)器的負(fù)擔(dān)，但用緩存需要一個(gè)合理的緩存更新機(jī)制?？紤]到各市屬單位每天下班前才 把財(cái)務(wù)數(shù)據(jù)上傳，財(cái)政局每天所查看到的財(cái)務(wù)信息其實(shí)并不包括當(dāng)天（除非有某位領(lǐng)導(dǎo)等到所屬單位全部上傳完之后才來(lái)查看信息，應(yīng)該已經(jīng)下班了），所以要是能 實(shí)現(xiàn)任務(wù)計(jì)劃調(diào)度，在每晚深夜把當(dāng)天及歷史財(cái)務(wù)信息匯總，更新緩存，速度瓶頸不就解決了嗎。

當(dāng) 時(shí)由于系統(tǒng)核心是基于Web部署的，報(bào)表計(jì)算引擎也相應(yīng)的部署在Tomcat容器上，因此如果想要借用Windows的任務(wù)計(jì)劃來(lái)實(shí)現(xiàn)定時(shí)計(jì)算，就需要額 外編寫普通桌面應(yīng)用程序接口，稍顯復(fù)雜。于是就琢磨著想在Web上實(shí)現(xiàn)，經(jīng)過查閱較多相關(guān)資料，發(fā)現(xiàn)Java定時(shí)器（java.util.Timer）有 定時(shí)觸發(fā)計(jì)劃任務(wù)的功能，通過配置定時(shí)器的間隔時(shí)間，在某一間隔時(shí)間段之后會(huì)自動(dòng)有規(guī)律的調(diào)用預(yù)先所安排的計(jì)劃任務(wù) （java.util.TimerTask）。另外，由于我們希望當(dāng)Web工程啟動(dòng)時(shí)，定時(shí)器能自動(dòng)開始計(jì)時(shí)，在整個(gè)Web工程的生命期里，定時(shí)器能在每 晚深夜觸發(fā)一次報(bào)表計(jì)算引擎。因此定時(shí)器的存放位置也值得考查，不能簡(jiǎn)單的存在于單個(gè)Servlet或JavaBean中，必須能讓定時(shí)器宿主的存活期為 整個(gè)Web工程生命期，在工程啟動(dòng)時(shí)能自動(dòng)加載運(yùn)行。結(jié)合這兩點(diǎn)，跟Servlet上下文有關(guān)的偵聽器就最合適不過了，通過在工程的配置文件中加以合理配 置，會(huì)在工程啟動(dòng)時(shí)自動(dòng)運(yùn)行，并在整個(gè)工程生命期中處于監(jiān)聽狀態(tài)。

下 面就Servlet偵聽器結(jié)合Java定時(shí)器來(lái)講述整個(gè)實(shí)現(xiàn)過程。要運(yùn)用Servlet偵聽器需要實(shí)現(xiàn) javax.servlet.ServletContextListener接口，同時(shí)實(shí)現(xiàn)它的 contextInitialized(ServletContextEvent event)和 contextDestroyed(ServletContextEvent event)兩個(gè)接口函數(shù)?？紤]定時(shí)器有個(gè)建立和銷毀的過程，看了前面兩個(gè) 接口函數(shù)，就不容置疑的把建立的過程置入contextInitialized，把銷毀的過程置入contextDestroyed了。

我把ServletContextListener的實(shí)現(xiàn)類取名為ContextListener,在其內(nèi)添加一個(gè)定時(shí)器，示例代碼如下所示（為考慮篇幅，僅提供部分代碼供讀者參考）：

private java.util.Timer timer = null;

public void contextInitialized(ServletContextEvent event) {

timer = new java.util.Timer(true);

event.getServletContext().log("定時(shí)器已啟動(dòng)");

timer.schedule(new MyTask(event.getServletContext()), 0, 60*60*1000);

event.getServletContext().log("已經(jīng)添加任務(wù)調(diào)度表");

}

public void contextDestroyed(ServletContextEvent event) {

timer.cancel();

event.getServletContext().log("定時(shí)器銷毀");

}

以上代碼中, timer.schedule(new MyTask(event.getServletContext()), 0, 60*60*1000) 這一行為定時(shí)器調(diào)度語(yǔ)句，其中MyTask是自定義需要被調(diào)度的執(zhí)行任務(wù)（在我的財(cái)政數(shù)據(jù)中心項(xiàng)目中就是報(bào)表計(jì)算引擎入口），從 java.util.TimerTask繼承，下面會(huì)重點(diǎn)講述，第三個(gè)參數(shù)表示每小時(shí)(即60*60*1000毫秒)被觸發(fā)一次，中間參數(shù)0表示無(wú)延遲。 其它代碼相當(dāng)簡(jiǎn)單，不再詳細(xì)說(shuō)明。

下 面介紹MyTask的實(shí)現(xiàn)，上面的代碼中看到了在構(gòu)造MyTask時(shí)，傳入了javax.servlet.ServletContext類型參數(shù),是為記 錄Servlet日志方便而傳入，因此需要重載MyTask的構(gòu)造函數(shù)（其父類java.util.TimerTask原構(gòu)造函數(shù)是沒有參數(shù)的）。在 timer.schedule()的調(diào)度中,設(shè)置了每小時(shí)調(diào)度一次,因此如果想實(shí)現(xiàn)調(diào)度任務(wù)每24小時(shí)被執(zhí)行一次，還需要判斷一下時(shí)鐘點(diǎn)，以常量 C_SCHEDULE_HOUR表示(晚上12點(diǎn)，也即0點(diǎn))。同時(shí)為防止24小時(shí)執(zhí)行下來(lái)，任務(wù)還未執(zhí)行完（當(dāng)然，一般任務(wù)是沒有這么長(zhǎng)的），避免第二 次又被調(diào)度以引起執(zhí)行沖突，設(shè)置了當(dāng)前是否正在執(zhí)行的狀態(tài)標(biāo)志isRunning。示例代碼如下所示：

private static final int C_SCHEDULE_HOUR = 0;

private static boolean isRunning = false;

private ServletContext context = null;

public MyTask(ServletContext context) {

this.context = context;

}

public void run() {

Calendar cal = Calendar.getInstance();

if (!isRunning) {

if (C_SCHEDULE_HOUR == cal.get(Calendar.HOUR_OF_DAY)) {

isRunning = true;

context.log("開始執(zhí)行指定任務(wù)");

//TODO 添加自定義的詳細(xì)任務(wù)，以下只是示例

int i = 0;

while (i++ < 10) {

context.log("已完成任務(wù)的" + i + "http://blog.csdn.net/" + 10);

}

isRunning = false;

context.log("指定任務(wù)執(zhí)行結(jié)束");

}

} else {

context.log("上一次任務(wù)執(zhí)行還未結(jié)束");

}

}

上面代碼中“//TODO……”之下四行是真正被調(diào)度執(zhí)行的演示代碼(在我的財(cái)政數(shù)據(jù)中心項(xiàng)目中就是報(bào)表計(jì)算過程)，您可以換成自己希望執(zhí)行的語(yǔ)句。

到這兒，ServletContextListener和MyTask的代碼都已完整了。最后一步就是把ServletContextListener部署到您的Web工程中去，在您工程的web.xml配置文件中加入如下三行：

com.test.ContextListener

當(dāng)然，上面的com.test得換成您自己的包名了。保存web.xml文件后，把工程打包部署到Tomcat中即可。任務(wù)會(huì)在每晚12點(diǎn)至凌晨1點(diǎn)之間被執(zhí)行，上面的代碼會(huì)在Tomcat的日志文件中記錄如下：

2003-12-05 0：21：39 開始執(zhí)行指定任務(wù)

2003-12-05 0：21：39 已完成任務(wù)的1/10

……

2003-12-05 0：21：39 已完成任務(wù)的10/10

2003-12-05 0：21：39 指定任務(wù)執(zhí)行結(jié)束

如何使用ServletContextListener

ideawu 發(fā)表于2006-06-23 18:20:15 分類: Web 狀態(tài): 公眾可見 查看: 775 評(píng)論: 0

這 個(gè)J2EE小提示闡述了ServletContextListener的用法。這個(gè)事件類作為Web應(yīng)用程序的一部分，處理Web應(yīng)用程序的 servlet上下文(context)的變化的通知。這可以解釋為，好像有個(gè)人在服務(wù)器旁不斷地通知我們服務(wù)器在發(fā)生什么事件。那當(dāng)然需要監(jiān)聽者了。因 此，在通知上下文(context)初始化和銷毀的時(shí)候，ServletContextListner非常有用。

import javax.servlet.ServletContextListener;

import javax.servlet.ServletContextEvent;

import javax.servlet.*;

public class MyListener implements ServletContextListener {

private ServletContext context = null;

/* 這個(gè)方法在Web應(yīng)用服務(wù)被移除，沒有能力再接受請(qǐng)求的時(shí)候被調(diào)用。

*/

public void contextDestroyed(ServletContextEvent event){

//Output a simple message to the server's console

System.out.println("The Simple Web App. Has Been Removed");

this.context = null;

}

// 這個(gè)方法在Web應(yīng)用服務(wù)做好接受請(qǐng)求的時(shí)候被調(diào)用。

public void contextInitialized(ServletContextEvent event){

this.context = event.getServletContext();

//Output a simple message to the server's console

System.out.println("The Simple Web App. Is Ready");

}

}

<web-app>

<listener>

<listener-class>

com.listeners.MyContextListener

</listener-class>

</listener>

<servlet/>

<servlet-mapping/>

</web-app>