如何在Web工程中實現(xiàn)任務(wù)計劃調(diào)度

字號:

好多朋友用過Windows的任務(wù)計劃,也有不少程序迷自己曾寫過時鐘報警、系統(tǒng)自動關(guān)機等趣味程序,可卻很少有朋友在Web工程中實現(xiàn)過類似功能。今天有空把筆者先前曾在Tomcat上實現(xiàn)的類似功能,搬出來與大家共享。
     早在幾年前,我公司跟某市財政局合作項目開發(fā),為加強財政局對所屬單位財務(wù)狀況的有效監(jiān)管,開發(fā)、實施了財政局?jǐn)?shù)據(jù)中心項目。此項目采用B/S加C/S混合結(jié)構(gòu)模式。財政局Web服務(wù)器上架設(shè)數(shù)據(jù)同步接收裝置,由市屬單位每天下班前把財務(wù)信息通過HTTP協(xié)議上傳至財政局中心服務(wù)器,與Web服務(wù)器上的接收裝置對接。財政局內(nèi)部各部門需要查閱大量財務(wù)信息,獲取完備的市屬單位當(dāng)前財務(wù)狀況信息,各部門按職能劃分,需要準(zhǔn)確的獲取各部門各自所關(guān)注的匯總信息,以財政報表的形式提供。
     因財政數(shù)據(jù)量大,實時計算財政報表速度較慢,當(dāng)初就考慮用報表緩存來減輕服務(wù)器的負(fù)擔(dān),但用緩存需要一個合理的緩存更新機制??紤]到各市屬單位每天下班前才把財務(wù)數(shù)據(jù)上傳,財政局每天所查看到的財務(wù)信息其實并不包括當(dāng)天(除非有某位領(lǐng)導(dǎo)等到所屬單位全部上傳完之后才來查看信息,應(yīng)該已經(jīng)下班了),所以要是能實現(xiàn)任務(wù)計劃調(diào)度,在每晚深夜把當(dāng)天及歷史財務(wù)信息匯總,更新緩存,速度瓶頸不就解決了嗎。
     當(dāng)時由于系統(tǒng)核心是基于Web部署的,報表計算引擎也相應(yīng)的部署在Tomcat容器上,因此如果想要借用Windows的任務(wù)計劃來實現(xiàn)定時計算,就需要額外編寫普通桌面應(yīng)用程序接口,稍顯復(fù)雜。于是就琢磨著想在Web上實現(xiàn),經(jīng)過查閱較多相關(guān)資料,發(fā)現(xiàn)Java定時器(java.util.Timer)有定時觸發(fā)計劃任務(wù)的功能,通過配置定時器的間隔時間,在某一間隔時間段之后會自動有規(guī)律的調(diào)用預(yù)先所安排的計劃任務(wù)(java.util.TimerTask)。另外,由于我們希望當(dāng)Web工程啟動時,定時器能自動開始計時,在整個Web工程的生命期里,定時器能在每晚深夜觸發(fā)一次報表計算引擎。因此定時器的存放位置也值得考查,不能簡單的存在于單個Servlet或JavaBean中,必須能讓定時器宿主的存活期為整個Web工程生命期,在工程啟動時能自動加載運行。結(jié)合這兩點,跟Servlet上下文有關(guān)的偵聽器就最合適不過了,通過在工程的配置文件中加以合理配置,會在工程啟動時自動運行,并在整個工程生命期中處于監(jiān)聽狀態(tài)。
     下面就Servlet偵聽器結(jié)合Java定時器來講述整個實現(xiàn)過程。要運用Servlet偵聽器需要實現(xiàn)javax.servlet.ServletContextListener接口,同時實現(xiàn)它的contextInitialized(ServletContextEvent event)和contextDestroyed(ServletContextEvent event)兩個接口函數(shù)??紤]定時器有個建立和銷毀的過程,看了前面兩個接口函數(shù),就不容置疑的把建立的過程置入contextInitialized,把銷毀的過程置入contextDestroyed了。
     我把ServletContextListener的實現(xiàn)類取名為ContextListener,在其內(nèi)添加一個定時器,示例代碼如下所示(為考慮篇幅,僅提供部分代碼供讀者參考):
     private java.util.Timer timer = null;
     public void contextInitialized(ServletContextEvent event) {
     timer = new java.util.Timer(true);
     event.getServletContext().log("定時器已啟動");
     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("定時器銷毀");
     }