閱讀825 返回首頁    go 阿裏雲 go 技術社區[雲棲]


Quartz教程:快速入門

本係列教程由quartz-2.2.x官方文檔翻譯、整理而來,希望給同樣對quartz感興趣的朋友一些參考和幫助,有任何不當或錯誤之處,歡迎指正;有興趣研究源碼的同學,可以參考我對quartz-core源碼的注釋(進行中)

歡迎來到quartz快速入門教程。閱讀本教程,你將會了解:

  • quartz下載
  • quartz安裝
  • 根據你的需要,配置Quartz
  • 開始一個示例應用

當熟悉了quratz調度的基本功能後,可以嚐試一些更高級的特性,比如Where,這個一個企業級功能,可以讓job和trigger運行在指定的,而不是隨機的Terracotta客戶端上。

下載和安裝

首先,下載最新的穩定版 – 不用注冊。解壓並安裝。

Quartz jar文件

quartz安裝包根目錄的lib/目錄下有很多的jar包。其中,quartz-xxx.jar(其中xxx是版本號)是最主要的。為了使用quartz,必須將該jar包放在應用的classpath下;

下載後,解壓,然後將quartz-xxx.jar放到你的應用中。

我主要是在應用服務器的環境中使用quartz,所以一般將quartz jar包放到應用中(.ear或.war)。當然,如果你希望在很多應用中使用quartz,將quartz的jar包放在應用服務器(appserver)的classpath下即可。如果你隻是希望在獨立的應用中使用quartz,將quartz的jar包和你的應用依賴的其它jar包放在一起即可。

quzrtz依賴一些第三方的庫(以jar包的形式),這些庫位於quartz安裝包的lib目錄下。要使用quartz的所有功能,必須將所有的第三方jar包都放到classpath下。如果你開發的是一個獨立的quartz應用,建議將所有的jar包都放到classpath下;如果是在應用服務器環境下使用quartz,其中有些包可能已經存在於classpath中了,因此你需要自己選擇。

在應用服務器環境下,如果同一個jar文件,存在兩個不同的版本,要注意,可能會產生一些奇怪的結果;比如,WebLogic包含了一個J2EE的實現(在weblogic.jar中),該實現與servlet.jar的實現可能不一致。此時,應該從你的應用中排除掉servlet.jar,這樣你就知道使用的是哪個類了。

properties文件

quartz使用名為quartz.properties的配置文件。剛開始時該配置文件不是必須的,但是為了使用最基本的配置,該文件必須位於classpath下。

基於我的個人情況舉個例子,我的應用是基於WebLogic Workshop開發的。我將所有的配置文件(包括quartz.properties)放到應用根目錄下的一個項目中。當我將項目打包成.ear文件時,放置配置文件的項目會以jar包的形式進入最終的.ear包,所以quartz.properties文件就自動位於classpath中了。

如果你準備構建一個使用quartz的web應用(以.war包的形式),你應該將quartz.properties文件放到WEB-INF/classes目錄下。

配置

這裏包含很多內容。quartz是一個配置很靈活的應用。配置quartz最好的方式是,編輯quartz.properties文件,然後放到應用的classpath下。

quartz的安裝包中包含了一些配置文件的示例,位於example/目錄下。我建議你創建自己的quartz.properties文件,而不是簡單地從示例中拷貝並刪除不需要的部分。這樣看起來更整潔,而且你也會了解到quartz的更多功能。

關於quartz配置文件的詳細文檔,請查閱Quartz配置參考

為了使用quartz,一個基本的quartz.properties配置文件如下所示:

org.quartz.scheduler.instanceName = MyScheduler
org.quartz.threadPool.threadCount = 3
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

上述配置的scheduler有如下特點:

  • org.quartz.scheduler.instanceName scheduler的名稱為“MyScheduler”
  • org.quartz.threadPool.threadCount 線程池中有3個線程,即最多可以同時執行3個job;
  • org.quartz.jobStore.class quartz的所有數據,包括job和trigger的配置,都會存儲在內存中(而不是數據庫裏)。如果你想使用quartz的數據庫存儲功能(校對注:設置成另外一個類),我們建議在使用數據庫存儲之前,先使用內存存儲(RamJobStore)。

示例應用

下載和安裝完quartz後,是時候開發一個示例應用,並讓它跑起來了。下麵的示例代碼,獲取scheduler實例對象,啟動,然後關閉。

QuartzTest.java


    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.impl.StdSchedulerFactory;
    import static org.quartz.JobBuilder.*;
    import static org.quartz.TriggerBuilder.*;
    import static org.quartz.SimpleScheduleBuilder.*;

    public class QuartzTest {

        public static void main(String[] args) {

            try {
                // Grab the Scheduler instance from the Factory 
                Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

                // and start it off
                scheduler.start();

                scheduler.shutdown();

            } catch (SchedulerException se) {
                se.printStackTrace();
            }
        }
    }

當你調用StdSchedulerFactory.getDefaultScheduler()獲取scheduler實例對象後,在調用scheduler.shutdown()之前,scheduler不會終止,因為還有活躍的線程在執行。

注意示例代碼中的靜態導入(static import),下麵的代碼中也會用到它們。

如果你沒有配置日誌輸出,所有的日誌會輸出到控製台,比如:

[INFO] 21 Jan 08:46:27.857 AM main [org.quartz.core.QuartzScheduler]
Quartz Scheduler v.2.0.0-SNAPSHOT created.

[INFO] 21 Jan 08:46:27.859 AM main [org.quartz.simpl.RAMJobStore]
RAMJobStore initialized.

[INFO] 21 Jan 08:46:27.865 AM main [org.quartz.core.QuartzScheduler]
Scheduler meta-data: Quartz Scheduler (v2.0.0) 'Scheduler' with instanceId 'NON_CLUSTERED'
  Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
  NOT STARTED.
  Currently in standby mode.
  Number of jobs executed: 0
  Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 50 threads.
  Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.


[INFO] 21 Jan 08:46:27.865 AM main [org.quartz.impl.StdSchedulerFactory]
Quartz scheduler 'Scheduler' initialized from default resource file in Quartz package: 'quartz.properties'

[INFO] 21 Jan 08:46:27.866 AM main [org.quartz.impl.StdSchedulerFactory]
Quartz scheduler version: 2.0.0

[INFO] 21 Jan 08:46:27.866 AM main [org.quartz.core.QuartzScheduler]
Scheduler Scheduler_$_NON_CLUSTERED started.

[INFO] 21 Jan 08:46:27.866 AM main [org.quartz.core.QuartzScheduler]
Scheduler Scheduler_$_NON_CLUSTERED shutting down.

[INFO] 21 Jan 08:46:27.866 AM main [org.quartz.core.QuartzScheduler]
Scheduler Scheduler_$_NON_CLUSTERED paused.

[INFO] 21 Jan 08:46:27.867 AM main [org.quartz.core.QuartzScheduler]
Scheduler Scheduler_$_NON_CLUSTERED shutdown complete.

你可以在start()和shutdown()之間做一些有趣的事情:

    // define the job and tie it to our HelloJob class
    JobDetail job = newJob(HelloJob.class)
        .withIdentity("job1", "group1")
        .build();

    // Trigger the job to run now, and then repeat every 40 seconds
    Trigger trigger = newTrigger()
        .withIdentity("trigger1", "group1")
        .startNow()
        .withSchedule(simpleSchedule()
                .withIntervalInSeconds(40)
                .repeatForever())            
        .build();

    // Tell quartz to schedule the job using our trigger
    scheduler.scheduleJob(job, trigger);

在調用shutdown()之前,你需要給job的觸發和執行預留一些時間,比如,你可以調用Thread.sleep(60000)讓線程睡眠一段時間。

好了,自己去探索吧!

最後更新:2017-05-23 17:32:13

  上一篇:go  JVM性能優化(三):垃圾收集
  下一篇:go  Quartz教程一:使用quartz