quartz定时任务不执行(任务统筹策略)
大家好，又见面了，我是你们的朋友全栈君。
由于某种原因，例如应用停掉，导致定时任务错过了本该执行的时间点，这就是定时任务过期。对于过期的定时任务，我们需要基于某种策略对其进行处理。
过期策略
在Trigger接口中定义了两种过期策略，
public static final int MISFIRE_INSTRUCTION_SMART_POLICY = 0;
public static final int MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY = -1;MISFIRE_INSTRUCTION_SMART_POLICY 表明过期的定时任务将使用智能策略，如何处理将依赖于具体的Trigger实现类。等会我们会专门分析最常用的CronTrigger的智能过期策略的实现。 MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY 表明对于过期的定时任务将不执行任何过期策略。
设定过期策略
以CronTrigger为例，我们在添加定时任务的时候可以通过CronSchedulerBuilder设定过期策略。
JobDetail jobDetail = JobBuilder.newJob(PrintJob.class)
.storeDurably(true)
.withIdentity(id)
.withDescription(desc)
.setJobData(jobDataMap).build();
CronScheduleBuilder schBuilder = CronScheduleBuilder.cronSchedule(cron)
.withMisfireHandlingInstructionFireAndProceed();
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity(id)
.withDescription(desc)
.forJob(jobDetail)
.withSchedule(schBuilder).build();如果不指定默认就是MISFIRE_INSTRUCTION_SMART_POLICY ，即采用智能策略模式。
CronTrigger过期策略
CronTrigger的智能过期策略有两种
public static final int MISFIRE_INSTRUCTION_FIRE_ONCE_NOW = 1;
public static final int MISFIRE_INSTRUCTION_DO_NOTHING = 2;看字面意思很好理解，第一种是立即触发一次，第二种是忽略掉不管。定时任务过期后，需要对triiger进行处理，具体的处理是在具体的Trigger实现类中实现的，例如CronTriggerImpl
@Override
public void updateAfterMisfire(org.quartz.Calendar cal) {
int instr = getMisfireInstruction();
if(instr == Trigger.MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY)
return;
if (instr == MISFIRE_INSTRUCTION_SMART_POLICY) {
instr = MISFIRE_INSTRUCTION_FIRE_ONCE_NOW;
}
if (instr == MISFIRE_INSTRUCTION_DO_NOTHING) {
Date newFireTime = getFireTimeAfter(new Date());
while (newFireTime != null && cal != null
&& !cal.isTimeIncluded(newFireTime.getTime())) {
newFireTime = getFireTimeAfter(newFireTime);
}
setNextFireTime(newFireTime);
} else if (instr == MISFIRE_INSTRUCTION_FIRE_ONCE_NOW) {
setNextFireTime(new Date());
}
}从源码中可以看到，CronTrigger的默认智能策略就是立即触发一次（MISFIRE_INSTRUCTION_FIRE_ONCE_NOW)，即更新下次触发时间为当前时间。
过期定时任务检测
前半部分我们讲了定时任务的过期策略，并以CronTrigger为例，说明了其智能过期策略是如何实现的。后半部分，我们将视角从Trigger提升到Scheduler，看看Quartz是如何检测出过期定时任务的。
在JobStoreSupport中有一个叫MisfireHandler的线程，它负责定期检测出那些过期的定时任务。我们来看看它是如何做的。
首先，我们要明确一个过期的标准。一个比较直观的想法就是，如果一个Trigger的下次触发时间在当前时间之前，那么这个定时任务肯定是过期了。但是我们为了给人家一个机会，可以通过减去一个值，稍稍把这个截止时间调前一点。这个值可以通过quartz.properties配置，默认是60000，即60秒。
org.quartz.jobStore.misfireThreshold: 10000当然Trigger必须是WAITING状态下才行，非WAITING状态的Trigger表明定时任务正在处理，已经完成或者出错了。而且过期策略不是MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY 。
有了这三个过期指标，过期的定时任务就好筛选了。我们去QRTZ_TRIGGERS表里面，把符合这三个条件的Trigger都筛选出来。
过期定时任务恢复
以MISFIRE_INSTRUCTION_FIRE_ONCE_NOW过期策略为例，拿到过期的Trigger后，根据过期策略，调用updateAfterMisfire()对其进行更新，包括设置下次触发时间，更新状态为WAITING。
处理完trigger后，MisfireHandler会立即向QuartzSchedulerThread发送信号，告诉有紧急任务达到。
if (recoverMisfiredJobsResult.getProcessedMisfiredTriggerCount() > 0) {
signalSchedulingChangeImmediately(recoverMisfiredJobsResult.getEarliestNewTime());
}QuartzSchedulerThread接收到信号后，如果才刚刚开始扫描触发器则必定能扫描到这个触发器，所以不用做任何额外处理。如果已经获取过触发器了，则释放掉已经获取的触发器，重新开始扫描。
if(releaseIfScheduleChangedSignificantly(triggers, triggerTime)) {
break;
}发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/128399.html原文链接：https://javaforall.cn
腾讯云开发者
