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
  • 概述:在C#中,++i和i++都是自增運算符,其中++i先增加值再返回,而i++先返回值再增加。應用場景根據需求選擇,首碼適合先增後用,尾碼適合先用後增。詳細示例提供清晰的代碼演示這兩者的操作時機和實際應用。 在C#中,++i 和 i++ 都是自增運算符,但它們在操作上有細微的差異,主要體現在操作的 ...
  • 上次發佈了:Taurus.MVC 性能壓力測試(ap 壓測 和 linux 下wrk 壓測):.NET Core 版本,今天計劃準備壓測一下 .NET 版本,來測試並記錄一下 Taurus.MVC 框架在 .NET 版本的性能,以便後續持續優化改進。 為了方便對比,本文章的電腦環境和測試思路,儘量和... ...
  • .NET WebAPI作為一種構建RESTful服務的強大工具,為開發者提供了便捷的方式來定義、處理HTTP請求並返迴響應。在設計API介面時,正確地接收和解析客戶端發送的數據至關重要。.NET WebAPI提供了一系列特性,如[FromRoute]、[FromQuery]和[FromBody],用 ...
  • 原因:我之所以想做這個項目,是因為在之前查找關於C#/WPF相關資料時,我發現講解圖像濾鏡的資源非常稀缺。此外,我註意到許多現有的開源庫主要基於CPU進行圖像渲染。這種方式在處理大量圖像時,會導致CPU的渲染負擔過重。因此,我將在下文中介紹如何通過GPU渲染來有效實現圖像的各種濾鏡效果。 生成的效果 ...
  • 引言 上一章我們介紹了在xUnit單元測試中用xUnit.DependencyInject來使用依賴註入,上一章我們的Sample.Repository倉儲層有一個批量註入的介面沒有做單元測試,今天用這個示例來演示一下如何用Bogus創建模擬數據 ,和 EFCore 的種子數據生成 Bogus 的優 ...
  • 一、前言 在自己的項目中,涉及到實時心率曲線的繪製,項目上的曲線繪製,一般很難找到能直接用的第三方庫,而且有些還是定製化的功能,所以還是自己繪製比較方便。很多人一聽到自己畫就害怕,感覺很難,今天就分享一個完整的實時心率數據繪製心率曲線圖的例子;之前的博客也分享給DrawingVisual繪製曲線的方 ...
  • 如果你在自定義的 Main 方法中直接使用 App 類並啟動應用程式,但發現 App.xaml 中定義的資源沒有被正確載入,那麼問題可能在於如何正確配置 App.xaml 與你的 App 類的交互。 確保 App.xaml 文件中的 x:Class 屬性正確指向你的 App 類。這樣,當你創建 Ap ...
  • 一:背景 1. 講故事 上個月有個朋友在微信上找到我,說他們的軟體在客戶那邊隔幾天就要崩潰一次,一直都沒有找到原因,讓我幫忙看下怎麼回事,確實工控類的軟體環境複雜難搞,朋友手上有一個崩潰的dump,剛好丟給我來分析一下。 二:WinDbg分析 1. 程式為什麼會崩潰 windbg 有一個厲害之處在於 ...
  • 前言 .NET生態中有許多依賴註入容器。在大多數情況下,微軟提供的內置容器在易用性和性能方面都非常優秀。外加ASP.NET Core預設使用內置容器,使用很方便。 但是筆者在使用中一直有一個頭疼的問題:服務工廠無法提供請求的服務類型相關的信息。這在一般情況下並沒有影響,但是內置容器支持註冊開放泛型服 ...
  • 一、前言 在項目開發過程中,DataGrid是經常使用到的一個數據展示控制項,而通常表格的最後一列是作為操作列存在,比如會有編輯、刪除等功能按鈕。但WPF的原始DataGrid中,預設只支持固定左側列,這跟大家習慣性操作列放最後不符,今天就來介紹一種簡單的方式實現固定右側列。(這裡的實現方式參考的大佬 ...