Quartz3.0定時任務學習之非同步調度器

来源:https://www.cnblogs.com/kiba/archive/2020/05/21/12794928.html

前言 Quartz3與Quartz2的主要區別有兩點: 1,Quartz3將它的資源類庫拆的更細了,比如,想使用Quartz3開發,最少要引用Quartz,Quartz.Jobs,Quartz.Plugins這三個類庫。 2,Quartz3整體上使用的是非同步創建實例,所以我們使用時就必須要async ...


前言

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

 

 


您的分享是我們最大的動力!

更多相關文章
  • 背景:我們的應用程式通常都是由多個程式集組成,例如一個 exe 程式依賴於多個 dll 程式集。在某些情況下,我們希望程式的分發能夠簡單,單獨一個 exe 就能正常運行。這種情況下,就需要將 dll 依賴項合併到 exe 主程式中。 本文章給大家講下非常好用的NuGet 包,Costura.Fody ...
  • 一、概述 在Window伺服器部署程式後,可能因為代碼的不合理或者其他各種各樣的問題,會導致CPU暴增,甚至達到100%等情況,嚴重危及到伺服器的穩定以及系統穩定,但是一般來說對於已發佈的程式,沒法即時看到出問題的代碼,而微軟提供了一個很好的工具“WinDbg”,使得我們能夠回溯問題。下麵講一下操作 ...
  • 前言, Blazor Assembly 需要最少 1.9M 的下載量. ( Blazor WebAssembly 船新項目下載量測試 , 僅供參考. ) 隨著程式越來越複雜, 引用的東西越來越多, 需要更多的下載量 , 有一些網站的網路可能較差, 載入這些文件需要一定的時間. 對於一些網站而言, 它 ...
  • 背景介紹:基於netcore2.2開發api介面程式,自定義了一個異常捕獲中間件,用於捕獲未經處理的異常以及狀態碼404、500等訪問(設計的出發點就是,出現了非200的響應,我這邊全部會進行處理成200,並返回固定格式的JSON格式數據),併進行統一的信息返回。 返回的JSON實體定義如下: 中間 ...
  • 前言: 昨天 Blazor WebAssembly 3.2 正式發佈了. 更新 VS2019後就能直接使用. 新建了兩個PWA項目, 一個不用asp.net core (靜態部署), 一個使用asp.net core (項目模板與伺服器交互) 其中下載量主要是預壓縮有沒有被使用 , 分別為 3.2M ...
  • 上一篇文章(https://www.cnblogs.com/meowv/p/12916613.html)使用自定義倉儲完成了簡單的增刪改查案例,有心的同學可以看出,我們的返回參數一塌糊塗,顯得很不友好。 在實際開發過程中,每個公司可能不盡相同,但都大同小異,我們的返回數據都是包裹在一個公共的模型下麵 ...
  • 現象: 用Microsoft.Office.Interop.Outlook取得日曆項,然後根據業務要求篩選。 items.Restrict方法中的篩選器,使用like進行模糊查詢時,會出COMException異常。 代碼: 1 //folder取得前略 2 3 Outlook.Items item ...
  • 單位的項目需要測溫,同事買了個海康威視的人體測溫機芯,型號位:TB 4117 3/S,給了一份pdf的說明書。 按說明書把設備連接設置好,從官網下載了sdk,我的個乖乖,壓縮包就有70多M,把他家的所有東西都給了我,有各種Demo,就是沒有測溫的,暈死,差點想打退堂鼓不玩了。 最後,最後得到如下成果 ...
一周排行
  • 一:背景 1. 講故事 曾今在項目中發現有同事自定義結構體的時候,居然沒有重寫Equals方法,比如下麵這段代碼: static void Main(string[] args) { var list = Enumerable.Range(0, 1000).Select(m => new Point ...
  • 最近一個朋友有個關於素數的小東西要寫一下,素數是什麼呢?除了1和他本身不能被其他數整除,那麼這個數就是素數,1除外哦。我們知道概念那就很簡單了,直接代碼擼起。 ...
  • 前言 在開發編程中,我們經常會遇到功能非常相似的功能模塊,只是他們的處理的數據不一樣,所以我們會分別採用多個方法來處理不同的數據類型。但是這個時候,我們就會想一個問題,有沒有辦法實現利用同一個方法來傳遞不同種類型的參數呢? 這個時候,泛型也就因運而生,專門來解決這個問題的。 泛型是在C 2.0就推出 ...
  • 本文章主要用於介紹在Asp.Net Mvc(C#)中使用Fleck製作一個Html5的即時聊天室,含有完整代碼和演示Demo。 ...
  • 出庫單的功能。能學習了出庫單管理之後,WMS的 主體功能算是完成了。當然一個成熟的WMS還包括了盤點,報表,策略規則,移庫功能及與其他系統(ERP、TMS等)的介面,實現無縫集成,打破信息孤島,讓數據實時、準確和同步。 ...
  • Data StructureThere're two types of variables in C#, reference type and value type.Enum:enum Color{Red=0,Green=1}//equals to enum Color{Red,//start fr... ...
  • 0. 前言 該項目使用Maven進行管理和構建,所以需要預先配置好Maven。嗯,在這個系列里就不做過多的介紹了。 1. 創建項目 先創建一個pom.xml 文件,添加以下內容: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http: ...
  • API 概述 API(Application Programming Interface),應用程式編程介面。 Java API是一本程式員的 字典 ,是JDK中提供給我們使用的類的說明文檔。 這些類將底層的代碼實現封裝了起來,我們不需要關心這些類是如何實現的,只需要學習這些類如何使用即可。 所以我 ...
  • 女程式員是這麼徵婚的: SELECT * FROM 男人們 WHERE 未婚=true and 同性戀=false and 有房=true and 有車=true and 條件 in (帥氣,紳士,大度,氣質,智慧,溫柔,體貼,會浪漫,活潑,可愛,最好還能帶孩子) and 年齡 between(24 ...
  • 有很多剛學習軟體測試的小伙伴,都會在網路上找尋各種學習資料,去提升自己的專業技能水平。因此,我決定定期分享我整理收集的一些軟體測試的測試工具下載、面試寶典、視頻教學合集。都整理好了,有需要的可以關註我(獲取方式在文末) 軟體測試的學習,不止是基礎理論,還需要學習測試工具的用法,如介面工具Postma ...