這一篇文章,我們緊接著上一篇的文章,講講在Quartz在java project的項目中如何進行使用,在這里我們使用maven進行構建項目。先看下本章的大綱:
(1)新建工程quartz-java;
(2)配置pom.xml文件;
(3)編碼說明;
(4)編寫Job類;
(5)編寫啟動類進行代碼測試;
(6)quartz.properties配置文件說明;
接下里一起看下具體的內容:
(1)新建工程quartz-java;
新建一個java project取名為quartz-java。
(2)配置pom.xml文件;
在pom.xml文件中添加quartz的依賴:
<groupId>org.quartz-scheduler<span class="hljs-name"groupId>
<artifactId>quartz<span class="hljs-name"artifactId>
<version>2.2.3<span class="hljs-name"version>
(3)編碼說明;
(一)首先我們需要定義一個任務類,比如為HelloJob ,該類需要繼承Job類,然后添加execute(JobExecutionContext context)方法,在這個方法中就是我們具體的任務執行的地方。
(二)在哪里定義“在什么時候執行什么任務呢?”:那么我們需要Scheduler,此類的創建方式使用Quartz提供的工廠類StdSchedulerFactory.getDefaultScheduler()進行創建。
(三)如何觸發呢:scheduler.scheduleJob(jobDetail,trigger);進行觸發定時任務,在這里需要兩個參數。jobDetail可以通過JobBuilder.newJob進行創建,在這里就需要制定一個Job類了,也就是我們第一步創建的HelloJob;trigger類的話,可以通過TriggerBuilder.newTrigger進行創建。
(4)編寫Job類;
編寫HelloJob任務類:
package com.kfit.job;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
- 任務類.
- @author Angel --守護天使
- @version v.0.1
- @date 2017年4月21日
*/
**public **class HelloJob implements Job{
**public ****void** execute(JobExecutionContext context) **throws**JobExecutionException {
// 執行響應的任務.
System. ***out*** .println("HelloJob.execute,"+**new** Date());
}
}
(5)編寫啟動類進行代碼測試;
在Main方法中進行編碼測試:
package com.kfit;
import java.util.concurrent.TimeUnit;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import com.kfit.job.HelloJob;
/**
- 直接在Main方法中進行啟動測試.
- @author Angel --守護天使
- @version v.0.1
- @date 2017年4月21日
*/
**public **class App {
**public ****static ****void** main(String[] args) **throws** SchedulerException, InterruptedException {
/*
*在 Quartz 中, scheduler 由 scheduler 工廠創建:DirectSchedulerFactory或者StdSchedulerFactory。第二種工廠StdSchedulerFactory 使用較多,
*因為DirectSchedulerFactory 使用起來不夠方便,需要作許多詳細的手工編碼設置。
*/
// 獲取Scheduler實例
Scheduler scheduler = StdSchedulerFactory. *getDefaultScheduler* ();
scheduler.start();
System. ***out*** .println("scheduler.start");
//具體任務.
JobDetail jobDetail = JobBuilder. *newJob* (HelloJob. **class** ).withIdentity("job1","group1").build();
//觸發時間點. (每5秒執行1次.)
SimpleScheduleBuilder simpleScheduleBuilder =SimpleScheduleBuilder. *simpleSchedule* ().withIntervalInSeconds(5).repeatForever();
Trigger trigger = TriggerBuilder. *newTrigger* ().withIdentity("trigger1","group1").startNow().withSchedule(simpleScheduleBuilder).build();
// 交由Scheduler安排觸發
scheduler.scheduleJob(jobDetail,trigger);
//睡眠20秒.
TimeUnit. ***SECONDS*** .sleep(20);
scheduler.shutdown();//關閉定時任務調度器.
System. ***out*** .println("scheduler.shutdown");
}
}
執行代碼查看控制臺的打印信息:
scheduler.start
HelloJob.execute,Fri Apr 2119:50:01 CST 2017
HelloJob.execute,Fri Apr 2119:50:06 CST 2017
HelloJob.execute,Fri Apr 2119:50:11 CST 2017
HelloJob.execute,Fri Apr 2119:50:16 CST 2017
HelloJob.execute,Fri Apr 2119:50:21 CST 2017
scheduler.shutdown
(6)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.threadPool.threadCount:配置線程池的容量,即表示同時最多可運行的線程數量。
org.quartz.scheduler.instanceName:scheduler實例名稱。
org.quartz.jobStore.class:job存儲方式,RAMJobStore是使用JobStore最簡單的一種方式,它也是性能最高效的,顧名思義,JobStore是把它的數據都存儲在RAM中,這也是它的快速和簡單配置的原因;JDBCJobStore也是一種相當有名的JobStore,它通過JDBC把數據都保存到數據庫中,所以在配置上會比RAMJobStore復雜一些,而且不像RAMJobStore那么快,但是當我們對數據庫中的表的主鍵創建索引時,性能上的缺點就不是很關鍵的了。
您可以在代碼中打印scheduler實例名稱,如下代碼:
Scheduler scheduler =StdSchedulerFactory. getDefaultScheduler ();
scheduler.start();
System. ***out*** .println("scheduler.start");
System. ***out*** .println(scheduler.getSchedulerName());
-
JAVA
+關注
關注
19文章
2966瀏覽量
104702 -
Quartz
+關注
關注
0文章
7瀏覽量
7934
發布評論請先 登錄
相關推薦
評論