淺談Scheduler
阿新 • • 發佈：2018-04-05
ace imp osc orm 核心概念 src out 返回值 div
1.Scheduler工廠模式
所有的Scheduler實例應該由SchedulerFactory來創建2.SchedulerFactory類圖
最常用的是StdSchedulerFactory工程類，其出那個鍵Scheduler的兩種方式:
//3. 創建scheduler Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 3. 創建scheduler SchedulerFactory sfact = newStdSchedulerFactory(); 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
淺談Scheduler