如何让Quartz每次运行时都持久化JobData而非仅在变更时？

Quartz默认仅在JobDetail（含JobDataMap）发生变更时触发持久化，这是性能优化的设计。要实现无论是否变更都强制持久化JobData，可参考以下几种方案：

方案1：自定义JobStore重写持久化逻辑 #

继承Quartz内置的JobStore（如JobStoreTX/JobStoreCMT），重写相关方法绕过变更检查，强制执行存储操作：

public class ForcePersistJobStore : JobStoreTX
{
    protected override async Task StoreJobDetailAsync(
        IJobDetail jobDetail, 
        bool replaceExisting, 
        CancellationToken cancellationToken = default)
    {
        // 强制覆盖现有记录，忽略变更判断
        await base.StoreJobDetailAsync(jobDetail, true, cancellationToken);
    }

    public override async Task JobWasExecutedAsync(
        IJobExecutionContext context, 
        JobExecutionException jobException, 
        CancellationToken cancellationToken = default)
    {
        await base.JobWasExecutedAsync(context, jobException, cancellationToken);
        // Job执行完成后，强制存储最新的JobDetail
        await StoreJobDetailAsync(context.JobDetail, true, cancellationToken);
    }
}

在Quartz配置中指定使用该自定义JobStore：

services.AddQuartz(q =>
{
    q.UsePersistentStore(s =>
    {
        s.UseJobStore<ForcePersistJobStore>();
        s.UseJsonSerializer();
        // 其他数据库连接、序列化配置...
    });
});

方案2：全局JobListener拦截执行后更新 #

实现IJobListener，在每个Job执行完成后主动触发JobDetail的更新：

public class ForcePersistJobListener : IJobListener
{
    private readonly ISchedulerFactory _schedulerFactory;

    public ForcePersistJobListener(ISchedulerFactory schedulerFactory)
    {
        _schedulerFactory = schedulerFactory;
    }

    public string Name => "ForcePersistJobListener";

    public async Task JobWasExecutedAsync(
        IJobExecutionContext context, 
        JobExecutionException jobException, 
        CancellationToken cancellationToken = default)
    {
        var scheduler = await _schedulerFactory.GetScheduler(cancellationToken);
        // 强制覆盖原JobDetail
        await scheduler.AddJob(context.JobDetail, true, true, cancellationToken);
    }

    public Task JobToBeExecutedAsync(IJobExecutionContext context, CancellationToken cancellationToken = default) => Task.CompletedTask;
    public Task JobExecutionVetoedAsync(IJobExecutionContext context, CancellationToken cancellationToken = default) => Task.CompletedTask;
}

注册监听器到Quartz：

services.AddQuartz(q =>
{
    q.AddJobListener<ForcePersistJobListener>();
    q.UsePersistentStore(s =>
    {
        s.UseJsonSerializer();
        // 其他配置...
    });
});

方案3：一次性批量迁移脚本（推荐用于迁移场景） #

如果只是为了完成二进制到JSON的迁移，没必要长期开启强制持久化，直接批量处理所有JobDetail更高效：

var scheduler = await _schedulerFactory.GetScheduler();
var allJobKeys = await scheduler.GetJobKeys(GroupMatcher<JobKey>.AnyGroup());

foreach (var jobKey in allJobKeys)
{
    var jobDetail = await scheduler.GetJobDetail(jobKey);
    // 重新添加JobDetail，强制触发JSON序列化并写入数据库
    await scheduler.AddJob(jobDetail, true, true);
}

也可直接操作数据库（需提前备份）：

1. 读取QUARTZ_JOB_DETAILS表的二进制JOB_DATA
2. 用Quartz二进制序列化器反序列化为JobDataMap
3. 用JSON序列化器转为JSON字符串后更新回数据库

注意事项 #

• 方案1、2会增加数据库写入压力，迁移完成后建议移除，避免长期影响性能
• 批量脚本是一次性操作，适合大规模数据库迁移场景
• 所有操作前务必备份数据库，防止数据丢失

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