Quartz學習總結（2）——定時任務框架Quartz詳解

阿新 • • 發佈：2019-01-11

實現每隔1秒列印一個Hello World
1.建立Maven專案，新增依賴：
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>
2.建立HelloWorldJob類
package quartz;
import org.quartz.Job;
import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;

public class HelloWorldJob implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
String strTime = new SimpleDateFormat("HH-mm-ss").format(new Date());

System.out.println( strTime + ":Hello World！");
}
}
3.建立MyScheduler類

package quartz;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MyScheduler {
public static void main(String[] args) throws SchedulerException {
//建立排程器Schedule
SchedulerFactory schedulerFactory = new StdSchedulerFactory();

Scheduler scheduler = schedulerFactory.getScheduler();
//建立JobDetail例項，並與HelloWordlJob類繫結
JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
.build();
//建立觸發器Trigger例項(立即執行，每隔1S執行一次)
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "triggerGroup1")
.startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
.build();
//開始執行
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}
Quartz中幾個重要的物件
1.Job和JobDetail
Job是Quartz中的一個介面，介面下只有execute方法，在這個方法中編寫業務邏輯。
該介面的原始碼：
package org.quartz;
public interface Job {
void execute(JobExecutionContext var1) throws JobExecutionException;
}
每次排程執行Job時，呼叫execute方法前會建立一個新的Job例項，執行完後，關聯的Job物件例項會被釋放，隨後jvm執行GC。

JobDetail是用來繫結Job，為Job例項提供了許多屬性，以及JobDataMap成員變數屬性。排程器scheduler通過JobDetail物件來新增Job例項。

屬性：
name
group
jobClass
jobDataMap
2.JobExecutionContext
當排程器Scheduler呼叫一個Job時，就會將JobExecutionContext傳遞給Job的execute()方法，Job能通過JobExecutionContext物件訪問到Quartz執行時的環境以及Job本身的詳細資料資訊。
程式碼演示：
public class HelloWorldJob implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
String strTime = new SimpleDateFormat("HH-mm-ss").format(new Date());
System.out.println( strTime + ":Hello World！");
System.out.println("JobDetail'name:" + jobExecutionContext.getJobDetail().getKey().getName());
System.out.println("JobDetail'group:" + jobExecutionContext.getJobDetail().getKey().getGroup());
System.out.println("JobDetail'class:" + jobExecutionContext.getJobDetail().getClass());
}
}
3.JobDataMap
任務排程時可以通過JobExecutionContext獲取JobDataMap，可以裝在任何可序列化的資料物件，JobDataMap實現了JDK的Map介面，可以以Key-Value的形式儲存資料。
實戰：JobDetail和Trigger傳遞資料，HelloWorldJob類execute三種方式獲取資料。
//建立JobDetail例項，並與HelloWordlJob類繫結
JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
.usingJobData("key1","this is jobDetail")
.build();
//建立觸發器Trigger例項(立即執行，每隔1S執行一次)
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "triggerGroup1")
.usingJobData("key2", "this is trigger")
.startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
.build();
HelloWorldJob獲取資料：
public class HelloWorldJob implements Job {
private String key1;
private String key2;
public String getKey1() {
return key1;
}
public void setKey1(String key1) {
this.key1 = key1;
}
public String getKey2() {
return key2;
}
public void setKey2(String key2) {
this.key2 = key2;
}
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
String strTime = new SimpleDateFormat("HH-mm-ss").format(new Date());
System.out.println( strTime + ":Hello World！");
//獲取DataMap資料方法一
System.out.println("JobDetail JobDataMap:" + jobExecutionContext.getJobDetail().getJobDataMap().get("key1"));
System.out.println("Trigger JobDataMap:" + jobExecutionContext.getTrigger().getJobDataMap().get("key2"));
//獲取DataMap資料方法二
System.out.println("JobDataMap:" + jobExecutionContext.getMergedJobDataMap().get("key1"));
System.out.println("JobDataMap:" + jobExecutionContext.getMergedJobDataMap().get("key2"));
//獲取資料方法三
System.out.println("通過成員變數獲取" + key1);
System.out.println("通過成員變數獲取" + key2);
}
}
4.Trigger
Trigger是Quartz中的觸發器，任務執行時會通知排程器Scheduler何時觸發，幾個重要的屬性。
Jobkey：表示job例項的標識
StartTime：表示觸發器首次被觸發的時間(Java.util.Date)。
EndTime：表示觸發器結束觸發的時間(Java.util.Date)
實戰：實現5S後執行，10S後結束，期間每隔1S執行一次定時任務
程式碼演示：
MyScheduler類
public class MyScheduler {
public static void main(String[] args) throws SchedulerException {
//建立排程器Schedule
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//建立JobDetail例項，並與HelloWordlJob類繫結
JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
.build();
//建立觸發器Trigger例項(5S後執行，10S後結束)
//開始時間(5S後)
Date date1 = new Date();
date1.setTime(date1.getTime() + 5000);
//結束時間(10S後)
Date date2 = new Date();
date2.setTime(date2.getTime() + 10000);
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "triggerGroup1")
.startAt(date1)
.endAt(date2)
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
.build();
//開始執行
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}
5.SimpleTrigger
SimpleTrigger可以實現在一個指定時間段內執行一次作業任務或一個時間段內多次執行作業任務。
實戰：5S後開始執行，間隔時間為1S，第一次執行後連續執行3次
package quartz2;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.Date;
public class MyScheduler2 {
public static void main(String[] args) throws SchedulerException {
//建立排程器Schedule
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//建立JobDetail例項，並與HelloWordlJob類繫結
JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
.build();
//建立觸發器Trigger例項(5S後執行,一直執行)
//開始時間(5S後)
Date date1 = new Date();
date1.setTime(date1.getTime() + 5000);
SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
.withIdentity("trigger1", "triggerGroup1")
.startAt(date1)
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
.withRepeatCount(3))
.build();
//開始執行
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}
6.CronTrigger
CronTrigger功能非常強大，是基於日曆的作業排程，而SimpleTrigger是精準指定間隔，所以相比SimpleTrigger，CroTrigger更加常用。CroTrigger是基於Cron表示式的，先了解下Cron表示式：
由7個子表示式組成字串的，格式如下：
[秒] [分] [小時] [日] [月] [周] [年]
Cron表示式的語法就不多說了，因為我也記不住只能度娘，給大家提供個線上生成Cron表示式的工具：http://cron.qqe2.com/ ，方便實用。
實戰：實現每週一到週五上午10:30執行定時任務
package quartz2;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.Date;
public class MyScheduler3 {
public static void main(String[] args) throws SchedulerException {
//建立排程器Schedule
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//建立JobDetail例項，並與HelloWordlJob類繫結
JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
.build();
//建立觸發器CronTrigger例項(每週一到週五10:30執行任務)
CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
.withIdentity("trigger1", "triggerGroup1")
.startNow()
.withSchedule(CronScheduleBuilder.cronSchedule("* 30 10 ? * 1/5 *"))
.build();
//開始執行
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}

Quartz學習總結（2）——定時任務框架Quartz詳解

Quartz學習總結（2）——定時任務框架Quartz詳解

Celery 學習筆記（2）- 定時任務

RabbitMQ學習總結（5）——釋出和訂閱例項詳解

Spring MVC 學習總結（二）——控制器定義與@RequestMapping詳解

Spring學習總結（2）- AOP

【數據結構】ArrayList原理及實現學習總結（2）

OpenCV學習總結（2）- 視覺系統的構成要素

Spring-batch學習總結（2）—Job,Flow創建及應用，多線程並發，決策器，監聽器，參數

事務學習總結（2）——spring事務

《實戰Java高併發程式設計》學習總結（2）

設計模式學習總結（2）單例模式、建造者模式、原型模式

Python--列表（list）、元組(tuple)、字典（dict）學習總結（2）

springboot學習筆記（三）---定時任務

MySQL學習總結（2）-MySQL客戶端相關語句

Maven學習總結（2）-Maven的安裝與配置、eclipse整合Maven

DQN從入門到放棄學習總結（2）

敏捷開發系列學習總結（2）——Bug修改流程

Oracle學習總結（2）——Oracle資料庫設計總結（三大正規化）

Tomcat學習總結（2）——Tomcat部署Java War包應用教程

Spring Boot學習總結（2）——Spring Boot整合Jsp

Quartz學習總結（2）——定時任務框架Quartz詳解

相關推薦