quartz misfire

2020-03-10  本文已影响0人  jianshuqiang

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);
上一篇 下一篇

猜你喜欢

热点阅读