<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    KevinGong

      BlogJava :: 首頁 :: 聯(lián)系 :: 聚合  :: 管理
      15 Posts :: 1 Stories :: 9 Comments :: 0 Trackbacks

    最近做一個cts,其中有一個定時報警的需求,網(wǎng)上找了點資料參考!

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

    ???? 好多朋友用過Windows的任務(wù)計劃,也有不少程序迷自己曾寫過時鐘報警、系統(tǒng)自動關(guān)機(jī)等趣味程序,可卻很少有朋友在Web工程中實現(xiàn)過類似功能。今天有空把筆者先前曾在Tomcat上實現(xiàn)的類似功能,搬出來與大家共享。
    ??? ?早在幾年前,我公司跟某市財政局合作項目開發(fā),為加強(qiáng)財政局對所屬單位財務(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),但用緩存需要一個合理的緩存更新機(jī)制。考慮到各市屬單位每天下班前才把財務(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工程生命期,在工程啟動時能自動加載運(yùn)行。結(jié)合這兩點,跟Servlet上下文有關(guān)的偵聽器就最合適不過了,通過在工程的配置文件中加以合理配置,會在工程啟動時自動運(yùn)行,并在整個工程生命期中處于監(jiān)聽狀態(tài)。
    ??? 下面就Servlet偵聽器結(jié)合Java定時器來講述整個實現(xiàn)過程。要運(yù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("定時器銷毀");
    ??? }

    ??? 以上代碼中, timer.schedule(new MyTask(event.getServletContext()), 0, 60*60*1000)這一行為定時器調(diào)度語句,其中MyTask是自定義需要被調(diào)度的執(zhí)行任務(wù)(在我的財政數(shù)據(jù)中心項目中就是報表計算引擎入口),從java.util.TimerTask繼承,下面會重點講述,第三個參數(shù)表示每小時(即60*60*1000毫秒)被觸發(fā)一次,中間參數(shù)0表示無延遲。其它代碼相當(dāng)簡單,不再詳細(xì)說明。
    ?? 下面介紹MyTask的實現(xiàn),上面的代碼中看到了在構(gòu)造MyTask時,傳入了javax.servlet.ServletContext類型參數(shù),是為記錄Servlet日志方便而傳入,因此需要重載MyTask的構(gòu)造函數(shù)(其父類java.util.TimerTask原構(gòu)造函數(shù)是沒有參數(shù)的)。在timer.schedule()的調(diào)度中,設(shè)置了每小時調(diào)度一次,因此如果想實現(xiàn)調(diào)度任務(wù)每24小時被執(zhí)行一次,還需要判斷一下時鐘點,以常量C_SCHEDULE_HOUR表示(晚上12點,也即0點)。同時為防止24小時執(zhí)行下來,任務(wù)還未執(zhí)行完(當(dāng)然,一般任務(wù)是沒有這么長的),避免第二次又被調(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 + "/" + 10);
    ??????????????? }

    ??????????????? isRunning = false;
    ??????????????? context.log("指定任務(wù)執(zhí)行結(jié)束");???????????????
    ??????????? }????????????
    ??????? } else {
    ??????????? context.log("上一次任務(wù)執(zhí)行還未結(jié)束");
    ??????? }
    ??? }

    ??? 上面代碼中“//TODO……”之下四行是真正被調(diào)度執(zhí)行的演示代碼(在我的財政數(shù)據(jù)中心項目中就是報表計算過程),您可以換成自己希望執(zhí)行的語句。
    到這兒,ServletContextListener和MyTask的代碼都已完整了。最后一步就是把ServletContextListener部署到您的Web工程中去,在您工程的web.xml配置文件中加入如下三行:
    ???
    ??????? com.test.ContextListener
    ????
    ??? 當(dāng)然,上面的com.test得換成您自己的包名了。保存web.xml文件后,把工程打包部署到Tomcat中即可。任務(wù)會在每晚12點至凌晨1點之間被執(zhí)行,上面的代碼會在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é)束

    posted on 2006-08-06 21:48 KevinGong 閱讀(290) 評論(0)  編輯  收藏 所屬分類: JSP+Servlet+JavaBean

    只有注冊用戶登錄后才能發(fā)表評論。


    網(wǎng)站導(dǎo)航:
     
    主站蜘蛛池模板: 日本一道一区二区免费看| 日产国产精品亚洲系列| 久久精品亚洲视频| 成人片黄网站色大片免费观看cn| 亚洲av再在线观看| 一个人晚上在线观看的免费视频| 中文字幕免费在线视频| 亚洲伦乱亚洲h视频| 一级毛片免费视频网站| 久久亚洲中文字幕精品一区四| 亚洲综合日韩中文字幕v在线| 青青草原1769久久免费播放| 亚洲av片劲爆在线观看| 国产成人不卡亚洲精品91| 久久国产精品2020免费m3u8 | 久久久久免费精品国产小说| 亚洲成人在线电影| 亚洲毛片在线免费观看| 亚洲综合av一区二区三区| 日本成人免费在线| 亚洲第一视频在线观看免费| 亚洲AV日韩AV永久无码下载| 国产四虎免费精品视频| 亚洲欧好州第一的日产suv| 亚洲精品免费观看| 日本亚洲免费无线码 | 男女交性永久免费视频播放| 美女视频黄频a免费| 国产精品亚洲成在人线| 97性无码区免费| 亚洲AV无码专区在线厂| 国产亚洲3p无码一区二区| 免费在线观看h片| 久久夜色精品国产噜噜噜亚洲AV| 亚洲免费综合色在线视频| 亚洲视频一区在线播放| 成全高清在线观看免费| 亚洲国产人成精品| 最好看最新的中文字幕免费| 亚洲乱码中文字幕久久孕妇黑人| 91热久久免费精品99|