少年阿賓

          那些青春的歲月

            BlogJava :: 首頁 :: 聯系 :: 聚合  :: 管理
            500 Posts :: 0 Stories :: 135 Comments :: 0 Trackbacks

          深入解讀Quartz的原理
           
          Quartz是一個大名鼎鼎的Java版開源定時調度器,功能強悍,使用方便。
           
          一、核心概念
           
          Quartz的原理不是很復雜,只要搞明白幾個概念,然后知道如何去啟動和關閉一個調度程序即可。
           
          1、Job
          表示一個工作,要執行的具體內容。此接口中只有一個方法
          void execute(JobExecutionContext context)
           
          2、JobDetail
          JobDetail表示一個具體的可執行的調度程序,Job是這個可執行程調度程序所要執行的內容,另外JobDetail還包含了這個任務調度的方案和策略。

           
          3、Trigger代表一個調度參數的配置,什么時候去調。
           
          4、Scheduler代表一個調度容器,一個調度容器中可以注冊多個JobDetail和Trigger。當Trigger與JobDetail組合,就可以被Scheduler容器調度了。
           
           
          二、一個最簡單入門實例
           
          import org.quartz.*;
          import org.quartz.impl.StdSchedulerFactory;

          import java.util.Date;

          /**
          * quartz定時器測試
          *
          * @author leizhimin 2009-7-23 8:49:01
          */
          public class MyJob implements Job {
                  public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
                          System.out.println(new Date() + ": doing something...");
                  }
          }

          class Test {
                  public static void main(String[] args) {
                          //1、創建JobDetial對象
                          JobDetail jobDetail = new JobDetail();
                          //設置工作項
                          jobDetail.setJobClass(MyJob.class);
                          jobDetail.setName("MyJob_1");
                          jobDetail.setGroup("JobGroup_1");

                          //2、創建Trigger對象
                          SimpleTrigger strigger = new SimpleTrigger();
                          strigger.setName("Trigger_1");
                          strigger.setGroup("Trigger_Group_1");
                          strigger.setStartTime(new Date());
                          //設置重復停止時間,并銷毀該Trigger對象
                          java.util.Calendar c = java.util.Calendar.getInstance();
                          c.setTimeInMillis(System.currentTimeMillis() + 1000 * 1L);
                          strigger.setEndTime(c.getTime());
                          strigger.setFireInstanceId("Trigger_1_id_001");
                          //設置重復間隔時間
                          strigger.setRepeatInterval(1000 * 1L);
                          //設置重復執行次數
                          strigger.setRepeatCount(3);

                          //3、創建Scheduler對象,并配置JobDetail和Trigger對象
                          SchedulerFactory sf = new StdSchedulerFactory();
                          Scheduler scheduler = null;
                          try {
                                  scheduler = sf.getScheduler();
                                  scheduler.scheduleJob(jobDetail, strigger);
                                  //4、并執行啟動、關閉等操作
                                  scheduler.start();

                          } catch (SchedulerException e) {
                                  e.printStackTrace();
                          }
          //                try {
          //                        //關閉調度器
          //                        scheduler.shutdown(true);
          //                } catch (SchedulerException e) {
          //                        e.printStackTrace();
          //                }
                  }
          }
           
          執行結果:

           
          當把結束時間改為:
                          //設置重復停止時間,并銷毀該Trigger對象
                          java.util.Calendar c = java.util.Calendar.getInstance();
                          c.setTimeInMillis(System.currentTimeMillis() + 1000 * 1L);
                          strigger.setEndTime(c.getTime());
           
          執行結果:
           
          當添加一條關閉調度器的語句:
                                  //4、并執行啟動、關閉等操作
                                  scheduler.start();
                                  scheduler.shutdown(true);

           
          程序執行結果:
          Thu Jul 23 10:11:50 CST 2009: doing something...

          Process finished with exit code 0
          僅僅執行了一次,這一次能執行完,原因是設定了scheduler.shutdown(true);true表示等待本次任務執行完成后停止。
           
          從這里也可以看出,scheduler是個容器,scheduler控制jobDetail的執行,控制的策略是通過trigger。
           
          當scheduler容器啟動后,jobDetail才能根據關聯的trigger策略去執行。當scheduler容器關閉后,所有的jobDetail都停止執行。
           
          三、透過實例看原理
           
          通過研讀Quartz的源代碼,和本實例,終于悟出了Quartz的工作原理。
           
          1、scheduler是一個計劃調度器容器(總部),容器里面可以盛放眾多的JobDetail和trigger,當容器啟動后,里面的每個JobDetail都會根據trigger按部就班自動去執行。
           
          2、JobDetail是一個可執行的工作,它本身可能是有狀態的。
           
          3、Trigger代表一個調度參數的配置,什么時候去調。
           
          4、當JobDetail和Trigger在scheduler容器上注冊后,形成了裝配好的作業(JobDetail和Trigger所組成的一對兒),就可以伴隨容器啟動而調度執行了。
           
          5、scheduler是個容器,容器中有一個線程池,用來并行調度執行每個作業,這樣可以提高容器效率。
           
          6、將上述的結構用一個圖來表示,如下:
           

           
          四、總結
           
          1、搞清楚了上Quartz容器執行作業的的原理和過程,以及作業形成的方式,作業注冊到容器的方法。就認識明白了Quartz的核心原理。
           
          2、Quartz雖然很龐大,但是一切都圍繞這個核心轉,為了配置強大時間調度策略,可以研究專門的CronTrigger。要想靈活配置作業和容器屬性,可以通過Quartz的properties文件或者XML來實現。
           
          3、要想調度更多的持久化、結構化作業,可以通過數據庫讀取作業,然后放到容器中執行。
           
          4、所有的一切都圍繞這個核心原理轉,搞明白這個了,再去研究更高級用法就容易多了。
           
          5、Quartz與Spring的整合也非常簡單,Spring提供一組Bean來支持:MethodInvokingJobDetailFactoryBean、SimpleTriggerBean、SchedulerFactoryBean,看看里面需要注入什么屬性即可明白了。Spring會在Spring容器啟動時候,啟動Quartz容器。
           
          6、Quartz容器的關閉方式也很簡單,如果是Spring整合,則有兩種方法,一種是關閉Spring容器,一種是獲取到SchedulerFactoryBean實例,然后調用一個shutdown就搞定了。如果是Quartz獨立使用,則直接調用scheduler.shutdown(true);
           
          7、Quartz的JobDetail、Trigger都可以在運行時重新設置,并且在下次調用時候起作用。這就為動態作業的實現提供了依據。你可以將調度時間策略存放到數據庫,然后通過數據庫數據來設定Trigger,這樣就能產生動態的調度。



          http://blog.csdn.net/jiangfeng861016/article/details/5970745




          posted on 2012-08-25 11:48 abin 閱讀(3289) 評論(1)  編輯  收藏 所屬分類: quartz

          Feedback

          # re: 純代碼實現Quartz定時器(一) 2014-06-06 18:07 fxqy
          用他能實現定時(晚上0點)刪除數據庫記錄的功能?  回復  更多評論
            

          主站蜘蛛池模板: 西盟| 阿拉善右旗| 徐汇区| 扎赉特旗| 尼木县| 平塘县| 青河县| 英山县| 台湾省| 安福县| 沅江市| 墨玉县| 化德县| 广灵县| 南和县| 延寿县| 大城县| 土默特右旗| 丽水市| 伊宁市| 道孚县| 宁乡县| 驻马店市| 新泰市| 庐江县| 禄劝| 株洲县| 满洲里市| 邻水| 乌海市| 余庆县| 汤原县| 上林县| 阿拉善盟| 宁陵县| 定安县| 育儿| 阜城县| 象山县| 嘉兴市| 绍兴市|