集群模式下如何强制Quartz任务串行执行？服务重启后任务重复触发如何解决

问题根因分析 #

• 重复注册触发器导致触发记录重置
  Spring Boot启动时默认会将@Bean定义的Trigger和Job写入Quartz库，若未做特殊配置，每次重启都可能覆盖数据库中已有的触发器记录、清除上次触发时间，导致启动后立即触发多次补执行，运行数次后触发时间对齐就恢复正常，完全匹配你遇到的现象。
• misfire策略设置不合理
  你当前使用的withMisfireHandlingInstructionNextWithRemainingCount策略，会在检测到misfire（错过触发时间）时立即执行一次任务，重启过程中服务中断产生的misfire会被批量补执行，导致多次触发。
• 集群节点状态同步延迟
  Quartz集群默认需要4倍clusterCheckinInterval的时间才能判定旧节点失效、释放旧节点持有的触发器锁。如果你的服务重启速度快于这个阈值，旧节点的锁未释放，新节点又获取到触发器就会出现重复执行。

解决方案 #

1. 调整Quartz基础配置，禁止启动时覆盖已有任务 #

在你的application.yml的spring.quartz下新增配置：

spring:
  quartz:
    overwrite-existing-jobs: false # 禁止启动时覆盖已存在的Job和Trigger
    properties:
      org.quartz.jobStore:
        misfireThreshold: 10000 # 调整misfire判定阈值为10s，小于你的任务执行间隔即可，避免误判misfire

2. 调整Trigger的misfire策略 #

将withMisfireHandlingInstructionNextWithRemainingCount替换为withMisfireHandlingInstructionNextWithExistingCount，该策略不会补执行重启过程中错过的任务，只会从下一个正常调度时间开始执行：

.withSchedule(
        SimpleScheduleBuilder
                .simpleSchedule()
                .withIntervalInSeconds(CompanyProfilePublishingJob.RUN_INTERVAL_IN_SECONDS)
                .withMisfireHandlingInstructionNextWithExistingCount() // 修改此处
                .repeatForever())

3. 可选：新增触发器存在性校验，避免重复注册 #

如果你的任务是固定不需要动态修改的，可以在配置类中先查询Scheduler中是否已存在对应Trigger，不存在再注册，避免重复写入：

@Autowired
private Scheduler scheduler;

@Bean
public Trigger companyProfilePublishingTrigger(final JobDetail companyProfilePublishingSchedulerJobDetails) throws SchedulerException {
    TriggerKey triggerKey = new TriggerKey("CompanyProfilePublishingSchedulerTrigger");
    if (scheduler.checkExists(triggerKey)) {
        return scheduler.getTrigger(triggerKey);
    }
    return TriggerBuilder
            .newTrigger()
            .forJob(companyProfilePublishingSchedulerJobDetails)
            .withIdentity(triggerKey)
            .withSchedule(
                    SimpleScheduleBuilder
                            .simpleSchedule()
                            .withIntervalInSeconds(CompanyProfilePublishingJob.RUN_INTERVAL_IN_SECONDS)
                            .withMisfireHandlingInstructionNextWithExistingCount()
                            .repeatForever())
            .build();
}

4. 数据库层校验 #

确认你的PostgreSQL数据库的事务隔离级别为读已提交（READ COMMITTED），避免隔离级别过高导致Quartz行锁失效引发重复执行。

内容的提问来源于stack exchange，提问作者gdulus