Quartz入门实例5-处理因执行job超时而错过触发的job-白红宇

Quartz入门实例5-处理因执行job超时而错过触发的job

阅读量：2215 次

发布时间：2019-05-07

本文共 9571 字，大约阅读时间需要 31 分钟。

例子将执行以下操作：

实例化2个Job ，每个job 5秒执行一次，一直循环直到Scheduler结束，但是job需要10秒执行完毕

StatefulDumbJob.java

package cn.zto.job;import java.text.SimpleDateFormat;import java.util.Date;import org.quartz.DisallowConcurrentExecution;import org.quartz.Job;import org.quartz.JobDataMap;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.PersistJobDataAfterExecution;@PersistJobDataAfterExecution//@DisallowConcurrentExecutionpublic class StatefulDumbJob  implements Job{  public static final String NUM_EXECUTIONS = "NumExecutions";  public static final String EXECUTION_DELAY = "ExecutionDelay";  public void execute(JobExecutionContext context)    throws JobExecutionException  {	SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");    System.err.println("---"+ dateFormat.format(new Date()) + " ：执行 " +context.getJobDetail().getKey());    JobDataMap map = context.getJobDetail().getJobDataMap();    int executeCount = 0;    if (map.containsKey("NumExecutions")) {      executeCount = map.getInt("NumExecutions");    }    ++executeCount;    map.put("NumExecutions", executeCount);    long delay = 5000L;    if (map.containsKey("ExecutionDelay")) {      delay = map.getLong("ExecutionDelay");    }    try{      Thread.sleep(delay);    }    catch (Exception ignore){    }    System.err.println("---" + dateFormat.format(new Date()) +" ："+ context.getJobDetail().getKey() + " 完成次数 (" + executeCount + ").");  }}

MisfireExample.java

package cn.zto.app;import java.text.SimpleDateFormat;import java.util.Date;import org.quartz.DateBuilder;import org.quartz.JobBuilder;import org.quartz.JobDetail;import org.quartz.Scheduler;import org.quartz.SchedulerFactory;import org.quartz.SchedulerMetaData;import org.quartz.SimpleScheduleBuilder;import org.quartz.SimpleTrigger;import org.quartz.TriggerBuilder;import org.quartz.impl.StdSchedulerFactory;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import cn.zto.job.StatefulDumbJob;public class MisfireExample{  public void run() throws Exception{	System.out.println("------- 初始化 -------------------");    SchedulerFactory sf = new StdSchedulerFactory();    Scheduler sched = sf.getScheduler();    System.out.println("------- 初始化完成 --------");    System.out.println("------- 向Scheduler加入Job ----------------");    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");    Date startTime = DateBuilder.nextGivenSecondDate(null, 15);    JobDetail job = JobBuilder.newJob(StatefulDumbJob.class)    		.withIdentity("statefulJob1", "group1")    		.usingJobData("ExecutionDelay", Long.valueOf(10000L))    		.build();    SimpleTrigger trigger = (SimpleTrigger)TriggerBuilder.newTrigger()    		.withIdentity("trigger1", "group1")    		.startAt(startTime)    		.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3).repeatForever())    		.build();    Date ft = sched.scheduleJob(job, trigger);    System.out.println(job.getKey() + " 将在: " + dateFormat.format(ft) + " 是运行，重复: " + trigger.getRepeatCount() + " 次,每 " + trigger.getRepeatInterval() / 1000L + " 秒执行一次");    job = JobBuilder.newJob(StatefulDumbJob.class)    		.withIdentity("statefulJob2", "group1")    		.usingJobData("ExecutionDelay", Long.valueOf(10000L))    		.build();    trigger = (SimpleTrigger)TriggerBuilder.newTrigger()    		.withIdentity("trigger2", "group1")    		.startAt(startTime)    		.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3).repeatForever()    				//设置失败指令:表示当job因为job执行时间过长 而 错过触发器时 job执行完后立即再次执行job    				.withMisfireHandlingInstructionNowWithExistingCount())    		.build();    ft = sched.scheduleJob(job, trigger);    System.out.println(job.getKey() + " 将在: " + dateFormat.format(ft) + " 是运行，重复: " + trigger.getRepeatCount() + " 次,每 " + trigger.getRepeatInterval() / 1000L + " 秒执行一次");    System.out.println("------- 开始Scheduler ----------------");    sched.start();    System.out.println("------- Scheduler调用job结束 -----------------");        System.out.println("------- 等待10分钟... --------------");    try{      Thread.sleep(600000L);    }    catch (Exception e){    }    System.out.println("------- 关闭Scheduler ---------------------");    sched.shutdown(true);    System.out.println("------- 关闭完成 -----------------");    SchedulerMetaData metaData = sched.getMetaData();    System.out.println("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");  }  public static void main(String[] args) throws Exception  {    MisfireExample example = new MisfireExample();    example.run();  }}

job1:没有设置触发失败指令所以 job1会在job执行完成后下一个触发器触发的时间执行job

job2:设置了触发失败指令所以当job2执行完成后不管有没有到触发时间都会执行job

最终的结果是 job2的执行次数大于job1的执行次数

为job加上@DisallowConcurrentExecution注解后job执行就会阻塞，在上一次job执行完毕后再去执行下一次job

如果没加上@DisallowConcurrentExecution注解只要到了触发器触发的时间，就会执行一次job，

因为上述的job有对数据进行操作如果上一个job没有执行结束，下一个job开始执行，就会对数据进行脏写：

这个是没加@DisallowConcurrentExecution注解的影响：

------- 初始化 -------------------SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".SLF4J: Defaulting to no-operation (NOP) logger implementationSLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.------- 初始化完成 --------------- 向Scheduler加入Job ----------------group1.statefulJob1 将在: 2014年07月31日 18时56分00秒 是运行，重复: -1 次,每 3 秒执行一次group1.statefulJob2 将在: 2014年07月31日 18时56分00秒 是运行，重复: -1 次,每 3 秒执行一次------- 开始Scheduler ----------------------- Scheduler调用job结束 ------------------------ 等待10分钟... -----------------2014年07月31日 18时56分00秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分00秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分03秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分03秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分06秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分06秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分09秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分09秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分10秒 ：group1.statefulJob1 完成次数 (1).---2014年07月31日 18时56分10秒 ：group1.statefulJob2 完成次数 (1).---2014年07月31日 18时56分12秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分12秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分13秒 ：group1.statefulJob2 完成次数 (1).---2014年07月31日 18时56分13秒 ：group1.statefulJob1 完成次数 (1).---2014年07月31日 18时56分15秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分15秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分16秒 ：group1.statefulJob2 完成次数 (1).---2014年07月31日 18时56分16秒 ：group1.statefulJob1 完成次数 (1).---2014年07月31日 18时56分18秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分18秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分19秒 ：group1.statefulJob2 完成次数 (1).---2014年07月31日 18时56分19秒 ：group1.statefulJob1 完成次数 (1).---2014年07月31日 18时56分21秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分21秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分22秒 ：group1.statefulJob2 完成次数 (2).---2014年07月31日 18时56分22秒 ：group1.statefulJob1 完成次数 (2).---2014年07月31日 18时56分24秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分24秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分25秒 ：group1.statefulJob1 完成次数 (2).---2014年07月31日 18时56分25秒 ：group1.statefulJob2 完成次数 (2).---2014年07月31日 18时56分27秒 ：执行 group1.statefulJob1---2014年07月31日 18时56分27秒 ：执行 group1.statefulJob2---2014年07月31日 18时56分28秒 ：group1.statefulJob1 完成次数 (2).---2014年07月31日 18时56分28秒 ：group1.statefulJob2 完成次数 (2).

加上注解后：

------- 初始化 -------------------SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".SLF4J: Defaulting to no-operation (NOP) logger implementationSLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.------- 初始化完成 --------------- 向Scheduler加入Job ----------------group1.statefulJob1 将在: 2014年07月31日 17时35分45秒 是运行，重复: -1 次,每 3 秒执行一次group1.statefulJob2 将在: 2014年07月31日 17时35分45秒 是运行，重复: -1 次,每 3 秒执行一次------- 开始Scheduler ----------------------- Scheduler调用job结束 ------------------------ 等待10分钟... -----------------2014年07月31日 17时35分45秒 ：执行 group1.statefulJob1---2014年07月31日 17时35分45秒 ：执行 group1.statefulJob2---2014年07月31日 17时35分55秒 ：group1.statefulJob1 完成次数 (1).---2014年07月31日 17时35分55秒 ：group1.statefulJob2 完成次数 (1).---2014年07月31日 17时35分55秒 ：执行 group1.statefulJob2---2014年07月31日 17时35分55秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分05秒 ：group1.statefulJob2 完成次数 (2).---2014年07月31日 17时36分05秒 ：group1.statefulJob1 完成次数 (2).---2014年07月31日 17时36分05秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分05秒 ：执行 group1.statefulJob2---2014年07月31日 17时36分15秒 ：group1.statefulJob1 完成次数 (3).---2014年07月31日 17时36分15秒 ：group1.statefulJob2 完成次数 (3).---2014年07月31日 17时36分15秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分15秒 ：执行 group1.statefulJob2---2014年07月31日 17时36分25秒 ：group1.statefulJob2 完成次数 (4).---2014年07月31日 17时36分25秒 ：group1.statefulJob1 完成次数 (4).---2014年07月31日 17时36分25秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分25秒 ：执行 group1.statefulJob2---2014年07月31日 17时36分35秒 ：group1.statefulJob1 完成次数 (5).---2014年07月31日 17时36分35秒 ：group1.statefulJob2 完成次数 (5).---2014年07月31日 17时36分35秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分35秒 ：执行 group1.statefulJob2---2014年07月31日 17时36分45秒 ：group1.statefulJob1 完成次数 (6).---2014年07月31日 17时36分45秒 ：group1.statefulJob2 完成次数 (6).---2014年07月31日 17时36分45秒 ：执行 group1.statefulJob2---2014年07月31日 17时36分45秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分55秒 ：group1.statefulJob2 完成次数 (7).---2014年07月31日 17时36分55秒 ：group1.statefulJob1 完成次数 (7).---2014年07月31日 17时36分55秒 ：执行 group1.statefulJob1---2014年07月31日 17时36分55秒 ：执行 group1.statefulJob2---2014年07月31日 17时37分05秒 ：group1.statefulJob1 完成次数 (8).---2014年07月31日 17时37分05秒 ：执行 group1.statefulJob1---2014年07月31日 17时37分05秒 ：group1.statefulJob2 完成次数 (8).---2014年07月31日 17时37分05秒 ：执行 group1.statefulJob2---2014年07月31日 17时37分15秒 ：group1.statefulJob1 完成次数 (9).---2014年07月31日 17时37分15秒 ：group1.statefulJob2 完成次数 (9).

转载地址：http://ahwfb.baihongyu.com/

你可能感兴趣的文章

【LEETCODE】202-Happy Number

【LEETCODE】240-Search a 2D Matrix II

查看>>

【LEETCODE】53-Maximum Subarray

查看>>