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();

// 建立每天早上 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
{
    public async Task Execute(IJobExecutionContext context)
    {
        try
        {
            // 工作邏輯
            await DoWork();
        }
        catch (Exception ex)
        {
            // 記錄錯誤
            await LogError(ex);
            
            // 決定是否重試
            if (ShouldRetry(ex))
            {
                // 觸發重試機制
                await TriggerRetry(context);
            }
            
            // 拋出例外,讓 Quartz 知道工作失敗
            throw;
        }
    }
}