Quartz.NET 入門指南 - 打造可靠的.NET排程系統

Install-Package Quartz

// 定義一個簡單的工作
public class HelloJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        // 記錄工作執行時間
        string executeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
        
        // 執行工作邏輯
        await Console.Out.WriteLineAsync($"Hello! 執行時間: {executeTime}");
        
        // 可以從 context 取得傳入的參數
        var dataMap = context.JobDetail.JobDataMap;
        string jobSays = dataMap.GetString("jobSays");
        await Console.Out.WriteLineAsync($"參數值: {jobSays}");
    }
}

// 建立排程器
IScheduler scheduler = await StdSchedulerFactory.GetDefaultScheduler();

// 定義工作
IJobDetail job = JobBuilder.Create<HelloJob>()
    .WithIdentity("helloJob", "group1")       // 設定工作名稱和群組
    .UsingJobData("jobSays", "Hello World!")   // 傳入參數
    .Build();

// 建立觸發器 - 每 5 秒執行一次
ITrigger trigger = TriggerBuilder.Create()
    .WithIdentity("trigger1", "group1")        // 設定觸發器名稱和群組
    .StartNow()                                // 立即開始
    .WithSimpleSchedule(x => x
        .WithIntervalInSeconds(5)              // 間隔 5 秒
        .RepeatForever())                      // 永遠重複
    .Build();

// 註冊工作和觸發器
await scheduler.ScheduleJob(job, trigger);

// 啟動排程器
await scheduler.Start();

// 等待（Console 程式需要防止主執行緒提早結束）
await Task.Delay(TimeSpan.FromSeconds(60));

// 關閉排程器
await scheduler.Shutdown();

// 建立每天早上 9:00 執行的觸發器
ITrigger cronTrigger = TriggerBuilder.Create()
    .WithIdentity("trigger2", "group1")
    .WithCronSchedule("0 0 9 * * ?")  // 每天早上 9:00
    .Build();

// 替換掉原本的觸發器，重新排程
await scheduler.ScheduleJob(job, cronTrigger);

public class ErrorHandlingJob : IJob
{
    private readonly ILogger<ErrorHandlingJob> _logger;

    public ErrorHandlingJob(ILogger<ErrorHandlingJob> logger)
    {
        _logger = logger;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        try
        {
            // 實際工作邏輯放這裡
            await DoWorkAsync();
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Job {JobKey} 執行失敗", context.JobDetail.Key);

            // refireImmediately = true 會讓 Quartz 立即重新排入佇列執行一次
            var jobEx = new JobExecutionException(ex, refireImmediately: false);
            throw jobEx;
        }
    }

    private async Task DoWorkAsync()
    {
        // 實際業務邏輯
        await Task.CompletedTask;
    }
}