Quartz3.0定時任務學習之非同步排程器

阿新 • • 發佈：2020-05-21

前言

Quartz3與Quartz2的主要區別有兩點：

1，Quartz3將它的資源類庫拆的更細了，比如，想使用Quartz3開發，最少要引用Quartz，Quartz.Jobs，Quartz.Plugins這三個類庫。

2，Quartz3整體上使用的是非同步建立例項，所以我們使用時就必須要async，await的語法。

下面我們用Quartz3來做一個任務排程。

建立排程器管理類

首先建立Jops類庫，然後在Nuget中搜索Quartz.Plugins；如下圖：

因為Quartz.Plugins依賴於Quartz，所以引入Quartz.Plugins就會自動引入Quartz。

然後我們建立任務排程管理類—ScheduleControler。程式碼如下：

public class ScheduleControler

{
    private static IScheduler scheduler;
    private static Dictionary<IJobDetail, IReadOnlyCollection<ITrigger>> dicJop = new Dictionary<IJobDetail, IReadOnlyCollection<ITrigger>>();
    
    private static int triggerId = 0;
    private static string defaultGroupName = "預設組";
    /// <summary>
    /// 初始化排程器
    /// </summary>
    /// <returns></returns>
    public static async Task Init()
    {
        try
        {
            //quartz.config配置檔案裡的鍵值對
            //NameValueCollection props = new NameValueCollection
            //{
            //   { "quartz.serializer.type", "binary" }
            //};
            StdSchedulerFactory factory = new StdSchedulerFactory(); 
            scheduler = await factory.GetScheduler(); 
            await scheduler.Start(); 
        }
        catch (SchedulerException se)
        {
            System.Console.WriteLine(se);
        }
    }
    /// <summary>
    /// 執行排程器任務
    /// </summary>
    /// <returns></returns>
    public static async Task Run()
    {
        try
        {
            await scheduler.ScheduleJobs(dicJop, true);

        }
        catch (SchedulerException se)
        {
            System.Console.WriteLine(se);
        }
    }
    /// <summary>
    /// 關閉排程器
    /// </summary>
    /// <returns></returns>
    public static async Task Shutdown()
    {
        try
        { 
            await scheduler.Shutdown(); 

        }
        catch (SchedulerException se)
        {
            System.Console.WriteLine(se);
        }
    }
    /// <summary>
    /// 新增任務
    /// </summary>
    /// <typeparam name="T">任務型別，繼承Ijop</typeparam>
    /// <param name="jopName">任務名</param>
    /// <param name="Interval">執行間隔時間/秒**最小為1秒</param>
    /// <param name="period">等待啟動時間/秒**-1為馬上啟動</param>
    /// <param name="repeatTime">重複次數**-1為永遠執行</param>
    /// <param name="endAt">在指定時間後結束/秒**0為不指定結束時間，預設值0</param>
    public static void PushJop<T>(string jopName, int Interval, int period=-1,int repeatTime=-1,int endAt=0)  where T:IJob
        {
            try
            {
                if (Interval <= 0)
                {
                    Interval = 1;
                }
                if (period < -1)
                {
                    period = -1;
                }
                if (repeatTime < -1)
                {
                    repeatTime = -1;
                } 
                if (endAt < 0)
                {
                    endAt = -1;
                }
                IJobDetail job = JobBuilder.Create<T>().WithIdentity(jopName, defaultGroupName).UsingJobData("Name", "IJobDetail").Build();
            
                var triggerBuilder  = TriggerBuilder.Create().WithIdentity($"{jopName}.trigger{triggerId}", defaultGroupName);
                if (period == -1)
                {
                    triggerBuilder = triggerBuilder.StartNow();
                }
                else
                {
                    DateTimeOffset dateTimeOffset = DateTimeOffset.Now.AddSeconds(period);
                    triggerBuilder = triggerBuilder.StartAt(dateTimeOffset);
                }
                if (endAt > 0)
                {
                    triggerBuilder = triggerBuilder.EndAt(new DateTimeOffset(DateTime.Now.AddSeconds(endAt)));
                }  

                if (repeatTime == -1)
                {
                    triggerBuilder = triggerBuilder.WithSimpleSchedule(x => x.WithIntervalInSeconds(Interval).RepeatForever());  
                }
                else
                {
                    triggerBuilder = triggerBuilder.WithSimpleSchedule(x => x.WithRepeatCount(Interval).WithRepeatCount(repeatTime));
                }
                ITrigger trigger = triggerBuilder.UsingJobData("Name", "ITrigger")
                     .WithPriority(triggerId)//設定觸發器優先順序,當有多個觸發器在相同時間出發時,優先順序最高[數字最大]的優先
                     .Build(); 

                dicJop.Add(job, new HashSet<ITrigger>() { trigger }); 
                triggerId++; 
            }
            catch (SchedulerException se)
            {
                System.Console.WriteLine(se);
            }
        }

    public static void PushJop<T>(string jopName, string cronExpress) where T : IJob
    {
        try
        { 
            IJobDetail job = JobBuilder.Create<T>().WithIdentity(jopName, defaultGroupName).UsingJobData("Name", "IJobDetail").Build(); 
            ITrigger trigger = TriggerBuilder.Create()
               .WithIdentity($"{jopName}.trigger{triggerId}", defaultGroupName)
               .WithCronSchedule(cronExpress)
               .ForJob(job)
               .Build(); 
            dicJop.Add(job, new HashSet<ITrigger>() { trigger });
            triggerId++;
        }
        catch (SchedulerException se)
        {
            System.Console.WriteLine(se);
        }
    } 
}

可以看到排程器管理類中包含四個主要函式，如下：

執行排程器任務(Run)

初始化排程器(Init)

關閉排程器(Shutdown)

新增任務(PushJop)

應用程式通過這四個函式的呼叫，就可以使用Quartz了。

新增配置檔案

quartz.config

quartz.config是排程器工廠StdSchedulerFactory的配置檔案，我們可以在初始化排程器時配置，但顯然在配置檔案裡設定更易於修改。

quartz.config內容如下：

# You can configure your scheduler in either <quartz> configuration section
# or in quartz properties file
# Configuration section has precedence

quartz.scheduler.instanceName = QuartzTest

# configure thread pool info
quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal

# job initialization plugin handles our xml reading, without it defaults are used
quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins
#指定quartz_jobs.xml路徑
#quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

# export this server to remoting context 使用CrystalQuartz 放開如下注釋
quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz
quartz.scheduler.exporter.port = 555
quartz.scheduler.exporter.bindName = QuartzScheduler
quartz.scheduler.exporter.channelType = tcp
quartz.scheduler.exporter.channelName = httpQuartz

如果在初始化時配置，參考如下程式碼：

NameValueCollection props = new NameValueCollection
{
   { "quartz.serializer.type", "binary" }
};
StdSchedulerFactory factory = new StdSchedulerFactory(props);

quartz_jobs.xml

quartz_jobs.xml是任務配置檔案，用於配置任務的。不過本文的排程器管理類已經通過的PushJop函式對任務進行了配置，所以就不需要在quartz_jobs.xml檔案中配置了，不過為了測試方便，我們還是新增一個quartz_jobs.xml檔案，因為quartz.config檔案中指定配置了quartz_jobs.xml，所以沒有它會異常。

這裡我們新增一個空的quartz_jobs.xml檔案，如下：

<?xml version="1.0" encoding="UTF-8"?>
<!-- This file contains job definitions in schema version 2.0 format -->
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
  <processing-directives>
    <overwrite-existing-data>true</overwrite-existing-data>
  </processing-directives> 
  <schedule> 
  </schedule>
</job-scheduling-data>

建立任務

建立一個任務類(Jop)用於處理業務操作，任務類需繼承IJop介面，程式碼如下。

 public class HelloJob : IJob
 {
     public async Task Execute(IJobExecutionContext context)
     {
         Task task = new Task(() => {
             LogicMethod(context);
         });
         task.Start();
         await task;
     }
     public void LogicMethod(IJobExecutionContext context)
     {
         Console.Out.WriteLine($"HelloJob DateTime:{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}  Key:{context.JobDetail.Key} ");
     } 
 }

測試Quartz

建立一個新控制檯專案—QuartzNetTest，引入Jops類庫和Quartz.Plugins。

然後修改Main函式，配置HelloJob任務每三秒執行一次，如下：

static void Main(string[] args)
{
    ScheduleControler.Init().GetAwaiter().GetResult();
    ScheduleControler.PushJop<HelloJob>("HelloWord", 3);
    ScheduleControler.Run().GetAwaiter().GetResult();
    var info = Console.ReadKey();
    if (info.Key == ConsoleKey.Enter)
    {
        ScheduleControler.Shutdown().GetAwaiter().GetResult();
        Console.WriteLine("結束");
    }
    Console.Read();
}

執行專案，如下圖：

Quartz執行成功。

Quartz工作管理員

QuartzNet除了定時執行任務，還提供了工作管理員。下面我們一起新建一個Quartz的任務管理。

建立一個空的Web專案——QuartzNetWebManager。

新增依賴類庫

Nuget搜尋CrystalQuartz.Remote安裝。

再搜尋Quartz安裝，注意這裡安裝的Quartz不是Quartz.Plugins。

這樣Quartz的任務管理就建立完成了。

然後我們開啟WebConfig，可以看到configuration下多了一個crystalQuartz節點，webServer下多了一個handlers，閱讀配置檔案，發現Quartz的工作管理員指定了網頁CrystalQuartzPanel.axd為訪問地址，。

WebConfig如下：

<crystalQuartz>
    <provider>
      <add property="Type" value="CrystalQuartz.Core.SchedulerProviders.RemoteSchedulerProvider, CrystalQuartz.Core" />
      <!-- Edit scheduler host value below =================================== -->
      <add property="SchedulerHost" value="tcp://localhost:555/QuartzScheduler" />
      <!--                                 =================================== -->
    </provider>
</crystalQuartz>
<system.webServer>
    <handlers>
      <add name="CrystalQuartzPanel" verb="*" path="CrystalQuartzPanel.axd" type="CrystalQuartz.Web.PagesHandler, CrystalQuartz.Web" />
    </handlers>
  </system.webServer>

訪問網址https://localhost:44302/CrystalQuartzPanel.axd，管理介面如下：

可以看到管理器中除了顯示當前執行的任務，還提供刪除任務，馬上執行等等功能；非常方便。

當然，Quartz還有很多功能，我們可以去官網學習。

QuartzNet官網：https://www.quartz-scheduler.net/

----------------------------------------------------------------------------------------------------

程式碼已經傳到Github上了，歡迎大家下載。

Github地址：https://github.com/kiba518/QuartzTest

----------------------------------------------------------------------------------------------------

注：此文章為原創，任何形式的轉載都請聯絡作者獲得授權並註明出處！
若您覺得這篇文章還不錯，請點選下方的【推薦】，非常感謝！

https://www.cnblogs.com/kiba/p/12794928.html

Quartz3.0定時任務學習之非同步排程器

Quartz3.0定時任務學習之非同步排程器

安卓開發學習之非同步任務原始碼閱讀

1.4- 定時任務總結之九句箴言

asp.net core 2.0 定時任務

0基礎統計學學習之路----概率論基礎2

0基礎統計學學習之路----隨機變數的分佈

thinkphp 定時任務學習筆記

spring（springboot）利用註解實現定時任務並實現非同步處理

swoole學習之非同步檔案IO

Spring Boot 使用Actitivi 6.0 定時任務

微信傳送百萬模板訊息swoole 定時任務不能非同步task問題

1.0 安卓學習之開始啟程

Quartz定時任務SimpleTrigger：任務、觸發器和排程器

gradle環境變數的配置3.0版(gradle學習之路一)

FPGA學習之蜂鳴器演奏樂曲

Python學習之路-裝飾器&生成器&正則表達式

Python學習之迭代器和生成器

python學習之-迭代器

WebGL學習之從著色器入門

C++ STL學習之空間配置器(allocator)

Quartz3.0定時任務學習之非同步排程器

相關推薦