(轉)Java任務調度框架Quartz入門教程指南(二) 使用job、trigger、schedule調用定時任務


http://blog.csdn.net/zixiao217/article/details/53044890

讀完第一節,我們已經對Quartz有了一個大體的認識,它可以定時幫我們執行一些處理程序,盡管可能你之前對Quartz不了解以至於第一節很多術語(job、trigger等)不理解,沒關系,從現在開始,筆者和你一起在實例中深入理解它們。沒有code,就沒有話語權——程序界真理

(本文章分享在CSDN平台,更多精彩請閱讀 東陸之滇的csdn博客:http://blog.csdn.net/zixiao217)

本系列教程主要使用Maven風格編寫代碼,對於怎樣使用maven,大家可以讀讀許曉斌的《Maven實戰》,相當不錯,筆者入門也是得此書。認真耐心讀完哦。

本節主要內容

  • 下載 Quartz
  • 安裝 Quartz
  • 根據你自己的需要配置 Quartz
  • 編寫第一個示例應用程序

下載和安裝Quartz

首先,你需要下載最新(不一定)穩定版本的Quartz。本系列教程我們使用2.2.1。你可以在官網http://www.quartz-scheduler.org/downloads/下載需要的版本jar包,現在我們使用maven方式:

pom.xml引入quartz依賴:

<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.1</version> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.2.1</version> </dependency>

 

quartz 屬性配置文件

Quartz使用一個quartz.properties的屬性配置文件。它不是必需的,但是使用它的話,你必須將它放置在你項目的classpath目錄下,也就是最終打包后位於WEN-INF/classes目錄下(web項目),使用Maven我們在src/main/resources目錄放置該文件即可。 


Quartz是一個可配置化的應用程序。最好的配置Quartz的方式是使用quartz.properties配置文件。關於Quartz的配置屬性文件的詳細技巧,我們在本系列教程最后會單獨講到,務必精益求精。 
迅速開始一個配置文件的內容,可以參考如下示例編寫:

 

quartz.properties

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

使用上述配置文件創建的任務調度程序有以下特點:

  • org.quartz.scheduler.instanceName - 設置調度程序scheduler的名稱為MyScheduler
  • org.quartz.threadPool.threadCount - 線程里設置了3個線程,意味着最多同時運行3個job
  • org.quartz.jobStore.class - 指定為RAMJobStore,表示所有Quartz的數據,包括jobDetail、trigger等均運行在內存中(而不是數據庫中)。 如果你想Quartz使用你的數據庫,還是建議你在使用數據庫配置之前使用RAMJobStore進行工作。通過使用一個數據庫,你可以打開一個全新的維度,但在這之前,建議你使用RAMJobStore。

編寫第一個quartz示例程序

第一步:編寫一個job類,需要實現org.quartz.Job接口

這里編寫一個樣例,該任務只做一件事,就是打印任務執行時間以及匯報任務已經執行。Hello.Java代碼如下:

package org.byron4j.quartz; import org.byron4j.utils.DateUtil; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; /** * 實現org.quartz.Job接口,聲明該類是一個可執行任務類 * @author Administrator * */ public class HelloJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("現在是北京時間:" + DateUtil.getCurrDateTime() + " - helloJob任務執行"); } } 

 

第二步:編寫日期時間工具類,提供獲取不同格式時間的公共方法

DateUtil.java代碼如下:

package org.byron4j.utils; import java.text.SimpleDateFormat; import java.util.Date; public class DateUtil { private static SimpleDateFormat officerSdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); public static String getCurrDateTime(){ return officerSdf.format(new Date()); } } 

 

第三步:使用job、trigger、schedule調用定時任務

在該實例中我們使用了靜態引入,引入了3個靜態方法

import static org.quartz.JobBuilder.newJob; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger;

 

 

你也可以分別使用替代,視個人習慣選擇:

JobBuilder.newJob(...) SimpleScheduleBuilder.simpleSchedule(...) TriggerBuilder.newTrigger(...)

 

QuartzTest.java代碼如下:

package org.byron4j.quartz; import static org.quartz.JobBuilder.newJob; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.Trigger; import org.quartz.impl.StdSchedulerFactory; public class QuartzTest { public static void main(String[] args) { try { //從調度程序工廠獲取一個調度程序的實例 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //顯示調度程序的名稱(這里會展示我們在quartz.properties文件中的名稱) System.out.println("scheduleName = " + scheduler.getSchedulerName()); /** 重要: * 定義一個job,並綁定到我們自定義的HelloJob的class對象 * 這里並不會馬上創建一個HelloJob實例,實例創建是在scheduler安排任務觸發執行時創建的 * 這種機制也為后面使用Spring集成提供了便利 */ JobDetail job = newJob(HelloJob.class) .withIdentity("job1", "group1") .build(); // 聲明一個觸發器,現在就執行(schedule.start()方法開始調用的時候執行);並且每間隔2秒就執行一次 Trigger trigger = newTrigger() .withIdentity("trigger1", "group1") .startNow() .withSchedule(simpleSchedule() .withIntervalInSeconds(2) .repeatForever()) .build(); // 告訴quartz使用定義的觸發器trigger安排執行任務job scheduler.scheduleJob(job, trigger); //啟動任務調度程序,內部機制是線程的啟動 scheduler.start(); //關閉任務調度程序,如果不關閉,調度程序schedule會一直運行着 //scheduler.shutdown(); } catch (SchedulerException e) { e.printStackTrace(); } } } 

 

重點指明一下job實例創建的時機: 
/** 重要: 
* 定義一個job,並綁定到我們自定義的HelloJob的class對象 
* 這里並不會馬上創建一個HelloJob實例,實例創建是在scheduler安排任務觸發執行時創建的 
* 這種機制也為后面使用spring集成提供了便利 
*/ 
JobDetail job = newJob(HelloJob.class) 
.withIdentity(“job1”, “group1”) 
.build();

第四步:執行調用你的定時任務

運行QuartzTest.java的main方法,我們可以看到控制台輸出,每隔2秒就執行了我們預先安排的打印時間和工作內容的任務:

scheduleName = MyScheduler 現在是北京時間:2016-11-05 13:08:30 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:32 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:34 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:36 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:38 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:40 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:42 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:44 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:46 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:48 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:50 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:52 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:54 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:56 - helloJob任務執行 現在是北京時間:2016-11-05 13:08:58 - helloJob任務執行 現在是北京時間:2016-11-05 13:09:00 - helloJob任務執行

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM