Quartz.NET结合ADOJobStore：如何在AddQuartz阶段检测作业是否已创建？

核心问题是每次重启应用时直接调用AddJob/AddTrigger会覆盖数据库中已有的作业和触发器记录，重置NEXT_FIRE_TIME和misfire状态，导致配置的WithMisfireHandlingInstructionFireAndProceed策略无法生效。以下是具体解决方案：

1. 启动时检查作业/触发器是否存在，仅在不存在时创建 #

不要在AddQuartz配置中直接硬编码创建逻辑，而是在应用启动后通过IScheduler接口主动查询作业状态，按需创建：

代码示例（Program.cs） #

var builder = WebApplication.CreateBuilder(args);

// 配置Quartz持久化存储
builder.Services.AddQuartz(q =>
{
    q.UsePersistentStore(s =>
    {
        s.UseSqlServer(builder.Configuration.GetConnectionString("QuartzDb"));
        s.UseJsonSerializer();
    });
});

builder.Services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);

var app = builder.Build();

// 启动后检查并创建作业
using var scope = app.Services.CreateScope();
var scheduler = scope.ServiceProvider.GetRequiredService<IScheduler>();
await scheduler.Start();

var jobKey = new JobKey("DailySyncJob", "SyncGroup");
var existingJob = await scheduler.GetJobDetail(jobKey);

if (existingJob == null)
{
    // 创建作业
    var job = JobBuilder.Create<YourDailyJob>()
        .WithIdentity(jobKey)
        .StoreDurably()
        .Build();

    // 创建带Misfire策略的触发器
    var trigger = TriggerBuilder.Create()
        .WithIdentity("DailySyncTrigger", "SyncGroup")
        .WithCronSchedule("0 0 0 * * ?", x => x
            .WithMisfireHandlingInstructionFireAndProceed())
        .Build();

    await scheduler.ScheduleJob(job, trigger);
}

// 可选：如果需要更新触发器配置（如Cron表达式变更）
else
{
    var triggerKey = new TriggerKey("DailySyncTrigger", "SyncGroup");
    var existingTrigger = await scheduler.GetTrigger(triggerKey) as ICronTrigger;
    var targetCronExpr = "0 0 0 * * ?";

    if (existingTrigger == null || existingTrigger.CronExpressionString != targetCronExpr)
    {
        var newTrigger = TriggerBuilder.Create()
            .WithIdentity(triggerKey)
            .WithCronSchedule(targetCronExpr, x => x
                .WithMisfireHandlingInstructionFireAndProceed())
            .Build();

        await scheduler.RescheduleJob(triggerKey, newTrigger);
    }
}

app.Run();

2. 简化方案：使用ReplaceExisting: false参数 #

如果不需要动态更新配置，也可以在AddQuartz配置中直接设置不替换已存在的作业和触发器：

builder.Services.AddQuartz(q =>
{
    q.UsePersistentStore(s =>
    {
        s.UseSqlServer(builder.Configuration.GetConnectionString("QuartzDb"));
        s.UseJsonSerializer();
    });

    var jobKey = new JobKey("DailySyncJob", "SyncGroup");
    // 不替换已存在的作业
    q.AddJob<YourDailyJob>(jobKey, j => j
        .StoreDurably()
        .ReplaceExisting(false));

    // 不替换已存在的触发器
    q.AddTrigger(t => t
        .ForJob(jobKey)
        .WithIdentity("DailySyncTrigger", "SyncGroup")
        .WithCronSchedule("0 0 0 * * ?", x => x
            .WithMisfireHandlingInstructionFireAndProceed())
        .ReplaceExisting(false));
});

原理说明 #

通过上述方式，重启应用时不会覆盖数据库中已有的作业和触发器记录，原有NEXT_FIRE_TIME和misfire状态得以保留，当应用重启时，Quartz会自动检查是否存在错过的触发，并执行配置的FireAndProceed策略。

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