當前位置：
首頁 > 知識 > 開源定時任務框架Quartz

開源定時任務框架Quartz

知識 07-08

Job和JobDetail

Job是Quartz中的一個介面，介面下只有execute方法，在這個方法中編寫業務邏輯。

該介面的源碼：

  2. package org.quartz;
  4. public interface Job {
  5. void execute(JobExecutionContext var1) throws JobExecutionException;
  6. }

每次調度執行Job時，調用execute方法前會創建一個新的Job實例，執行完後，關聯的Job對象實例會被釋放，隨後jvm執行GC。

JobDetail是用來綁定Job，為Job實例提供了許多屬性，以及JobDataMap成員變數屬性。調度器scheduler通過JobDetail對象來添加Job實例。

屬性：

1. name

2. group

3. jobClass

4. jobDataMap

JobExecutionContext

當調度器Scheduler調用一個Job時，就會將JobExecutionContext傳遞給Job的execute()方法，Job能通過JobExecutionContext對象訪問到Quartz運行時的環境以及Job本身的詳細數據信息。

代碼演示：

  2. public class HelloWorldJob implements Job {
  3. @Override
  4. public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  5. String strTime = new SimpleDateFormat("HH-mm-ss").format(new Date());
  6. System.out.println( strTime + ":Hello World！");
  7. System.out.println("JobDetail"name:" + jobExecutionContext.getJobDetail().getKey().getName());
  8. System.out.println("JobDetail"group:" + jobExecutionContext.getJobDetail().getKey().getGroup());
  9. System.out.println("JobDetail"class:" + jobExecutionContext.getJobDetail().getClass());
  10. }
  11. }

JobDataMap

任務調度時可以通過JobExecutionContext獲取JobDataMap，可以裝在任何可序列化的數據對象，JobDataMap實現了JDK的Map介面，可以以Key-Value的形式存儲數據。

實戰：JobDetail和Trigger傳遞數據，HelloWorldJob類execute三種方式獲取數據。

  2. //創建JobDetail實例，並與HelloWordlJob類綁定
  3. JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
  4. .usingJobData("key1","this is jobDetail")
  5. .build();
  7. //創建觸發器Trigger實例(立即執行，每隔1S執行一次)
  8. Trigger trigger = TriggerBuilder.newTrigger()
  9. .withIdentity("trigger1", "triggerGroup1")
  10. .usingJobData("key2", "this is trigger")
  11. .startNow()
  12. .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
  13. .build();

HelloWorldJob獲取數據：

  2. public class HelloWorldJob implements Job {
  3. private String key1;
  4. private String key2;
  6. public String getKey1() {
  7. return key1;
  8. }
  10. public void setKey1(String key1) {
  11. this.key1 = key1;
  12. }
  14. public String getKey2() {
  15. return key2;
  16. }
  18. public void setKey2(String key2) {
  19. this.key2 = key2;
  20. }
  22. @Override
  23. public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  24. String strTime = new SimpleDateFormat("HH-mm-ss").format(new Date());
  25. System.out.println( strTime + ":Hello World！");
  27. //獲取DataMap數據方法一
  28. System.out.println("JobDetail JobDataMap:" + jobExecutionContext.getJobDetail().getJobDataMap().get("key1"));
  29. System.out.println("Trigger JobDataMap:" + jobExecutionContext.getTrigger().getJobDataMap().get("key2"));
  31. //獲取DataMap數據方法二
  32. System.out.println("JobDataMap:" + jobExecutionContext.getMergedJobDataMap().get("key1"));
  33. System.out.println("JobDataMap:" + jobExecutionContext.getMergedJobDataMap().get("key2"));
  35. //獲取數據方法三
  36. System.out.println("通過成員變數獲取" + key1);
  37. System.out.println("通過成員變數獲取" + key2);
  38. }
  39. }

Trigger

Trigger是Quartz中的觸發器，任務執行時會通知調度器Scheduler何時出發，幾個重要的屬性。

1. Jobkey：表示job實例的標識

2. StartTime：表示觸發器首次被觸發的時間(Java.util.Date)。

3. EndTime：表示觸發器結束觸發的時間(Java.util.Date)

實戰：實現5S後執行，10S後結束，期間每隔1S執行一次定時任務

代碼演示：

MyScheduler類

  2. public class MyScheduler {
  4. public static void main(String[] args) throws SchedulerException {
  5. //創建調度器Schedule
  6. SchedulerFactory schedulerFactory = new StdSchedulerFactory();
  7. Scheduler scheduler = schedulerFactory.getScheduler();
  9. //創建JobDetail實例，並與HelloWordlJob類綁定
  10. JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
  11. .build();
  13. //創建觸發器Trigger實例(5S後執行，10S後結束)
  14. //開始時間(5S後)
  15. Date date1 = new Date();
  16. date1.setTime(date1.getTime() + 5000);
  18. //結束時間(10S後)
  19. Date date2 = new Date();
  20. date2.setTime(date2.getTime() + 10000);
  22. Trigger trigger = TriggerBuilder.newTrigger()
  23. .withIdentity("trigger1", "triggerGroup1")
  24. .startAt(date1)
  25. .endAt(date2)
  26. .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
  27. .build();
  29. //開始執行
  30. scheduler.scheduleJob(jobDetail, trigger);
  31. scheduler.start();
  32. }
  33. }

SimpleTrigger

SimpleTrigger可以實現在一個指定時間段內執行一次作業任務或一個時間段內多次執行作業任務。

實戰：5S後開始執行，間隔時間為1S，第一次執行後連續執行3次

  2. package quartz2;
  4. import org.quartz.*;
  5. import org.quartz.impl.StdSchedulerFactory;
  7. import java.util.Date;
  9. /**
  10. * created by Java-Road
  11. * created in 2018/5/27
  12. */
  13. public class MyScheduler2 {
  15. public static void main(String[] args) throws SchedulerException {
  16. //創建調度器Schedule
  17. SchedulerFactory schedulerFactory = new StdSchedulerFactory();
  18. Scheduler scheduler = schedulerFactory.getScheduler();
  20. //創建JobDetail實例，並與HelloWordlJob類綁定
  21. JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
  22. .build();
  24. //創建觸發器Trigger實例(5S後執行,一直執行)
  25. //開始時間(5S後)
  26. Date date1 = new Date();
  27. date1.setTime(date1.getTime() + 5000);
  29. SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
  30. .withIdentity("trigger1", "triggerGroup1")
  31. .startAt(date1)
  32. .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
  33. .withRepeatCount(3))
  34. .build();
  36. //開始執行
  37. scheduler.scheduleJob(jobDetail, trigger);
  38. scheduler.start();
  39. }
  40. }

CronTrigger

CronTrigger功能非常強大，是基於日曆的作業調度，而SimpleTrigger是精準指定間隔，所以相比SimpleTrigger，CroTrigger更加常用。CroTrigger是基於Cron表達式的，先了解下Cron表達式：

由7個子表達式組成字元串的，格式如下：

[秒] [分] [小時] [日] [月] [周] [年]

Cron表達式的語法就不多說了，因為我也記不住只能度娘，給大家提供個在線生成Cron表達式的工具：http://cron.qqe2.com/

實戰：實現每周一到周五上午10:30執行定時任務

  2. package quartz2;
  4. import org.quartz.*;
  5. import org.quartz.impl.StdSchedulerFactory;
  7. import java.util.Date;
  9. /**
  10. * created by Java-Road
  11. * created in 2018/5/27
  12. */
  13. public class MyScheduler3 {
  15. public static void main(String[] args) throws SchedulerException {
  16. //創建調度器Schedule
  17. SchedulerFactory schedulerFactory = new StdSchedulerFactory();
  18. Scheduler scheduler = schedulerFactory.getScheduler();
  20. //創建JobDetail實例，並與HelloWordlJob類綁定
  21. JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class).withIdentity("job1", "jobGroup1")
  22. .build();
  24. //創建觸發器CronTrigger實例(每周一到周五10:30執行任務)
  25. CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
  26. .withIdentity("trigger1", "triggerGroup1")
  27. .startNow()
  28. .withSchedule(CronScheduleBuilder.cronSchedule("* 30 10 ? * MON-FRI *"))
  29. .build();
  31. //開始執行
  32. scheduler.scheduleJob(jobDetail, trigger);
  33. scheduler.start();
  34. }
  35. }

開源定時任務框架Quartz

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！

本站內容充實豐富，博大精深，小編精選每日熱門資訊，隨時更新，點擊「搶先收到最新資訊」瀏覽吧！


請您繼續閱讀更多來自 程序員小新人學習 的精彩文章:

※使用Spark進行流式實時日誌分析系統的實現
※Webpack 入門

TAG:程序員小新人學習 |