<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网站永久免费 | 中文字幕在线日亚洲9| 无码乱肉视频免费大全合集| 亚洲大香人伊一本线| 91免费国产在线观看| 亚洲一线产区二线产区区| 毛片免费观看视频| 亚洲AV无码一区二区三区电影 | 久久亚洲精品国产精品| 最近中文字幕大全中文字幕免费| 亚洲国产精品一区| av无码久久久久不卡免费网站| 精品日韩99亚洲的在线发布| 午夜视频免费观看| 日本高清免费中文在线看| 国产午夜亚洲精品国产成人小说| 中文在线观看免费网站| 亚洲尹人香蕉网在线视颅| 成年人视频免费在线观看| 蜜臀亚洲AV无码精品国产午夜.| 免费国产a国产片高清| 免费无码黄网站在线看| 中文字幕亚洲精品| 免费无码看av的网站| 国产福利免费视频| 亚洲婷婷在线视频| 免费人成在线观看视频播放| a级毛片黄免费a级毛片| 亚洲免费视频网址| 亚洲综合精品网站| 四虎最新永久免费视频| 猫咪免费观看人成网站在线| 亚洲视频在线观看一区| 在线看片人成视频免费无遮挡| 国产精品hd免费观看| 亚洲精品欧洲精品| 久久亚洲AV永久无码精品| 99久久这里只精品国产免费 | 午夜老司机永久免费看片|