C#基於Quartz.NET實現任務調度並部署Windows服務

来源:https://www.cnblogs.com/wzh5959/archive/2019/10/15/11678938.html
-Advertisement-
Play Games

一、Quartz.NET介紹 Quartz.NET是一個強大、開源、輕量的作業調度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改寫,可用於winform和asp.net mvc、.Net Core應用中。它靈活而不複雜。你能夠用它來為執行一個作業而創建簡單的或 ...


一、Quartz.NET介紹

Quartz.NET是一個強大、開源、輕量的作業調度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改寫,可用於winform和asp.net mvc、.Net Core應用中。它靈活而不複雜。你能夠用它來為執行一個作業而創建簡單的或複雜的作業調度。它有很多特征,如:資料庫支持,集群,插件,支持cron-like表達式等等。

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

源碼:https://github.com/quartznet/quartznet

二、Quartz.NET用途

 一,可以定時發郵件通知。 

二 , 電商網站的定時打折活動。(比如規定11月11日 淘寶購買女朋友打八折)

三, 定時對數據更新 或者添加。

四,自己朋友生日。 可以定時發生日祝福。 等等 (我也不一一舉例了) 

三、Quartz.NET安裝

我使用的VS版本是2017的  選擇工具  - NuGet包管理 - 管理解決方案的NuGet包   輸入 Quartz.NET 安裝

還可以通過NuGet控制台 通過安裝命令  

Install-Package Quartz

四、Quartz.NET實現思路

一:繼承並實現IJob介面,在Execute 方法中寫你要定時執行的事情(切記 )

二:使用Quartz創建任務調度核心代碼步驟

  1、配置Quartz,創建工廠,開啟調度。

  2、創建工作任務

  3、創建觸發器

  4、將任務加入到任務池

三:添加任務,使用Topshelf部署Windows服務,定時執行

五、代碼步驟講解

  一:繼承並實現IJob介面,在Execute 方法中寫你要做的事情(切記 )

   

 1 using Quartz.Utility;
 2 using System;
 3 using System.IO;
 4 using System.Threading.Tasks;
 5 
 6 namespace Quartz.JobWork
 7 {
 8     public class MyJob : IJob
 9     {
10         public Task Execute(IJobExecutionContext context)
11         {
12             Task task = null;
13             try
14             {
15                 string fileName = "printlog.txt";
16                 StreamWriter writer = new StreamWriter(fileName, true);
17                 task = writer.WriteLineAsync(string.Format("{0},測試", DateTime.Now.ToLongTimeString()));
18                 writer.Close();
19                 writer.Dispose();
20             }
21             catch (Exception ex)
22             {
23                 LogHelper.WriteLog(ex.Message.ToString(), ex);
24             }
25             return task;
26         }
27     }
28 }

 

二:使用Quartz創建任務調度核心代碼步驟

註:這裡提供一個QuartzHelper幫助類,直接把以下代碼copy過去即可用,只需要重寫Execute方法即可。Quartz3.0及以上的版本是採用的非同步,3.0以下的版本沒有採用非同步,使用方法是一樣的

 1 using Quartz.Impl;
 2 using System;
 3 using System.Collections.Generic;
 4 using System.Collections.Specialized;
 5 using System.Linq;
 6 using System.Text;
 7 using System.Threading;
 8 using System.Threading.Tasks;
 9 
10 namespace Quartz.Utility
11 {
12     public class QuartzHelper
13     {
14         static readonly IScheduler _scheduler;
15         static QuartzHelper()
16         {
17             var properties = new NameValueCollection();
18             // 設置線程池
19             properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
20             //設置線程池的最大線程數量
21             properties["quartz.threadPool.threadCount"] = "5";
22             //設置作業中每個線程的優先順序
23             properties["quartz.threadPool.threadPriority"] = ThreadPriority.Normal.ToString();
24 
25             // 遠程輸出配置
26             properties["quartz.scheduler.exporter.type"] = "Quartz.Simpl.RemotingSchedulerExporter, Quartz";
27             properties["quartz.scheduler.exporter.port"] = "555";  //配置埠號
28             properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";
29             properties["quartz.scheduler.exporter.channelType"] = "tcp"; //協議類型
30 
31             //創建一個工廠
32             var schedulerFactory = new StdSchedulerFactory(properties);
33             //啟動
34             _scheduler = schedulerFactory.GetScheduler().Result;
35             //1、開啟調度
36             _scheduler.Start();
37         }
38         /// <summary>
39         /// 時間間隔執行任務
40         /// </summary>
41         /// <typeparam name="T">任務類,必須實現IJob介面</typeparam>
42         /// <param name="seconds">時間間隔(單位:秒)</param>
43         public static async Task<bool> ExecuteInterval<T>(int seconds) where T : IJob
44         {
45             //2、創建工作任務
46             IJobDetail job = JobBuilder.Create<T>().Build();
47             // 3、創建觸發器
48             ITrigger trigger = TriggerBuilder.Create()
49            .StartNow()
50            .WithSimpleSchedule(
51                 x =>x.WithIntervalInSeconds(seconds)
52                 //x.WithIntervalInMinutes(1)
53                 .RepeatForever())
54            .Build();
55             //4、將任務加入到任務池
56             await _scheduler.ScheduleJob(job, trigger);
57             return true;
58         }
59 
60         /// <summary>
61         /// 指定時間執行任務
62         /// </summary>
63         /// <typeparam name="T">任務類,必須實現IJob介面</typeparam>
64         /// <param name="cronExpression">cron表達式,即指定時間點的表達式</param>
65         public static async Task<bool> ExecuteByCron<T>(string cronExpression) where T : IJob
66         {
67             //2、創建工作任務
68             IJobDetail job = JobBuilder.Create<T>().Build();
69             //3、創建觸發器
70             ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create()
71             .StartNow()
72             .WithCronSchedule(cronExpression)
73             .Build();
74             //4、將任務加入到任務池
75             await _scheduler.ScheduleJob(job, trigger);
76             return true;
77         }
78     }
79 }

 

 三:添加任務,Topshelf部署Windows服務,定時執行

 1 namespace Quartz
 2 {
 3     public class Program
 4     {
 5         static void Main(string[] args)
 6         {
 7             string cronExpression = "0 0 8,23 * * ? ";  //=>這是指每天的9點和16點執行任務
 8             cronExpression = "30 0/1 * * * ?";
 9             //QuartzHelper.ExecuteByCron<MyJob>(cronExpression).Wait();  //=>這是調用Cron計劃方法
10             QuartzHelper.ExecuteInterval<MyJob>(180).Wait();
11             /*
12              簡單說一下Cron表達式吧,
13 
14             由7段構成:秒 分 時 日 月 星期 年(可選)
15  
16             "-" :表示範圍  MON-WED表示星期一到星期三
17             "," :表示列舉 MON,WEB表示星期一和星期三
18             "*" :表是“每”,每月,每天,每周,每年等
19             "/" :表示增量:0/15(處於分鐘段裡面) 每15分鐘,在0分以後開始,3/20 每20分鐘,從3分鐘以後開始
20             "?" :只能出現在日,星期段裡面,表示不指定具體的值
21             "L" :只能出現在日,星期段裡面,是Last的縮寫,一個月的最後一天,一個星期的最後一天(星期六)
22             "W" :表示工作日,距離給定值最近的工作日
23             "#" :表示一個月的第幾個星期幾,例如:"6#3"表示每個月的第三個星期五(1=SUN...6=FRI,7=SAT)
24  
25             如果Minutes的數值是 '0/15' ,表示從0開始每15分鐘執行
26  
27             如果Minutes的數值是 '3/20' ,表示從3開始每20分鐘執行,也就是‘3/23/43’
28             */
29             HostFactory.Run(x =>
30             {
31                 x.UseLog4Net();
32                 //x.Service<TownCrier>(s =>                        
33                 //{
34                 //    s.ConstructUsing(name => new TownCrier());    
35                 //    s.WhenStarted(tc => tc.Start());              
36                 //    s.WhenStopped(tc => tc.Stop());               
37                 //});
38                 x.RunAsLocalSystem();
39                 x.SetDescription("QuartzJob任務定時發送");
40                 x.SetDisplayName("QuartzJob");
41                 x.SetServiceName("QuartzJob");
42 
43                 x.EnablePauseAndContinue();
44             });
45             Console.ReadKey();
46         }
47     }
48 }

 

  最後就可以做自己想要做的事情了!

   下期講解使用Topshelf部署Windows服務!

 


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

-Advertisement-
Play Games
更多相關文章
  • Python學習筆記(四)—— 程式的控制結構 一、程式的控制結構分類 二、程式的分支結構 1、分類 1.1 單分支結構 單分支示例: 1.2 二分支結構 二分支示例: 二分支的緊湊形式: 1.3 多分支結構 多分支舉例: 2、條件判斷及組合 2.1 條件判斷 2.2 條件組合 條件判斷及組合示例: ...
  • 目錄導引: 一、原碼、反碼、補碼 二、位運算 一、原碼、反碼、補碼 電腦只有加法運算器,計算器中存儲、計算數據都是補碼,正數和0的原碼、反碼、補碼相同,負數的原碼、反碼、補碼不同。 原碼:符號位+絕對值(0表示正數,1表示負數) 反碼:符號位不變,其餘位取反 補碼:反碼+1 1、為什麼要用補碼存儲 ...
  • springboot springboot使你可以輕鬆創建獨立的、基於生產級別的的spring的項目。 You can "just run". 約定大於配置。 快速啟動 Spring Initializr 打包運行 1. maven package 打成jar包 tomcat已經集成於springb ...
  • 強烈建議大家從官網下載nmap,而不是其他的第三方。官網地址:https://nmap.org/download.html 打開是這樣的,感覺有點陰森森的色調。BTW,誰能逃得過真香定律呢。 windows 安裝 直接選擇下載這個exe安裝包即可,然後選擇逐步安裝。安裝過程中需要安裝Npcap和VC ...
  • 1、什麼事面向對象?主要特征是什麼?面向對象是程式的一種設計方式,它利於提高程式的重用性,使程式結構更加清晰。主要特征:封裝、繼承、多態。2、SESSION 與 COOKIE的區別是什麼,請從協議,產生的原因與作用說明?A、http無狀態協議,不能區分用戶是否是從同一個網站上來的,同一個用戶請求不同 ...
  • 點這裡進入ABP進階教程目錄 效果預覽 至此,ABP進階教程的查詢/分頁/排序/導出/列印示例已完成,效果如下 登錄 首頁 辦公室信息 院系信息 課程信息 教職員信息 學生信息 新增 修改 刪除 查詢 複製 導出 列印 敬請期待下一個系列. ...
  • 點這裡進入ABP進階教程目錄 問題描述 功能按鈕 - 導出PDF,中文信息導出為亂碼。 解決方案 導出PDF是通過pdfmake.js實現的。 檢查發現是pdfmake引用的vfs_fonts.js字體只有一種: Roboto,而Roboto不支持中文。 解決思路是生成一個包含支持中文字體的vfs_ ...
  • 點這裡進入ABP進階教程目錄 問題描述 功能按鈕 - 導出CSV,中文信息導出為亂碼。 解決方案 打開展示層(即JD.CRS.Web.Mvc)的\wwwroot\view-resources\Views\Course\Index.js //用以存放Course查詢相關腳本 找到DataTable/b ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...