Quartz 在misfire模式[错失、补偿执行] 策略

悠悠 2023-07-05 13:08 14阅读 0赞

# 概述 #

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

misfire产生的条件是：到了该触发执行时上一个执行还未完成，且线程池中没有空闲线程可以使用（**或有空闲线程可以使用但job设置为@DisallowConcurrentExecution**）且过期时间已经超过misfireThreshold就认为是misfire了，错失触发了

**job默认是并发执行, 如果job设置@DisallowConcurrentExecution ,则为串行执行.**

## misfired job原因 ##

1.  系统因为某些原因被重启。在系统关闭到重新启动之间的一段时间里，可能有些任务会被 misfire；
2.  Trigger 被暂停（suspend）的一段时间里，有些任务可能会被 misfire；
3.  线程池中所有线程都被占用，导致任务无法被触发执行，造成 misfire；
4.  有状态任务在下次触发时间到达时，上次执行还没有结束；为了处理 misfired job，Quartz 中为 trigger 定义了处理策略，主要有下面两种：MISFIRE\_INSTRUCTION\_FIRE\_ONCE\_NOW：针对 misfired job 马上执行一次；MISFIRE\_INSTRUCTION\_DO\_NOTHING：忽略 misfired job，等待下次触发；默认是MISFIRE\_INSTRUCTION\_SMART\_POLICY，该策略在CronTrigger中=MISFIRE\_INSTRUCTION\_FIRE\_ONCE\_NOW线程默认1分钟执行一次；在一个事务中，默认一次最多recovery 20个；

# 参数设置 #

## quartz.properties ##

> **org.quartz.jobStore.misfireThreshold = 60000 \[默认\]**

## CronSchedule 策略 ##

org.quartz.Trigger trigger = TriggerBuilder.newTrigger()
                    .withIdentity("trigger1", "group1")
                    .startNow()
                    .withSchedule(
                            CronScheduleBuilder.cronSchedule("0/3 * * * * ?")
    
                            //  withMisfireHandlingInstructionIgnoreMisfires() MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY 忽略所有的超时状态，按照触发器的策略执行。
                            // withMisfireHandlingInstructionFireAndProceed()   MISFIRE_INSTRUCTION_FIRE_ONCE_NOW   立刻执行一次，然后就按照正常的计划执行。
                            // withMisfireHandlingInstructionDoNothing()   MISFIRE_INSTRUCTION_DO_NOTHING           目前不执行，然后就按照正常的计划执行。
                    )
                    .build();

withMisfireHandlingInstructionFireAndProceed   [MISFIRE_INSTRUCTION_FIRE_ONCE_NOW]（默认）
    ——以当前时间为触发频率立刻触发一次执行
    ——然后按照Cron频率依次执行
    
    
    
    withMisfireHandlingInstructionDoNothing   [MISFIRE_INSTRUCTION_DO_NOTHING ]
    ——不触发立即执行
    ——等待下次Cron触发频率到达时刻开始按照Cron频率依次执行
    
    
    withMisfireHandlingInstructionIgnoreMisfires    [MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY] 
    ——以错过的第一个频率时间立刻开始执行
    ——重做错过的所有频率周期后
    ——当下一次触发频率发生时间大于当前时间后，再按照正常的Cron频率依次执行
    即: 忽略所有的超时状态，按照触发器的策略执行。

前提：在每个星期周一下午5点到7点，每隔一个小时执行一次，理论上共执行3次。
    
    1. 情景一：
    
    //所有misfire的任务会马上执行
    public static final int MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY = -1;
    若是5点misfire，6:15系统恢复之后，5,6点的misfire会马上执行。
    
    2. 情景二：
    
    
    //不做任何事情
    public static final int MISFIRE_INSTRUCTION_DO_NOTHING = 2;
    若是5点misfire，6:15系统恢复之后，只会执行7点的misfire。如果下次执行时间超过了end time，实际上就没有执行机会了。
    
    3. 情景三：（cronTrigger的默认策略）
    
    
    // CornTrigger默认策略，合并部分misfire，正常执行下一个周期的任务。
    public static final int MISFIRE_INSTRUCTION_FIRE_ONCE_NOW = 1;
    若是5点misfire，6:15系统恢复之后，立刻执行一次（只会一次）misfire。

## SimpleSchedule 策略 ##

SimpleScheduleBuilder sp = SimpleScheduleBuilder.simpleSchedule();
     
    sp.withMisfireHandlingInstructionFireNow();
    sp.withMisfireHandlingInstructionIgnoreMisfires();
    sp.withMisfireHandlingInstructionNextWithExistingCount();
    sp.withMisfireHandlingInstructionNextWithRemainingCount();
    sp.withMisfireHandlingInstructionNowWithExistingCount();　　（默认）
    sp.withMisfireHandlingInstructionNowWithRemainingCount();

withMisfireHandlingInstructionNowWithExistingCount（默认）
    ——以当前时间为触发频率立即触发执行
    ——执行至FinalTIme的剩余周期次数
    ——以调度或恢复调度的时刻为基准的周期频率，FinalTime根据剩余次数和当前时间计算得到
    ——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值
    
    
    withMisfireHandlingInstructionFireNow
    ——以当前时间为触发频率立即触发执行
    ——执行至FinalTIme的剩余周期次数
    ——以调度或恢复调度的时刻为基准的周期频率，FinalTime根据剩余次数和当前时间计算得到
    ——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值
    
    
    
    withMisfireHandlingInstructionIgnoreMisfires
    ——以错过的第一个频率时间立刻开始执行
    ——重做错过的所有频率周期
    ——当下一次触发频率发生时间大于当前时间以后，按照Interval的依次执行剩下的频率
    ——共执行RepeatCount+1次
    
    
    withMisfireHandlingInstructionNextWithExistingCount
    ——不触发立即执行
    ——等待下次触发频率周期时刻，执行至FinalTime的剩余周期次数
    ——以startTime为基准计算周期频率，并得到FinalTime
    ——即使中间出现pause，resume以后保持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值

# #

参考:

[https://www.cnblogs.com/skyLogin/p/6927629.html][https_www.cnblogs.com_skyLogin_p_6927629.html]

[https://www.jianshu.com/p/572322b36383][https_www.jianshu.com_p_572322b36383]

[https_www.cnblogs.com_skyLogin_p_6927629.html]: https://www.cnblogs.com/skyLogin/p/6927629.html
[https_www.jianshu.com_p_572322b36383]: https://www.jianshu.com/p/572322b36383