quartz misfire
withMisfireHandlingInstructionFireAndProceed
默认设置,服务重启立即执行一次
withMisfireHandlingInstructionIgnoreMisfires
执行上次没有执行完成的任务,服务会立即执行
withMisfireHandlingInstructionDoNothing
服务重启后不会立即执行
业务场景
根据业务需要满足上次任务如果已经启动,那么服务重启以后不会立即执行,否则立即执行一次
解决方法
测试发现单独使用withMisfireHandlingInstructionIgnoreMisfires没法满足业务需要
测试方法:设置每五分钟执行一次,发现设置为withMisfireHandlingInstructionIgnoreMisfires的时候调度任务会多次执行。
最终解决方法
如果上次任务已经执行完成:
withMisfireHandlingInstructionDoNothing
如果上次任务没执行withMisfireHandlingInstructionFireAndProceed(默认配置)
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
long currentTime = System.currentTimeMillis();
//获取上次执行时间 时间戳
long previousFireTime = trigger.getPreviousFireTime() == null ? 0 : trigger.getPreviousFireTime().getTime();
scheduleBuilder.withMisfireHandlingInstructionIgnoreMisfires();
if (previousFireTime > 0) {
if (currentTime - previousFireTime < 24 * 60 * 1 * 60 * 1000) {
scheduleBuilder.withMisfireHandlingInstructionDoNothing();
}
}
// 按新的cronExpression表达式重新构建trigger
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
//trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(simpleScheduleBuilder).build();
// 按新的trigger重新设置job执行
scheduler.rescheduleJob(triggerKey, trigger);
网友评论