作业调度框架 Quartz 学习笔记(五) -- 错过的任务怎么办?

落日映苍穹つ 2022-05-29 01:19 190阅读 0赞

非常感谢[http://blog.csdn.net/lnara/article/details/8658258][http_blog.csdn.net_lnara_article_details_8658258]

不知道大家在用Quartz的时候 有没有遇到这样一种情况:

触发器设定每3秒钟触发一次 ,但是工作需要10秒钟的执行时间.因此，在一次任务结束执行前，触发器已经错失触发

当这种情况下我们怎么处理呢,让我们一起学习一下......

还是先贴代码:

job类:StatefulDumbJob.java

**\[java\]**  [view plain][]  [copy][view plain]

1.  import java.text.SimpleDateFormat;  
2.  import java.util.Calendar;  
3.  import org.quartz.DisallowConcurrentExecution;  
4.  import org.quartz.Job;  
5.  import org.quartz.JobDataMap;  
6.  import org.quartz.JobExecutionContext;  
7.  import org.quartz.JobExecutionException;  
8.  import org.quartz.PersistJobDataAfterExecution;  
9.    
10. @PersistJobDataAfterExecution  
11. @DisallowConcurrentExecution  
12. public class StatefulDumbJob implements Job \{  
13.   
14.     // 静态常量，作为任务在调用间，保持数据的键(key)  
15.     // NUM\_EXECUTIONS，保存的计数每次递增1  
16.     // EXECUTION\_DELAY，任务在执行时，中间睡眠的时间。本例中睡眠时间过长导致了错失触发  
17.     public static final String NUM\_EXECUTIONS = "NumExecutions";  
18.     public static final String EXECUTION\_DELAY = "ExecutionDelay";  
19.   
20.     @Override  
21.     public void execute(JobExecutionContext context)  
22.             throws JobExecutionException \{  
23.   
24.         // 任务执行的时间  
25.         SimpleDateFormat dateFormat = new SimpleDateFormat(  
26.                 "yyyy-MM-dd HH:mm:ss");  
27.         String jobRunTime = dateFormat.format(Calendar.getInstance().getTime());  
28.   
29.         System.err.println("---" + context.getJobDetail().getKey().getName() + " 在  : \["  
30.                 + jobRunTime + "\] 执行了!!");  
31.   
32.         // 任务执行计数 累加  
33.         JobDataMap map = context.getJobDetail().getJobDataMap();  
34.         int executeCount = 0;  
35.         if (map.containsKey(NUM\_EXECUTIONS)) \{  
36.             executeCount = map.getInt(NUM\_EXECUTIONS);  
37.         \}  
38.         executeCount++;  
39.         map.put(NUM\_EXECUTIONS, executeCount);  
40.   
41.         // 睡眠时间: 由调度类重新设置值 ,本例为 睡眠10s  
42.         long delay = 5000l;  
43.         if (map.containsKey(EXECUTION\_DELAY)) \{  
44.             delay = map.getLong(EXECUTION\_DELAY);  
45.         \}  
46.   
47.         try \{  
48.             Thread.sleep(delay);  
49.         \} catch (Exception ignore) \{  
50.         \}  
51.   
52.         // 睡眠醒来后，打印任务执行结束的信息  
53.         System.err.println("  -" + context.getJobDetail().getKey().getName()  
54.                 + " 完成次数  : " + executeCount );  
55.     \}  
56. \}

调度类: MisfireExample.java

**\[java\]**  [view plain][]  [copy][view plain]

1.  import static org.quartz.DateBuilder.nextGivenSecondDate;  
2.  import static org.quartz.JobBuilder.newJob;  
3.  import static org.quartz.SimpleScheduleBuilder.simpleSchedule;  
4.  import static org.quartz.TriggerBuilder.newTrigger;  
5.    
6.  import java.text.SimpleDateFormat;  
7.  import java.util.Date;  
8.    
9.  import org.quartz.JobDetail;  
10. import org.quartz.Scheduler;  
11. import org.quartz.SchedulerFactory;  
12. import org.quartz.SchedulerMetaData;  
13. import org.quartz.SimpleTrigger;  
14. import org.quartz.impl.StdSchedulerFactory;  
15.   
16. public class MisfireExample \{  
17.   
18.     public static void main(String\[\] args) throws Exception \{  
19.         MisfireExample example = new MisfireExample();  
20.         example.run();  
21.     \}  
22.   
23.     public void run() throws Exception \{  
24.         // 任务执行的时间 格式化  
25.         SimpleDateFormat dateFormat = new SimpleDateFormat(  
26.                 "yyyy-MM-dd HH:mm:ss");  
27.   
28.         SchedulerFactory sf = new StdSchedulerFactory();  
29.         Scheduler sched = sf.getScheduler();  
30.         System.out.println("--------------- 初始化 -------------------");  
31.   
32.         // 下一个第15秒  
33.         Date startTime = nextGivenSecondDate(null, 15);  
34.   
35.         // statefulJob1 每3s运行一次,但它会延迟10s  
36.         JobDetail job = newJob(StatefulDumbJob.class)  
37.                 .withIdentity("statefulJob1", "group1")  
38.                 .usingJobData(StatefulDumbJob.EXECUTION\_DELAY, 10000L) // 设置参数:睡眠时间 10s  
39.                 .build();  
40.         SimpleTrigger trigger = newTrigger()  
41.                 .withIdentity("trigger1", "group1")  
42.                 .startAt(startTime)  
43.                 .withSchedule(  
44.                         simpleSchedule().withIntervalInSeconds(3)  
45.                                 .repeatForever()).build();  
46.         Date ft = sched.scheduleJob(job, trigger);  
47.         System.out.println(job.getKey().getName() + " 将在: " + dateFormat.format(ft)  
48.                 + "  时运行.并且重复: " + trigger.getRepeatCount() + " 次, 每次间隔 "  
49.                 + trigger.getRepeatInterval() / 1000 + " 秒");  
50.   
51.         // statefulJob2 将每3s运行一次 , 但它将延迟10s , 然后不断的迭代  
52.         job = newJob(StatefulDumbJob.class)  
53.                 .withIdentity("statefulJob2", "group1")  
54.                 .usingJobData(StatefulDumbJob.EXECUTION\_DELAY, 10000L)// 设置参数:睡眠时间 10s  
55.                 .build();  
56.         trigger = newTrigger()  
57.                 .withIdentity("trigger2", "group1")  
58.                 .startAt(startTime)  
59.                 .withSchedule(  
60.                         simpleSchedule()  
61.                                 .withIntervalInSeconds(3)  
62.                                 .repeatForever()  
63.                                  // 设置错失触发后的调度策略   
64.                                 .withMisfireHandlingInstructionNowWithRemainingCount()  
65.                                 )   
66.                 .build();  
67.   
68.         ft = sched.scheduleJob(job, trigger);  
69.         System.out.println(job.getKey().getName() + " 将在: " + dateFormat.format(ft)  
70.                 + "  时运行.并且重复: " + trigger.getRepeatCount() + " 次, 每次间隔 "  
71.                 + trigger.getRepeatInterval() / 1000 + " 秒");  
72.   
73.         System.out.println("------- 开始调度 (调用.start()方法) ----------------");  
74.         sched.start();  
75.   
76.         // 给任务留时间运行  
77.         Thread.sleep(600L \* 1000L);  
78.   
79.         sched.shutdown(true);  
80.         System.out.println("------- 调度已关闭 ---------------------");  
81.   
82.         // 显示一下 已经执行的任务信息  
83.         SchedulerMetaData metaData = sched.getMetaData();  
84.         System.out.println("~~~~~~~~~~  执行了 "  
85.                 + metaData.getNumberOfJobsExecuted() + " 个 jobs.");  
86.     \}  
87. \}

\-------------------------------------我是分割线----------------------------------------------------------

先说明 一个词 : misfire -- 指的是 错过了触发时间

你会注意到2个触发器具有相同的时间安排，相同的任务

触发器设定每3秒钟触发一次，但是工作需要10秒钟的执行时间

因此，在一次任务结束执行前，触发器已经错失触发(除非’错失触发时限’被设置为超过7秒)。

其中第二个任务设置自己的错失触发指示:.withMisfireHandlingInstructionNowWithRemainingCount()

所以当检测到丢失触发时，不会立即触发，而是忽略本次安排到下一个预定时间去触发

我们的结论 :

a)       本范例中，触发的间隔被设置为3秒，但是由于任务体执行间睡眠10秒，导致了错失触发的产生。

b)       实际运行的效果，2个任务执行的间隔为10秒。

c)        由于丢失触发时，job2的策略是立即触发，而job1是等待下一次机会触发。所以job2会赶在job1的前头，最终运行次数大于job1。

Quartz 的 Misfire处理规则:

调度(scheduleJob)或恢复调度(resumeTrigger,resumeJob)后不同的misfire对应的处理规则

CronTrigger   
  
withMisfireHandlingInstructionDoNothing  
——不触发立即执行  
——等待下次Cron触发频率到达时刻开始按照Cron频率依次执行  
  
withMisfireHandlingInstructionIgnoreMisfires  
——以错过的第一个频率时间立刻开始执行  
——重做错过的所有频率周期后  
——当下一次触发频率发生时间大于当前时间后，再按照正常的Cron频率依次执行  
  
withMisfireHandlingInstructionFireAndProceed  
——以当前时间为触发频率立刻触发一次执行  
——然后按照Cron频率依次执行  
  
  
 SimpleTrigger   
  
withMisfireHandlingInstructionFireNow  
——以当前时间为触发频率立即触发执行  
——执行至FinalTIme的剩余周期次数  
——以调度或恢复调度的时刻为基准的周期频率，FinalTime根据剩余次数和当前时间计算得到  
——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值  
  
withMisfireHandlingInstructionIgnoreMisfires  
——以错过的第一个频率时间立刻开始执行  
——重做错过的所有频率周期  
——当下一次触发频率发生时间大于当前时间以后，按照Interval的依次执行剩下的频率  
——共执行RepeatCount+1次  
  
withMisfireHandlingInstructionNextWithExistingCount  
——不触发立即执行  
——等待下次触发频率周期时刻，执行至FinalTime的剩余周期次数  
——以startTime为基准计算周期频率，并得到FinalTime  
——即使中间出现pause，resume以后保持FinalTime时间不变  
  
  
withMisfireHandlingInstructionNowWithExistingCount  
——以当前时间为触发频率立即触发执行  
——执行至FinalTIme的剩余周期次数  
——以调度或恢复调度的时刻为基准的周期频率，FinalTime根据剩余次数和当前时间计算得到  
——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值  
  
withMisfireHandlingInstructionNextWithRemainingCount  
——不触发立即执行  
——等待下次触发频率周期时刻，执行至FinalTime的剩余周期次数  
——以startTime为基准计算周期频率，并得到FinalTime  
——即使中间出现pause，resume以后保持FinalTime时间不变  
  
withMisfireHandlingInstructionNowWithRemainingCount  
——以当前时间为触发频率立即触发执行  
——执行至FinalTIme的剩余周期次数  
——以调度或恢复调度的时刻为基准的周期频率，FinalTime根据剩余次数和当前时间计算得到

——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值

MISFIRE\_INSTRUCTION\_RESCHEDULE\_NOW\_WITH\_REMAINING\_REPEAT\_COUNT  
——此指令导致trigger忘记原始设置的starttime和repeat-count  
——触发器的repeat-count将被设置为剩余的次数  
——这样会导致后面无法获得原始设定的starttime和repeat-count值

另外,如果任务数超过了Quartz的线程池中的线程数时,也会发生类似的情况 兄弟们可以参考一下下面的这篇博文:

[http://www.cnblogs.com/makemelaugh/archive/2012/06/17/2533105.html][http_www.cnblogs.com_makemelaugh_archive_2012_06_17_2533105.html]

[http_blog.csdn.net_lnara_article_details_8658258]: http://blog.csdn.net/lnara/article/details/8658258
[view plain]: http://blog.csdn.net/lnara/article/details/8658258#
[http_www.cnblogs.com_makemelaugh_archive_2012_06_17_2533105.html]: http://www.cnblogs.com/makemelaugh/archive/2012/06/17/2533105.html