quartz 淺談 Scheduler
阿新 • • 發佈：2018-08-02
觸發器 pack 表示 類圖 工廠 結果 com span .get 
1.Scheduler工廠模式
所有的Scheduler實例應該由SchedulerFactory來創建2.SchedulerFactory類圖
最常用的是StdSchedulerFactory工程類，其出那個鍵Scheduler的兩種方式:
//3. 創建scheduler
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 3. 創建scheduler
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
3. 回顧Quartz三個核心概念
調度器
任務
觸發器
1個job對應多個Trigger
4.Scheduler的創建方式
StdSchedulerFactory:
使用一組參數（Java.util.Properties）來創建和初始化Quartz調度器
配置參數一般存儲在quartz.properties中
調用getScheduler方法就能創建和初始化調度器對象
5..Scheduler的主要函數
// 綁定 jobDetail 和 trigger，將它註冊進 Scheduler 當中 ,返回值是最近一次任務執行的開始時間 Date scheduleJob(JobDetail jobDetail, Trigger trigger) // 啟動 Scheduler void start() // 暫停 Scheduler void standby() // 關閉 Scheduler void shutdown()
例一:測試:scheduleJob函數返回最近一次開始執行的時間
package cn.qlq.quartz;
import static org.quartz.JobBuilder.newJob;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class HelloScheduler {
public static void main(String[] args) {
try {
// 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
.withIdentity("myJob") // 定義name/group
.build();
// 打印當前的時間
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
Date date = new Date();
System.out.println("current time is :" + sf.format(date));
// 2. 2018年內每天11點18開始執行，每隔5s執行一次
CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")// 定義名字和組
.withSchedule( //定義任務調度的時間間隔和次數
CronScheduleBuilder
.cronSchedule("0/5 0 14,18 * * ? *")
)
.build();
// 3. 創建scheduler
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
// 4. 將trigger和jobdetail加入這個調度
// scheduler.scheduleJob(jobDetail, trigger);
// 5. 啟動scheduler
scheduler.start();
System.out.println("schedule time is:"+sf.format(scheduler.scheduleJob(jobDetail, trigger)));
} catch (Exception e) {
e.printStackTrace();
}
}
}
結果:
current time is :2018-04-05 11:42:42
schedule time is:2018-04-05 02:00:00
例二:測試standby()掛起Scheduler之後3s後再次開啟Scheduler
package cn.qlq.quartz;
import static org.quartz.JobBuilder.newJob;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class HelloScheduler {
public static void main(String[] args) {
try {
// 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
.withIdentity("myJob") // 定義name/group
.build();
// 打印當前的時間
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
Date date = new Date();
System.out.println("current time is :" + sf.format(date));
// 2. 2018年內每天11點18開始執行，每隔5s執行一次
CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")// 定義名字和組
.withSchedule( //定義任務調度的時間間隔和次數
CronScheduleBuilder
.cronSchedule("* * * * * ? *")
)
.build();
// 3. 創建scheduler
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
// 4. 將trigger和jobdetail加入這個調度
scheduler.scheduleJob(jobDetail, trigger);
// 5. 啟動scheduler
scheduler.start();
//scheduler執行2s後掛起
Thread.sleep(2000);
scheduler.standby();
//scheduler掛起3s後再次啟動scheduler
Thread.sleep(3000);
scheduler.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}
結果：
current time is :2018-04-05 11:49:28 current exec time is :2018-04-05 11:49:28 current exec time is :2018-04-05 11:49:29 current exec time is :2018-04-05 11:49:30 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:34 current exec time is :2018-04-05 11:49:35 ....
例三:測試shutdown函數(shutdown之後不能再次調用start重啟，會報錯)
shutdown(true)表示等待所有正在執行的任務執行完畢後關閉Scheduler
shutdown(false),即shutdown()表示直接關閉Scheduler
(1)Job中睡眠5s鐘
package cn.qlq.quartz;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class HelloJob implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//打印當前的時間
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
Date date = new Date();
System.out.println("current exec time is :"+sf.format(date));
}
}
shutdown傳入true參數:(在程序執行完之後才殺死Scheduler)
package cn.qlq.quartz;
import static org.quartz.JobBuilder.newJob;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class HelloScheduler {
public static void main(String[] args) {
try {
// 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
.withIdentity("myJob") // 定義name/group
.build();
// 打印當前的時間
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
Date date = new Date();
System.out.println("current time is :" + sf.format(date));
// 2. 2018年內每天11點18開始執行，每隔5s執行一次
CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")// 定義名字和組
.withSchedule( //定義任務調度的時間間隔和次數
CronScheduleBuilder
.cronSchedule("* * * * * ? *")
)
.build();
// 3. 創建scheduler
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
// 4. 將trigger和jobdetail加入這個調度
scheduler.scheduleJob(jobDetail, trigger);
// 5. 啟動scheduler
scheduler.start();
//scheduler執行2s後掛起
Thread.sleep(2000);
scheduler.shutdown(true);
//shutdown(true)表示等待所有正在執行的任務執行完畢後關閉Scheduler
//shutdown(false),即shutdown()表示直接關閉Scheduler
System.out.println("scheduler is shutdown?"+scheduler.isShutdown());
} catch (Exception e) {
e.printStackTrace();
}
}
}
結果:
current time is :2018-04-05 11:58:25 current exec time is :2018-04-05 11:58:30 current exec time is :2018-04-05 11:58:31 current exec time is :2018-04-05 11:58:32 scheduler is shutdown?true
shutdown傳入false參數:(立即殺死Scheduler)
package cn.qlq.quartz;
import static org.quartz.JobBuilder.newJob;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class HelloScheduler {
public static void main(String[] args) {
try {
// 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
.withIdentity("myJob") // 定義name/group
.build();
// 打印當前的時間
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
Date date = new Date();
System.out.println("current time is :" + sf.format(date));
// 2. 2018年內每天11點18開始執行，每隔5s執行一次
CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")// 定義名字和組
.withSchedule( //定義任務調度的時間間隔和次數
CronScheduleBuilder
.cronSchedule("* * * * * ? *")
)
.build();
// 3. 創建scheduler
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
// 4. 將trigger和jobdetail加入這個調度
scheduler.scheduleJob(jobDetail, trigger);
// 5. 啟動scheduler
scheduler.start();
//scheduler執行2s後掛起
Thread.sleep(2000);
scheduler.shutdown(false);
//shutdown(true)表示等待所有正在執行的任務執行完畢後關閉Scheduler
//shutdown(false),即shutdown()表示直接關閉Scheduler
System.out.println("scheduler is shutdown?"+scheduler.isShutdown());
} catch (Exception e) {
e.printStackTrace();
}
}
}
結果:
current time is :2018-04-05 12:00:11 scheduler is shutdown?true current exec time is :2018-04-05 12:00:17 current exec time is :2018-04-05 12:00:17 current exec time is :2018-04-05 12:00:18 current exec time is :2018-04-05 12:00:19
quartz 淺談 Scheduler