c# 實現Quartz任務調度

来源:https://www.cnblogs.com/ouyangkai/p/18128298
-Advertisement-
Play Games

使用 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();
        // 其他邏輯...  
    }  
}

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

-Advertisement-
Play Games
更多相關文章
  • MySQL Ruler mysql 日常開發規範
    拓展閱讀 MySQL View MySQL truncate table 與 delete 清空表的區別和坑 MySQL Ruler mysql 日常開發規範 MySQL datetime timestamp 以及如何自動更新，如何實現範圍查詢 MySQL 06 mysql 如何實現類似 oracl ...
  • 又一款低代碼生成器
    maku-generator —— 一款低代碼生成器，可根據自定義模板內容，快速生成前後端代碼，可實現項目的快速開發、上線，減少重覆的代碼編寫，開發人員只需專註業務邏輯即可。 ...
  • 開源相機管理庫Aravis常式學習（一）——單幀採集single-acquisition
    目錄簡介源碼函數說明arv_camera_newarv_camera_acquisitionarv_camera_get_model_namearv_buffer_get_image_widtharv_buffer_get_image_height 簡介 本文針對官方常式中的第一個常式：single ...
  • DDD領域設計理解
    DDD 領域驅動設計理解（Domain Driven Design） 目錄DDD 領域驅動設計理解（Domain Driven Design）概念核心目標 概念 領域驅動設計事實上是1針對OOAD的一個擴展和延申。DDD基於面向對象分析與設計技術。 對技術架構進行了分層規劃。 對每個類進行了策略和劃 ...
  • 從零開始學Spring Boot系列-外部化配置
    Spring Boot 允許你將配置外部化，以便可以在不同的環境中使用相同的應用程式代碼。可以使用屬性文件、YAML文件、環境變數和命令行參數將配置外部化。屬性值可以通過使用 @Value 註解直接註入 bean，可以通過 Spring 的 Environment 抽象訪問，也可以通過 @Confi... ...
  • IDEA、PyCharm、CLion 等 Intellij 全家桶各版本（含最新））永久激活教程
    永久激活支持全家桶所有軟體，包括 Pycharm、IDEA、WebStorm、Phpstorm、Datagrip、RubyMine、CLion、AppCode 下麵以 Intellij IDEA 作為演示。 準備工作：下載插件包 https://qweree.cn/index.php/259/（如果 ...
  • Python基於Excel數據加以反距離加權空間插值並掩膜圖層
    本文介紹基於Python中ArcPy模塊，實現Excel數據讀取並生成矢量圖層，同時進行IDW插值與批量掩膜的方法。 1 任務需求 首先，我們來明確一下本文所需實現的需求。 現有一個記錄有北京市部分PM2.5濃度監測站點在2019年05月18日00時至23時（其中不含19時）等23個逐小時PM2.5 ...
  • C#的AOP（最經典實現）
    (適用於.NET/.NET Core/.NET Framework) 【目錄】0.前言1.第一個AOP程式2.Aspect橫切麵編程3.一個橫切麵程式攔截多個主程式4.多個橫切麵程式攔截一個主程式5.AOP的泛型處理（擴充）6.AOP的非同步處理（擴充）7.優勢總結8.展望 0.前言 AOP（Aspe ...
一周排行
    -Advertisement-
    Play Games
  • 如何基於surging跨網關跨語言進行緩存降級
    基於.NET Framework 4.8 開發的深度學習模型部署測試平臺，提供了YOLO框架的主流系列模型，包括YOLOv8~v9，以及其系列下的Det、Seg、Pose、Obb、Cls等應用場景，同時支持圖像與視頻檢測。模型部署引擎使用的是OpenVINO™、TensorRT、ONNX runti... ...
  • 十年沉澱，重啟開發之路
    十年沉澱，重啟開發之路 十年前，我沉浸在開發的海洋中，每日與代碼為伍，與演算法共舞。那時的我，滿懷激情，對技術的追求近乎狂熱。然而，隨著歲月的流逝，生活的忙碌逐漸占據了我的大部分時間，讓我無暇顧及技術的沉澱與積累。 十年間，我經歷了職業生涯的起伏和變遷。從初出茅廬的菜鳥到逐漸嶄露頭角的開發者，我見證了 ...
  • C#.NET體系圖文概述—2024最全總結
    C# 是一種簡單、現代、面向對象和類型安全的編程語言。.NET 是由 Microsoft 創建的開發平臺，平臺包含了語言規範、工具、運行，支持開發各種應用，如Web、移動、桌面等。.NET框架有多個實現，如.NET Framework、.NET Core（及後續的.NET 5+版本），以及社區版本M... ...
  • 班級擂臺（光榮）榜 - 極簡教育小工具
    前言 本文介紹瞭如何使用三菱提供的MX Component插件實現對三菱PLC軟元件數據的讀寫，記錄了使用電腦模擬，模擬PLC，直至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1. PLC開發編程環境GX Works2，GX Works2下載鏈接 https:// ...
  • web server apache tomcat11-31-websocket
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • day31-jQuery
    1、jQuery介紹 jQuery是什麼 jQuery是一個快速、簡潔的JavaScript框架，是繼Prototype之後又一個優秀的JavaScript代碼庫（或JavaScript框架）。jQuery設計的宗旨是“write Less，Do More”，即倡導寫更少的代碼，做更多的事情。它封裝 ...
  • aardio爬蟲) 實戰篇：逆向有道翻譯web介面
    前言 之前的文章把js引擎(aardio封裝庫) 微軟開源的js引擎(ChakraCore))寫好了，這篇文章整點js代碼來測一下bug。測試網站：https://fanyi.youdao.com/index.html#/ 逆向思路 逆向思路可以看有道翻譯js逆向（MD5加密，AES加密）附完整源碼 ...
  • 面試官：這就是你理解的Java多線程基礎？
    引言 現代的操作系統（Windows，Linux，Mac OS）等都可以同時打開多個軟體（任務），這些軟體在我們的感知上是同時運行的，例如我們可以一邊瀏覽網頁，一邊聽音樂。而CPU執行代碼同一時間只能執行一條，但即使我們的電腦是單核CPU也可以同時運行多個任務，如下圖所示，這是因為我們的 CPU 的 ...
  • Python文本統計與分析從基礎到進階
    掌握使用Python進行文本英文統計的基本方法，並瞭解如何進一步優化和擴展這些方法，以應對更複雜的文本分析任務。 ...
  • Redis多數據源，看這篇就夠了
    背景 Redis多數據源常見的場景： 分區數據處理：當數據量增長時，單個Redis實例可能無法處理所有的數據。通過使用多個Redis數據源，可以將數據分區存儲在不同的實例中，使得數據處理更加高效。 多租戶應用程式：對於多租戶應用程式，每個租戶可以擁有自己的Redis數據源，以確保數據隔離和安全性。 ...
所有分類