在實際的專案中，常遇到延時觸發作業以及定時觸發作業
這里所講的是借助第三方的組件 Quartz.Net 來實作（原始碼位置：https://github.com/quartznet/quartznet）
實作思路（來自博友wuzh）
一：繼承并實作IJob介面，在Execute 方法中寫你要定時執行的事情（切記 ）
二：使用Quartz創建任務調度核心代碼步驟
1、配置Quartz，創建工廠，開啟調度，
2、創建作業任務
3、創建觸發器
4、將任務加入到任務池
Demo 創建控制臺應用程式，定時發送郵件以及延時寫日志
1 在vs2015中使用Nuget，獲取Quartz
2 創建兩個作業
/// <summary> /// 繼承并實作IJob介面，在Execute 方法中寫你要定時執行的事情（切記 ） /// </summary> public class MyJob : IJob { public Task Execute(IJobExecutionContext context) { Task task = null; try { string fileName = "printlog.txt"; using (StreamWriter writer = new StreamWriter(fileName, true)) { task = writer.WriteLineAsync(string.Format("{0},測驗", DateTime.Now.ToLongTimeString())); Console.WriteLine(string.Format("{0},測驗", DateTime.Now.ToLongTimeString())); } } catch (Exception) { } return Task.CompletedTask; } } /// <summary> /// 發郵件 /// </summary> public class SendEmailJob : IJob { public Task Execute(IJobExecutionContext context) { //Smtp sendEmail.SendMailUseGmail("[email protected]", "[email protected]", "terryK", "Quartz.net定時作業", "Quartz.net定時發送郵件", "tiyklkinqanxbgXX", 587, "smtp.qq.com", true); return Task.CompletedTask; } } public class sendEmail { public static Task SendMailUseGmail(string toUserAddress, string fromUserAddress, string fromUserName, string contextName, string context, string fromUserPass, int port, string host, bool sslState) { using (MailMessage mailMessage = new MailMessage()) { mailMessage.To.Add(toUserAddress); mailMessage.From = new MailAddress(fromUserAddress, fromUserName, Encoding.UTF8); mailMessage.Subject = contextName; mailMessage.SubjectEncoding = Encoding.UTF8; mailMessage.Body = context; mailMessage.BodyEncoding = Encoding.UTF8; mailMessage.IsBodyHtml = false; mailMessage.Priority = MailPriority.High; SmtpClient smtpClient = new SmtpClient(); smtpClient.Credentials = new NetworkCredential(fromUserAddress, fromUserPass); smtpClient.Port = port; smtpClient.Host = host; smtpClient.EnableSsl = sslState; try { smtpClient.Send(mailMessage); Console.WriteLine("發送成功，請查看"); } catch (SmtpException var_3_A8) { Console.WriteLine(var_3_A8.ToString()); } } return Task.CompletedTask; } }
3 創建QuartzHelper，用于配置環境以及完成 IScheduler, IJobDetails 與 ITrigger之間的配置
public class QuartzHelper { static readonly IScheduler _scheduler; static QuartzHelper() { #region 配置 Quartz NameValueCollection properties = new NameValueCollection { {"quartz.serializer.type","binary"} }; // 設定執行緒池 properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz"; //設定執行緒池的最大執行緒數量 properties["quartz.threadPool.threadCount"] = "10"; //設定作業中每個執行緒的優先級 properties["quartz.threadPool.threadPriority"] = ThreadPriority.Normal.ToString(); // 遠程輸出配置 properties["quartz.scheduler.exporter.type"] = "Quartz.Simpl.RemotingSchedulerExporter, Quartz"; properties["quartz.scheduler.exporter.port"] = "555"; //配置埠號 properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler"; properties["quartz.scheduler.exporter.channelType"] = "tcp"; //協議型別 #endregion //創建一個工廠 var schedulerFactory = new StdSchedulerFactory(properties); //啟動 _scheduler = schedulerFactory.GetScheduler().Result; //1、開啟調度 _scheduler.Start(); } /// <summary> /// 時間間隔執行任務 /// </summary> /// <typeparam name="T">任務類，必須實作IJob介面</typeparam> /// <param name="seconds">時間間隔(單位：秒)</param> public static async Task AsyncExecuteInterval<T>(int seconds) where T : IJob { //2、創建作業任務 IJobDetail job = JobBuilder.Create<T>() .WithIdentity("printlog", "LogGroup") .Build(); // 3、創建觸發器 ITrigger trigger = TriggerBuilder.Create() .StartNow() .WithIdentity("LogTrigger", "LogGroup") .WithSimpleSchedule(x => x.WithIntervalInSeconds(seconds).RepeatForever()) .Build(); //4、將任務加入到任務池 await _scheduler.ScheduleJob(job, trigger); } /// <summary> /// 指定時間執行任務 /// </summary> /// <typeparam name="T">任務類，必須實作IJob介面</typeparam> /// <param name="cronExpression">cron運算式，即指定時間點的運算式</param> public static async Task<bool> AsyncExecuteByCron<T>(string cronExpression) where T : IJob { //2、創建作業任務 IJobDetail job = JobBuilder.Create<T>() .WithIdentity("SendEmailJob", "EmailGroup") .Build(); //3、創建觸發器 ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create() .StartNow() .WithIdentity("SendEmail", "EmailGroup") .WithCronSchedule(cronExpression) .Build(); //4、將任務加入到任務池 await _scheduler.ScheduleJob(job, trigger); return true; } }
4 運行呼叫
public class Program { static void Main(string[] args) { Task.Run(() => { string cronExpression = "0 36 15,20 ? * MON-FRI"; // =>周一到周五 每天上午8：30以及下午8：30執行定時任務（發送郵件） QuartzHelper.AsyncExecuteByCron<SendEmailJob>(cronExpression).Wait(); });//=>這是呼叫Cron計劃方法 Task.Run(() => QuartzHelper.AsyncExecuteInterval<MyJob>(5).Wait()); /* 簡單說一下Cron運算式: 由7段構成：秒 分 時 日 月 星期 年（可選） "-" ：表示范圍 MON-WED表示星期一到星期三 "," ：表示列舉 MON,WEB表示星期一和星期三 "*" ：表是“每”，每月，每天，每周，每年等 "/" :表示增量：0/15（處于分鐘段里面） 每15分鐘，在0分以后開始，3/20 每20分鐘，從3分鐘以后開始 "?" :只能出現在日，星期段里面，表示不指定具體的值 "L" :只能出現在日，星期段里面，是Last的縮寫，一個月的最后一天，一個星期的最后一天（星期六） "W" :表示作業日，距離給定值最近的作業日 "#" :表示一個月的第幾個星期幾，例如："6#3"表示每個月的第三個星期五（1=SUN...6=FRI,7=SAT） 如果Minutes的數值是 '0/15' ，表示從0開始每15分鐘執行 如果Minutes的數值是 '3/20' ，表示從3開始每20分鐘執行，也就是‘3/23/43’ */ Console.ReadKey(); } }
5 整個Demo代碼
using Quartz; using Quartz.Impl; using System; using System.Collections.Generic; using System.Collections.Specialized; using System.IO; using System.Linq; using System.Net; using System.Net.Mail; using System.Text; using System.Threading; using System.Threading.Tasks; namespace Quartz { public class Program { static void Main(string[] args) { Task.Run(() => { string cronExpression = "0 30 8,20 ? * MON-FRI"; // =>周一到周五 每天上午8：30以及下午8：30執行定時任務（發送郵件） QuartzHelper.AsyncExecuteByCron<SendEmailJob>(cronExpression).Wait(); });//=>這是呼叫Cron計劃方法 Task.Run(() => QuartzHelper.AsyncExecuteInterval<MyJob>(5).Wait()); /* 簡單說一下Cron運算式: 由7段構成：秒 分 時 日 月 星期 年（可選） "-" ：表示范圍 MON-WED表示星期一到星期三 "," ：表示列舉 MON,WEB表示星期一和星期三 "*" ：表是“每”，每月，每天，每周，每年等 "/" :表示增量：0/15（處于分鐘段里面） 每15分鐘，在0分以后開始，3/20 每20分鐘，從3分鐘以后開始 "?" :只能出現在日，星期段里面，表示不指定具體的值 "L" :只能出現在日，星期段里面，是Last的縮寫，一個月的最后一天，一個星期的最后一天（星期六） "W" :表示作業日，距離給定值最近的作業日 "#" :表示一個月的第幾個星期幾，例如："6#3"表示每個月的第三個星期五（1=SUN...6=FRI,7=SAT） 如果Minutes的數值是 '0/15' ，表示從0開始每15分鐘執行 如果Minutes的數值是 '3/20' ，表示從3開始每20分鐘執行，也就是‘3/23/43’ */ Console.ReadKey(); } } /// <summary> /// 繼承并實作IJob介面，在Execute 方法中寫你要定時執行的事情（切記 ） /// </summary> public class MyJob : IJob { public Task Execute(IJobExecutionContext context) { Task task = null; try { string fileName = "printlog.txt"; using (StreamWriter writer = new StreamWriter(fileName, true)) { task = writer.WriteLineAsync(string.Format("{0},測驗", DateTime.Now.ToLongTimeString())); Console.WriteLine(string.Format("{0},測驗", DateTime.Now.ToLongTimeString())); } } catch (Exception) { } return Task.CompletedTask; } } /// <summary> /// 發郵件 /// </summary> public class SendEmailJob : IJob { public Task Execute(IJobExecutionContext context) { //Smtp sendEmail.SendMailUseGmail("[email protected]", "[email protected]", "terryK", "Quartz.net定時作業", "Quartz.net定時發送郵件", "tiyklkinqanxbgXX", 587, "smtp.qq.com", true); return Task.CompletedTask; } } public class sendEmail { public static Task SendMailUseGmail(string toUserAddress, string fromUserAddress, string fromUserName, string contextName, string context, string fromUserPass, int port, string host, bool sslState) { using (MailMessage mailMessage = new MailMessage()) { mailMessage.To.Add(toUserAddress); mailMessage.From = new MailAddress(fromUserAddress, fromUserName, Encoding.UTF8); mailMessage.Subject = contextName; mailMessage.SubjectEncoding = Encoding.UTF8; mailMessage.Body = context; mailMessage.BodyEncoding = Encoding.UTF8; mailMessage.IsBodyHtml = false; mailMessage.Priority = MailPriority.High; SmtpClient smtpClient = new SmtpClient(); smtpClient.Credentials = new NetworkCredential(fromUserAddress, fromUserPass); smtpClient.Port = port; smtpClient.Host = host; smtpClient.EnableSsl = sslState; try { smtpClient.Send(mailMessage); Console.WriteLine("發送成功，請查看"); } catch (SmtpException var_3_A8) { Console.WriteLine(var_3_A8.ToString()); } } return Task.CompletedTask; } } public class QuartzHelper { static readonly IScheduler _scheduler; static QuartzHelper() { #region 配置 Quartz NameValueCollection properties = new NameValueCollection { {"quartz.serializer.type","binary"} }; // 設定執行緒池 properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz"; //設定執行緒池的最大執行緒數量 properties["quartz.threadPool.threadCount"] = "10"; //設定作業中每個執行緒的優先級 properties["quartz.threadPool.threadPriority"] = ThreadPriority.Normal.ToString(); // 遠程輸出配置 properties["quartz.scheduler.exporter.type"] = "Quartz.Simpl.RemotingSchedulerExporter, Quartz"; properties["quartz.scheduler.exporter.port"] = "555"; //配置埠號 properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler"; properties["quartz.scheduler.exporter.channelType"] = "tcp"; //協議型別 #endregion //創建一個工廠 var schedulerFactory = new StdSchedulerFactory(properties); //啟動 _scheduler = schedulerFactory.GetScheduler().Result; //1、開啟調度 _scheduler.Start(); } /// <summary> /// 時間間隔執行任務 /// </summary> /// <typeparam name="T">任務類，必須實作IJob介面</typeparam> /// <param name="seconds">時間間隔(單位：秒)</param> public static async Task AsyncExecuteInterval<T>(int seconds) where T : IJob { //2、創建作業任務 IJobDetail job = JobBuilder.Create<T>() .WithIdentity("printlog", "LogGroup") .Build(); // 3、創建觸發器 ITrigger trigger = TriggerBuilder.Create() .StartNow() .WithIdentity("LogTrigger", "LogGroup") .WithSimpleSchedule(x => x.WithIntervalInSeconds(seconds).RepeatForever()) .Build(); //4、將任務加入到任務池 await _scheduler.ScheduleJob(job, trigger); } /// <summary> /// 指定時間執行任務 /// </summary> /// <typeparam name="T">任務類，必須實作IJob介面</typeparam> /// <param name="cronExpression">cron運算式，即指定時間點的運算式</param> public static async Task<bool> AsyncExecuteByCron<T>(string cronExpression) where T : IJob { //2、創建作業任務 IJobDetail job = JobBuilder.Create<T>() .WithIdentity("SendEmailJob", "EmailGroup") .Build(); //3、創建觸發器 ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create() .StartNow() .WithIdentity("SendEmail", "EmailGroup") .WithCronSchedule(cronExpression) .Build(); //4、將任務加入到任務池 await _scheduler.ScheduleJob(job, trigger); return true; } } }
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/117670.html
標籤：C#
上一篇：C# 閃爍
下一篇：NET/Regex 處理連續空格