一、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服務!