博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
quartz-misfire 错失、补偿执行
阅读量:5958 次
发布时间:2019-06-19

本文共 3685 字,大约阅读时间需要 12 分钟。

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

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

比如:13:07:24开始执行,重复执行5次,开始执行时,quartz已经计算好每次调度的时间刻,分别如下:

03:33:36,03:33:39,03:33:42,03:33:45,03:33:48,03:33:51

如果第一次执行时间为11s,到03:33:47结束,03:33:47减去03:33:39的时间间隔是8s,如果misfireThreshold设置的时间小于等于8s间隔,则认为是misfire了,如果大于8s间隔,则认为没有misfire。

 

CronTrigger 

CronScheduleBuilder csb = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");csb.withMisfireHandlingInstructionDoNothing();csb.withMisfireHandlingInstructionFireAndProceed();(默认)csb.withMisfireHandlingInstructionIgnoreMisfires();

  

withMisfireHandlingInstructionDoNothing——不触发立即执行——等待下次Cron触发频率到达时刻开始按照Cron频率依次执行
withMisfireHandlingInstructionIgnoreMisfires——以错过的第一个频率时间立刻开始执行——重做错过的所有频率周期后——当下一次触发频率发生时间大于当前时间后,再按照正常的Cron频率依次执行
withMisfireHandlingInstructionFireAndProceed(默认)——以当前时间为触发频率立刻触发一次执行——然后按照Cron频率依次执行

SimpleTrigger 

SimpleScheduleBuilder ssb = SimpleScheduleBuilder.simpleSchedule();ssb.withMisfireHandlingInstructionFireNow();ssb.withMisfireHandlingInstructionIgnoreMisfires();ssb.withMisfireHandlingInstructionNextWithExistingCount();ssb.withMisfireHandlingInstructionNextWithRemainingCount();ssb.withMisfireHandlingInstructionNowWithExistingCount();  (默认)ssb.withMisfireHandlingInstructionNowWithRemainingCount();
 
withMisfireHandlingInstructionFireNow——以当前时间为触发频率立即触发执行——执行至FinalTIme的剩余周期次数——以调度或恢复调度的时刻为基准的周期频率,FinalTime根据剩余次数和当前时间计算得到——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值
  
withMisfireHandlingInstructionIgnoreMisfires——以错过的第一个频率时间立刻开始执行——重做错过的所有频率周期——当下一次触发频率发生时间大于当前时间以后,按照Interval的依次执行剩下的频率——共执行RepeatCount+1次
  
withMisfireHandlingInstructionNextWithExistingCount——不触发立即执行——等待下次触发频率周期时刻,执行至FinalTime的剩余周期次数——以startTime为基准计算周期频率,并得到FinalTime——即使中间出现pause,resume以后保持FinalTime时间不变
  
withMisfireHandlingInstructionNextWithRemainingCount——不触发立即执行——等待下次触发频率周期时刻,执行至FinalTime的剩余周期次数——以startTime为基准计算周期频率,并得到FinalTime——即使中间出现pause,resume以后保持FinalTime时间不变
  
withMisfireHandlingInstructionNowWithExistingCount(默认)——以当前时间为触发频率立即触发执行——执行至FinalTIme的剩余周期次数——以调度或恢复调度的时刻为基准的周期频率,FinalTime根据剩余次数和当前时间计算得到——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值
  
withMisfireHandlingInstructionNowWithRemainingCount——以当前时间为触发频率立即触发执行——执行至FinalTIme的剩余周期次数——以调度或恢复调度的时刻为基准的周期频率,FinalTime根据剩余次数和当前时间计算得到——调整后的FinalTime会略大于根据starttime计算的到的FinalTime值MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_REMAINING_REPEAT_COUNT——此指令导致trigger忘记原始设置的starttime和repeat-count——触发器的repeat-count将被设置为剩余的次数——这样会导致后面无法获得原始设定的starttime和repeat-count值

  

misfireHandler线程

下面这些原因可能造成 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个;

执行流程:

  1. 若配置(默认为true,可配置)成获取锁前先检查是否有需要recovery的trigger,先获取misfireCount;
  2. 获取TRIGGER_ACCESS锁;
  3. hasMisfiredTriggersInState:获取misfired的trigger,默认一个事务里只能最大20个misfired trigger(可配置),misfired判断依据:status=waiting,next_fire_time < current_time-misfirethreshold(可配置,默认1min)
  4. notifyTriggerListenersMisfired
  5. updateAfterMisfire:获取misfire策略(默认是MISFIRE_INSTRUCTION_SMART_POLICY,该策略在CronTrigger中=MISFIRE_INSTRUCTION_FIRE_ONCE_NOW),根据策略更新nextFireTime;
  6. 将nextFireTime等更新到trigger表;
  7. commit connection,释放锁
  8. 如果还有更多的misfired,sleep短暂时间(为了集群负载均衡),否则sleep misfirethreshold时间,后继续轮询;

misfireHandler线程执行流程如下图所示:

 

转载于:https://www.cnblogs.com/skyLogin/p/6927629.html

你可能感兴趣的文章
RabbitMQ (两)工作队列
查看>>
[GIT] Git 工作流程(Git flow, Github flow flow, Git lab flow)
查看>>
Jquery高亮显示文本中重要的关键字
查看>>
对于表列数据类型选择的一点思考对于表列数据类型选择的一点思考
查看>>
如何为编程爱好者设计一款好玩的智能硬件(二)——别人是如何设计硬件积木的!...
查看>>
SQL server 2005高可用性之----数据库镜像
查看>>
轻、快、好、免费的开发工具
查看>>
[LeetCode] Delete Duplicate Emails 删除重复邮箱
查看>>
fullCalendar动态获取数据
查看>>
Android 服务端开发之开发环境配置
查看>>
如何建立自己的私有云存储
查看>>
CPA,CPS,CPC,CPM的特点
查看>>
Phonegap Online和Offline
查看>>
软件设计
查看>>
Open XML应用安全(4)文档校验
查看>>
jquery.lazyload的使用
查看>>
学习笔记:启动对特定用户的会话的sql跟踪
查看>>
开发node桌面级应用工具:apk转化epub
查看>>
笨笨图片批量抓取下载 V0.2 beta[C# | WinForm | 正则表达式 | HttpWebRequest | Async异步编程]...
查看>>
VS2010启动程序提示文件加载 使用 简体中文(GB2312)编码加载文件解决办法
查看>>