Quartz触发任务进入ERROR状态后停止执行，如何配置重试？

一、控制任务重试的核心配置/实现方式 #

Quartz提供多种机制避免任务进入ERROR状态后停止触发，实现持续重试：

1. 任务内部触发即时重试 #

在DeliverTicketsJob的execute方法中捕获所有异常，抛出JobExecutionException并设置refireImmediately=true，让Quartz立即重试任务：

@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
    try {
        // 业务逻辑代码
    } catch (Exception e) {
        LOGGER.error("DeliverTicketsJob执行失败，触发重试", e);
        JobExecutionException retryException = new JobExecutionException(e);
        retryException.setRefireImmediately(true);
        throw retryException;
    }
}

2. 配置任务持久化与崩溃恢复 #

创建任务时开启requestRecovery和durability参数，确保调度器重启或Pod异常时任务能恢复执行：

JobDescription jobDescription = JobDescriptionBuilder.builder()
        // 现有配置保留
        .requestRecovery(true) // 调度器崩溃后自动恢复任务
        .durability(true) // 无触发器关联时仍保留任务
        .build();

3. CRON任务的重试策略补充 #

若需对CRON任务设置固定间隔重试，可结合SimpleTrigger作为重试触发器，或通过JobListener手动重新调度任务。

二、排查任务进入ERROR状态的方法 #

当前TriggerListener仅监听触发器生命周期，无法捕获任务执行异常，可通过以下方式定位问题：

1. 实现JobListener捕获执行异常 #

新增JobListener监听任务执行的成功/失败事件，直接获取异常详情：

public class QuartzJobExecutionListener implements JobListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(QuartzJobExecutionListener.class);

    @Override
    public String getName() {
        return "QuartzJobExecutionListener";
    }

    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        LOGGER.info("任务即将执行: {}", context.getJobDetail().getKey());
    }

    @Override
    public void jobExecutionVetoed(JobExecutionContext context) {
        LOGGER.info("任务执行被否决: {}", context.getJobDetail().getKey());
    }

    @Override
    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
        if (jobException != null) {
            LOGGER.error("任务执行失败进入ERROR状态: {}", context.getJobDetail().getKey(), jobException);
        } else {
            LOGGER.info("任务执行完成: {}", context.getJobDetail().getKey());
        }
    }
}

注册该Listener到调度器：

scheduler.getListenerManager().addJobListener(new QuartzJobExecutionListener());

2. 开启Quartz DEBUG日志 #

在日志配置中开启org.quartz包的DEBUG级别，查看调度器内部的任务分配、执行、异常处理流程：

# Logback示例配置
<logger name="org.quartz" level="DEBUG" />

3. 检查Quartz存储状态 #

若使用数据库存储（JDBC JobStore），直接查询QRTZ_TRIGGERS表的TRIGGER_STATE和ERROR_MSG字段（部分版本支持），获取任务状态及错误信息。

三、现有代码调整建议 #

• 替换当前TriggerListener为上述JobListener，监控任务执行异常；
• 强制在DeliverTicketsJob的execute方法中捕获所有异常，通过JobExecutionException触发重试；
• 确认JobDescriptionBuilder是否支持requestRecovery和durability配置，不支持则直接用Quartz原生API创建JobDetail时设置。

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