如何在.NET 5应用中实现基于用户动态指定时间的Quartz Scheduler

1. 安装必要依赖 #

通过NuGet安装以下包：

Quartz
Quartz.Extensions.Hosting
Microsoft.EntityFrameworkCore.SqlServer // 根据你的数据库类型选择对应包

2. 定义数据更新任务 #

创建实现IJob的任务类，封装数据库更新逻辑：

using Quartz;
using System.Threading.Tasks;

public class DataUpdateJob : IJob
{
    private readonly YourDbContext _dbContext;

    // 注入数据库上下文
    public DataUpdateJob(YourDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        // 替换为你的实际数据更新逻辑
        var targetRecords = await _dbContext.YourTable.Where(t => t.NeedUpdate).ToListAsync();
        foreach (var record in targetRecords)
        {
            record.Status = "已更新";
            // 其他字段更新操作
        }
        await _dbContext.SaveChangesAsync();
    }
}

3. 配置Quartz与动态调度服务 #

在Startup.cs中注册服务：

using Quartz;
using Microsoft.EntityFrameworkCore;

public void ConfigureServices(IServiceCollection services)
{
    // 注册数据库上下文
    services.AddDbContext<YourDbContext>(options =>
        options.UseSqlServer(Configuration.GetConnectionString("DefaultConnection")));

    // 配置Quartz
    services.AddQuartz(q =>
    {
        q.UseMicrosoftDependencyInjectionJobFactory(); // 用DI创建任务实例
    });

    // 托管Quartz服务
    services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);

    // 添加自定义动态调度服务
    services.AddHostedService<DynamicJobScheduler>();
}

4. 实现动态调度逻辑 #

创建后台服务，定期从数据库读取定时时间并调整任务：

using Microsoft.Extensions.Hosting;
using Quartz;
using System.Threading;
using System.Threading.Tasks;

public class DynamicJobScheduler : BackgroundService
{
    private readonly ISchedulerFactory _schedulerFactory;
    private readonly YourDbContext _dbContext;
    private IScheduler _scheduler;
    private DateTime? _lastScheduledTime;

    public DynamicJobScheduler(ISchedulerFactory schedulerFactory, YourDbContext dbContext)
    {
        _schedulerFactory = schedulerFactory;
        _dbContext = dbContext;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _scheduler = await _schedulerFactory.GetScheduler(stoppingToken);
        await _scheduler.Start(stoppingToken);

        while (!stoppingToken.IsCancellationRequested)
        {
            // 从数据库获取用户指定的执行时间
            var scheduleSetting = await _dbContext.ScheduleSettings.FirstOrDefaultAsync(stoppingToken);
            if (scheduleSetting != null && scheduleSetting.ExecutionTime != _lastScheduledTime)
            {
                _lastScheduledTime = scheduleSetting.ExecutionTime;

                // 移除旧任务（避免重复调度）
                await _scheduler.DeleteJob(new JobKey("DataUpdateJob"), stoppingToken);

                // 创建新任务和触发器
                var job = JobBuilder.Create<DataUpdateJob>()
                    .WithIdentity("DataUpdateJob")
                    .Build();

                var trigger = TriggerBuilder.Create()
                    .WithIdentity("DataUpdateTrigger")
                    .StartAt(scheduleSetting.ExecutionTime) // 按数据库指定时间执行
                    .Build();

                // 调度任务
                await _scheduler.ScheduleJob(job, trigger, stoppingToken);
            }

            // 每隔5分钟检查一次数据库配置，可根据需求调整间隔
            await Task.Delay(TimeSpan.FromMinutes(5), stoppingToken);
        }

        await _scheduler.Shutdown(stoppingToken);
    }
}

5. 数据库表说明 #

需要创建存储定时配置的表（示例）：

CREATE TABLE ScheduleSettings (
    Id INT PRIMARY KEY IDENTITY(1,1),
    ExecutionTime DATETIME NOT NULL,
    -- 可添加其他配置字段，比如任务描述
);

注意事项 #

• 如果需要重复执行任务，可将触发器改为Cron表达式模式，替换StartAt为WithCronSchedule(scheduleSetting.CronExpression)
• 确保数据库上下文的依赖注入配置正确
• 可根据业务需求调整数据库检查间隔时间

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