c# 實現Quartz任務調度_ZenDei技術網路在線

使用 Quartz.NET，你可以很容易地安排任務在應用程式啟動時運行，或者每天、每周、每月的特定時間運行，甚至可以基於更複雜的調度規則。官網：http://www.quartz-scheduler.net/ 實現任務類創建一個實現了 IJob 介面的類(MailJobTest)，該介面包含一個 ...

使用 Quartz.NET，你可以很容易地安排任務在應用程式啟動時運行，或者每天、每周、每月的特定時間運行，甚至可以基於更複雜的調度規則。

官網：http://www.quartz-scheduler.net/

實現任務類

創建一個實現了 IJob 介面的類(MailJobTest)，該介面包含一個 Execute 方法，該方法將在作業運行時調用。例如：

using Quartz;
using System;
using System.Threading.Tasks;
using UploadLogiData.Util;

namespace UploadLogiData
{
    /// <summary>
    /// 郵件任務測試(每天三點固定時間檢測Logi數據併發送內部郵件)
    /// </summary>
    //對於耗時任務，需要上一次執行完成後，才執行下次任務，覆蓋之前設置的執行周期
    [DisallowConcurrentExecution]
    public class MailJobTest : IJob
    {
        public async Task Execute(IJobExecutionContext context)
        {
            try
            {
                DisplayListboxMsg("郵箱開始調度");

            } catch (Exception ex)
            {  
                UpUtil.LogWrite("ExceptionLog",$"定時器異常_{ex.StackTrace}");
            }
        }
    }
}

實現一個LogiDownloadJob任務類

using MechTE_480.DateTimeCategory;
using Quartz;
using System;
using System.Threading.Tasks;
using UploadLogiData.Util;

namespace UploadLogiData.Quartzs
{
    /// <summary>
    /// 監聽啟動時間,執行任務下載logi數據
    /// </summary>
    //對於耗時任務，需要上一次執行完成後，才執行下次任務，覆蓋之前設置的執行周期
    [DisallowConcurrentExecution]
    public class LogiDownloadJob : IJob
    {
        public async Task Execute(IJobExecutionContext context)
        {
            DisplayListboxMsg("啟動時間開始調度");
        }
    }
}

啟動調度

實例化並啟動調度程式，並調度要執行的作業：

IScheduler scheduler1;
/// <summary>
/// 執行任務調度
/// </summary>
/// <returns></returns>
public async Task ExLogiQuartz()
{
    DisplayListboxMsg("檢測任務啟動!");
    //1、創建一個調度
    var factory = new StdSchedulerFactory();
    var scheduler = await factory.GetScheduler();
    await scheduler.Start();

    //2、創建一個任務
    var job = JobBuilder.Create<LogiDownloadJob>()
        .WithIdentity("LogiJob","LogiGroup")
        .Build();
    //3、創建一個觸發器
    var trigger = TriggerBuilder.Create()
        .WithIdentity("LogiTrigger","LogiTriggerGroup")
        .WithCronSchedule("0/5 * * * * ?")     //5秒執行一次
        .Build();
    await scheduler.ScheduleJob(job,trigger);

    // 第二個任務
    var job2 = JobBuilder.Create<MailJobTest>()
       .WithIdentity("MailJob","MailGroup")
       .Build();
    //3、創建一個觸發器
    var trigger2 = TriggerBuilder.Create()
        .WithIdentity("MailTrigger","MailTriggerGroup")
        .WithCronSchedule("0/5 * * * * ?")     //5秒執行一次
        .Build();
    await scheduler.ScheduleJob(job2,trigger2);

    scheduler1 = scheduler; // 對象賦值
}

為作業指定身份：

var job = JobBuilder.Create<SimpleJob>()
        .WithIdentity("LogiJob","LogiGroup") // // 作業名稱為 "LogiJob"，組名為 "LogiGroup"  
        .Build();

為觸發器指定身份：

ITrigger trigger = TriggerBuilder.Create()  
    .WithIdentity("myTrigger", "myTriggerGroup") // 觸發器名稱為 "myTrigger"，組名為 "myTriggerGroup"  
    .StartNow()  
    .WithSimpleSchedule(x => x.WithIntervalInHours(1).RepeatForever())  
    .Build();

創建第二個任務:

 // 創建並調度第二個作業  
 // 第二個任務
 var job2 = JobBuilder.Create<MailJobTest>()
    .WithIdentity("MailJob","MailGroup")
    .Build();
 //3、創建一個觸發器
 var trigger2 = TriggerBuilder.Create()
     .WithIdentity("MailTrigger","MailTriggerGroup")
     .WithCronSchedule("0/5 * * * * ?")     //5秒執行一次
     .Build();
 await scheduler.ScheduleJob(job2,trigger2);
  
    // 可以繼續添加更多的作業和觸發器...

重要性

唯一性：確保每個作業和觸發器在調度器中具有唯一的標識，從而避免衝突。
組織性：通過組名，可以將相關的作業或觸發器組織在一起，便於管理。
靈活性：通過使用不同的組，可以輕鬆地啟用、禁用或刪除一組相關的作業或觸發器。
查詢和更新：有了明確的身份標識，可以更容易地查詢作業或觸發器的狀態，或者對其進行更新。

取消任務調度

// 關閉
scheduler1.Shutdown().Wait();

 //方法外部訪問調度器實例
IScheduler scheduler1;
 public async void ExQuartz()
 {
     DisplayListboxMsg("檢測任務啟動!");
     //1、創建一個調度
     var factory = new StdSchedulerFactory();
     var scheduler = await factory.GetScheduler();
     await scheduler.Start();
     //2、創建一個任務
     var job = JobBuilder.Create<SimpleJob>()
         .WithIdentity("job1","group1")
         .Build();
     //3、創建一個觸發器
     var trigger = TriggerBuilder.Create()
         .WithIdentity("trigger1","group1")
         .WithCronSchedule("0/2 * * * * ?")     //5秒執行一次
         .Build();
     await scheduler.ScheduleJob(job,trigger);

     scheduler1 = scheduler; // 對象賦值
  
 }

把ExQuartz封裝到類裡面

ExLogiQuartz方法示例，同時考慮了scheduler的存儲和訪問：

QuartzScheduler類中

using Quartz;
using Quartz.Impl;
using System.Threading.Tasks;

namespace UploadLogiData.Quartzs
{

    /// <summary>
    /// 封裝了ExLogiQuartz方法和對scheduler的訪問
    /// </summary>
    public class QuartzScheduler
    {
        /// <summary>
        /// 方法外部訪問調度器實例
        /// </summary>
        IScheduler logiScheduler;

        //先靜態定義一下主窗體
        public static Form1 form;

        public async Task ExLogiQuartz()
        {
            form.DisplayListboxMsg("檢測任務啟動!");
            // 創建一個調度器實例  
            var factory = new StdSchedulerFactory();
            logiScheduler = await factory.GetScheduler();
            await logiScheduler.Start();

            // 創建一個任務：LogiDownloadJob，每5秒執行一次  
            var job = JobBuilder.Create<LogiDownloadJob>()
                .WithIdentity("LogiJob","LogiGroup")
                .Build();
            var trigger = TriggerBuilder.Create()
                .WithIdentity("LogiTrigger","LogiTriggerGroup")
                .WithCronSchedule("0/5 * * * * ?") // 5秒執行一次  
                .Build();
            await logiScheduler.ScheduleJob(job,trigger);

            // 創建第二個任務：MailJobTest，每天下午3點10分執行一次  
            var job2 = JobBuilder.Create<MailJobTest>()
                .WithIdentity("MailJob","MailGroup")
                .Build();
            var trigger2 = TriggerBuilder.Create()
                .WithIdentity("MailTrigger","MailTriggerGroup")
                .WithCronSchedule("0 10 15 * * ?") // 每天下午3點10分執行一次  
                .Build();
            await logiScheduler.ScheduleJob(job2,trigger2);

            // 如果需要在其他地方訪問scheduler，可以通過類屬性或方法獲取  
        }
        public IScheduler Scheduler => logiScheduler;

    }
}

調用示例

// 使用示例  
public class Program  
{  
    public static async Task Main(string[] args)  
    {  
        var quartzScheduler = new QuartzScheduler();  
        await quartzScheduler.ExLogiQuartz();  
        
        // 如果需要在其他地方訪問scheduler，可以通過以下方式獲取  
        var scheduler = quartzScheduler.Scheduler;  
      
        // 如調用關閉
        quartzScheduler.Scheduler.Shutdown().Wait();
        // 其他邏輯...  
    }  
}