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

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

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

    無線&移動互聯網技術研發

    換位思考·····
    posts - 19, comments - 53, trackbacks - 0, articles - 283
      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

    Spring Quartz 任務調度存儲信息(三)

    Posted on 2010-05-27 13:49 Gavin.lee 閱讀(2360) 評論(0)  編輯  收藏 所屬分類: SSH2 --Spring

    任務調度信息存儲

    在默認情況下Quartz將任務調度的運行信息保存在內存中,這種方法提供了最佳的性能,因為內存中數據訪問最快。不足之處是缺乏數據的持久性,當程序路途停止或系統崩潰時,所有運行的信息都會丟失。

    比如我們希望安排一個執行100次的任務,如果執行到50次時系統崩潰了,系統重啟時任務的執行計數器將從0開始。在大多數實際的應用中,我們往往并不需要保存任務調度的現場數據,因為很少需要規劃一個指定執行次數的任務。

    對于僅執行一次的任務來說,其執行條件信息本身應該是已經持久化的業務數據(如鎖定到期解鎖任務,解鎖的時間應該是業務數據),當執行完成后,條件信息也會相應改變。當然調度現場信息不僅僅是記錄運行次數,還包括調度規則、JobDataMap中的數據等等。

    如果確實需要持久化任務調度信息,Quartz允許你通過調整其屬性文件,將這些信息保存到數據庫中。使用數據庫保存任務調度信息后,即使系統崩潰后重新啟動,任務的調度信息將得到恢復。如前面所說的例子,執行50次崩潰后重新運行,計數器將從51開始計數。使用了數據庫保存信息的任務稱為持久化任務。

    通過配置文件調整任務調度信息的保存策略

    其實Quartz JAR文件的org.quartz包下就包含了一個quartz.properties屬性配置文件并提供了默認設置。如果需要調整默認配置,可以在類路徑下建立一個新的quartz.properties,它將自動被Quartz加載并覆蓋默認的設置。

    先來了解一下Quartz的默認屬性配置文件:

    代碼清單5 quartz.properties:默認配置

    集群的配置,這里不使用集群

    org.quartz.scheduler.instanceName = DefaultQuartzScheduler

    org.quartz.scheduler.rmi.export = false

    org.quartz.scheduler.rmi.proxy = false

    org.quartz.scheduler.wrapJobExecutionInUserTransaction = false

    配置調度器的線程池

    org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool

    org.quartz.threadPool.threadCount = 10

    org.quartz.threadPool.threadPriority = 5

    org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

    配置任務調度現場數據保存機制

    org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

    Quartz的屬性配置文件主要包括三方面的信息:

    1)集群信息;

    2)調度器線程池;

    3)任務調度現場數據的保存。

    如果任務數目很大時,可以通過增大線程池的大小得到更好的性能。默認情況下,Quartz采用org.quartz.simpl.RAMJobStore保存任務的現場數據,顧名思義,信息保存在RAM內存中,我們可以通過以下設置將任務調度現場數據保存到數據庫中:

    代碼清單6 quartz.properties:使用數據庫保存任務調度現場數據

    org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX

    org.quartz.jobStore.tablePrefix = QRTZ_數據表前綴

    org.quartz.jobStore.dataSource = qzDS數據源名稱

    定義數據源的具體屬性

    org.quartz.dataSource.qzDS.driver = oracle.jdbc.driver.OracleDriver

    org.quartz.dataSource.qzDS.URL = jdbc:oracle:thin:@localhost:1521:ora9i

    org.quartz.dataSource.qzDS.user = stamen

    org.quartz.dataSource.qzDS.password = abc

    org.quartz.dataSource.qzDS.maxConnections = 10

    要將任務調度數據保存到數據庫中,就必須使用org.quartz.impl.jdbcjobstore.JobStoreTX代替原來的org.quartz.simpl.RAMJobStore并提供相應的數據庫配置信息。首先處指定了Quartz數據庫表的前綴,在處定義了一個數據源,在處具體定義這個數據源的連接信息。

    你必須事先在相應的數據庫中創建Quartz的數據表(共8張),在Quartz的完整發布包的docs/dbTables目錄下擁有對應不同數據庫的SQL腳本。

    查詢數據庫中的運行信息

    任務的現場保存對于上層的Quartz程序來說是完全透明的,我們在src目錄下編寫一個如代碼清單6所示的quartz.properties文件后,重新運行代碼清單2或代碼清單3的程序,在數據庫表中將可以看到對應的持久化信息。當調度程序運行過程中途停止后,任務調度的現場數據將記錄在數據表中,在系統重啟時就可以在此基礎上繼續進行任務的調度。

    代碼清單7 JDBCJobStoreRunner:從數據庫中恢復任務的調度

    package com.baobaotao.basic.quartz;

    import org.quartz.Scheduler;

    import org.quartz.SchedulerFactory;

    import org.quartz.SimpleTrigger;

    import org.quartz.Trigger;

    import org.quartz.impl.StdSchedulerFactory;

    public class JDBCJobStoreRunner {

        public static void main(String args[]) {

           try {

               SchedulerFactory schedulerFactory = new StdSchedulerFactory();

               Scheduler scheduler = schedulerFactory.getScheduler();

               // ①獲取調度器中所有的觸發器組

               String[] triggerGroups = scheduler.getTriggerGroupNames();

               // ②重新恢復在tgroup1組中,名為trigger1_1觸發器的運行

               for (int i = 0; i < triggerGroups.length; i++) {

                  String[] triggers = scheduler.getTriggerNames(triggerGroups[i]);

                  for (int j = 0; j < triggers.length; j++) {

                      Trigger tg = scheduler.getTrigger(triggers[j],   triggerGroups[i]);

                      // -1:根據名稱判斷

                      if (tg instanceof SimpleTrigger&& tg.getFullName().equals("tgroup1.trigger1_1")) {

                         // -1:恢復運行

                         scheduler.rescheduleJob(triggers[j], triggerGroups[i], tg);

                      }

                  }

               }

               scheduler.start();

           } catch (Exception e) {

               e.printStackTrace();

           }

        }

    }


    當代碼清單2中的SimpleTriggerRunner執行到一段時間后非正常退出,我們就可以通過這個JDBCJobStoreRunner根據記錄在數據庫中的現場數據恢復任務的調度。Scheduler中的所有Trigger以及JobDetail的運行信息都會保存在數據庫中,這里我們僅恢復tgroup1組中名稱為trigger1_1的觸發器,這可以通過如②-1所示的代碼進行過濾,觸發器的采用GROUP.TRIGGER_NAME的全名格式。通過Scheduler#rescheduleJob(String triggerName,String groupName,Trigger newTrigger)即可重新調度關聯某個Trigger的任務。

    下面我們來觀察一下不同時期qrtz_simple_triggers表的數據:

    1.運行代碼清單2SimpleTriggerRunner一小段時間后退出:


    REPEAT_COUNT
    表示需要運行的總次數,而TIMES_TRIGGER表示已經運行的次數。

    2.運行代碼清單7JDBCJobStoreRunner恢復trigger1_1的觸發器,運行一段時間后退出,這時qrtz_simple_triggers中的數據如下:


    首先
    Quartz會將原REPEAT_COUNT-TIMES_TRIGGER得到新的REPEAT_COUNT值,并記錄已經運行的次數(重新從0開始計算)。

    3.重新啟動JDBCJobStoreRunner運行后,數據又將發生相應的變化:


    4
    .繼續運行直至完成所有剩余的次數,再次查詢qrtz_simple_triggers表:


    這時,該表中的記錄已經變空。

    值得注意的是,如果你使用JDBC保存任務調度數據時,當你運行代碼清單2SimpleTriggerRunner然后退出,當再次希望運行SimpleTriggerRunner時,系統將拋出JobDetail重名的異常:

    Unable to store Job with name: 'job1_1' and group: 'jGroup1', because one already exists with this identification.

    因為每次調用Scheduler#scheduleJob()時,Quartz都會將JobDetailTrigger的信息保存到數據庫中,如果數據表中已經同名的JobDetailTrigger,異常就產生了。

    本文使用quartz 1.6版本,我們發現當后臺數據庫使用MySql時,數據保存不成功,該錯誤是Quartz的一個Bug,相信會在高版本中得到修復。因為HSQLDB不支持SELECT * FROM TABLE_NAME FOR UPDATE的語法,所以不能使用HSQLDB數據庫。

    小結

    Quartz提供了最為豐富的任務調度功能,不但可以制定周期性運行的任務調度方案,還可以讓你按照日歷相關的方式進行任務調度。Quartz框架的重要組件包括JobJobDetailTriggerScheduler以及輔助性的JobDataMapSchedulerContext

    Quartz擁有一個線程池,通過線程池為任務提供執行線程,你可以通過配置文件對線程池進行參數定制。Quartz的另一個重要功能是可將任務調度信息持久化到數據庫中,以便系統重啟時能夠恢復已經安排的任務。此外,Quartz還擁有完善的事件體系,允許你注冊各種事件的監聽器。

    主站蜘蛛池模板: 亚洲免费视频一区二区三区| 久久国产色AV免费看| 九月丁香婷婷亚洲综合色| 久久国产色AV免费观看| 亚洲日韩国产二区无码| 亚洲一区二区三区免费| 成人午夜免费福利视频| 美女被爆羞羞网站在免费观看| 亚洲精品国产精品乱码不卡√| 在线观看日本免费a∨视频| 国产黄色免费观看| 亚洲小说图片视频| 久久亚洲中文字幕精品一区| 91免费国产在线观看| 一级毛片a免费播放王色电影 | 久久久久久国产a免费观看不卡 | 亚洲国产av一区二区三区丶| 日韩精品亚洲专区在线观看| 亚洲视频免费在线看| 一出一进一爽一粗一大视频免费的 | 99在线视频免费观看视频 | 亚洲最大中文字幕无码网站| 亚洲综合熟女久久久30p| 亚洲高清中文字幕免费| 爽爽爽爽爽爽爽成人免费观看| 四虎必出精品亚洲高清| 久久久亚洲欧洲日产国码农村| 日韩精品亚洲专区在线观看| 国产成人免费网站| 亚洲免费精彩视频在线观看| 男女猛烈无遮掩视频免费软件 | 亚洲狠狠成人综合网| 亚洲成人免费在线| 亚洲中文字幕伊人久久无码| 日韩免费视频在线观看| 啦啦啦完整版免费视频在线观看| 久久国产一片免费观看| 看一级毛片免费观看视频| 亚洲一区二区观看播放| 亚洲va在线va天堂va手机| 亚洲国产精品自在在线观看|