Quartz.Net的基礎使用方法，多任務執行

前一篇隨筆講了Quartz單任務的簡單實現，這一篇我們來講講多任務的實現

Quartz.Net的基礎使用方法，單任務執行

主要看下面這段代碼，這是Quartz多任務調度的方法，主要就是圍繞這個方法去擴展：

//
// 摘要:
//     Schedule all of the given jobs with the related set of triggers.
//
// 言論：
//     If any of the given jobs or triggers already exist (or more specifically, if
//     the keys are not unique) and the replace parameter is not set to true then an
//     exception will be thrown.
Task ScheduleJobs(IReadOnlyDictionary<IJobDetail, IReadOnlyCollection<ITrigger>> triggersAndJobs, bool replace, CancellationToken cancellationToken = default);

1、首先我們建兩個任務類：

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

namespace HHF.Quartz
{
    public class Task_1 : IJob
    {
        public Task Execute(IJobExecutionContext context)
        {
            return Console.Out.WriteLineAsync($"這是任務一，執行時間：{DateTime.Now}");
        }
    }
}

2、改造一下之前的QuartzScheduler類，添加一個GetJobs方法，生成任務集合

/// <summary>
/// 很Low的一段代碼
/// </summary>
/// <returns></returns>
public List<IJobDetail> GetJobs()
{
   IJobDetail job1 = JobBuilder.Create<Task_1>()
            .WithIdentity("job1")
            .Build();
   IJobDetail job2 = JobBuilder.Create<Task_2>()
            .WithIdentity("job3")
            .Build();
   return new List<IJobDetail>() { job1, job2 };
}

3、改造一下Run方法

/// <summary>
/// 任務調度的使用過程
/// </summary>
/// <returns></returns>
public async static Task Run()
{
    // 創建scheduler的引用
    ISchedulerFactory schedFact = new StdSchedulerFactory();
    IScheduler sched = await schedFact.GetScheduler();

    // 獲取job集合
    var jobs = GetJobs();
    // 申明一個任務與觸發器映射的字典集合
    var jobAndTriggerMapping = new Dictionary<IJobDetail, IReadOnlyCollection<ITrigger>>();
    // 遍歷任務列表
    for (int i = 0; i < jobs.Count; i++)
    {
        var job = jobs[i];
        // 只讀的觸發器集合
        var triggers = new ReadOnlyCollection<ITrigger>(
            new List<ITrigger>()
            {
                TriggerBuilder.Create()
                    .WithIdentity("trigger_"+i)
                    .WithSimpleSchedule(x => x.WithIntervalInSeconds(i+5).RepeatForever())
                    .Build()
            });
        // 建立映射關系
        jobAndTriggerMapping[job] = triggers;
    }
    // 將映射關系包裝成制度字典集合
    var readOnlyjobAndTriggerMapping = new ReadOnlyDictionary<IJobDetail, IReadOnlyCollection<ITrigger>>(jobAndTriggerMapping);

    /* 
     * 使用trigger規划執行任務job
     *第二個參數replace：如果為true，則指定的觸發器或者任務名稱已經存在將會替換，否則將拋出異常
     */
    await sched.ScheduleJobs(readOnlyjobAndTriggerMapping, true);

    // 啟動 scheduler
    await sched.Start();
}

4、查看執行結果，我們可以看到，任務一的執行間隔時間為5秒，任務二的執行間隔時間為6秒，可以正常執行。