Window服務基於Quartz.Net元件實現定時任務排程(二)
前言:
在上一章中,我們通過利用控制檯實現定時任務排程,已經大致瞭解瞭如何基於Quartz.Net元件實現任務,至少包括三部分:job(作業),trigger(觸發器),scheduler(排程器)。其中job是需要在一個定時任務中具體執行的業務邏輯,trigger通過規定job何時並按照何種指定的規則進行執行,最後job和trigger會被註冊到scheduler中,利用scheduler(排程器)來負責協調job和trigger的搭配執行。
你是否在工作中會遇到需要軟體具有自動執行任務的功能,但是又不希望直接啟動軟體來手動執行任務?
這個時候,我們可以考慮用到window服務,基於Quartz.Net元件定時輪詢資料庫同步,定時郵件通知,定時處理資料等功能。
開始:
首先建立一個windows服務專案
在建立好的專案中,Service1.cs檔案中點選“單擊此處切換到程式碼檢視”切換到程式碼
這個時候我們可以注意到兩個方法:OnStart (服務啟動)和 OnStop(服務停止)
/// <summary> /// 服務啟動 /// </summary> /// <param name="args"></param> protected override void OnStart(string[] args) { }
/// <summary> /// 服務停止 /// </summary> protected override void OnStop() { }
一、建立一個scheduler的引用:
ISchedulerFactory schedFact = new StdSchedulerFactory(); IScheduler sched = await schedFact.GetScheduler();
二、啟動 scheduler:
await sched.Start();
三、實現IJob:
SyncJob.cs 實現IJob,在Execute方法裡編寫要處理的業務邏輯,系統就會按照Quartz的配置,定時處理
[Invoke(Name = "SyncJob", Remark = "Quartz服務", Group = "Quartz服務管理", Begin = "2018-05-01 12:00:00", Interval = 5)] public class SyncJob : IJob { public Task Execute(IJobExecutionContext context) { try { //每次執行 獲取當前時間 輸出當前時間 //可以在這裡編寫每次定時執行需要的方法 LogHelper.SaveLog("輸出日誌", "在當前時間:" + DateTime.Now + "--上一次執行時間:" + DateTime.Now.AddSeconds(-5)); } catch (Exception ex) { LogHelper.SaveLog(ex); } return null; } }
四、建立trigger:(建立一個某個時間點的觸發器,並且每5秒執行一次)
ITrigger trigger = TriggerBuilder.Create() .WithIdentity("trigger1", "group1") //觸發器 組 .WithSimpleSchedule(x => x.WithIntervalInSeconds(5).RepeatForever()) .Build();
五、觸發器執行任務:
await sched.ScheduleJob(job, trigger);
將幾個步驟整合後代碼如下:
/// <summary> /// 服務啟動 /// </summary> /// <param name="args"></param> protected override void OnStart(string[] args) { Run().GetAwaiter().GetResult(); LogHelper.SaveLog("服務", "開始"); } /// <summary> /// 服務停止 /// </summary> protected override void OnStop() { try { if (scheduler != null) { scheduler.Shutdown(); } } catch (Exception ex) { LogHelper.SaveLog(ex); } LogHelper.SaveLog("服務", "結束"); } IScheduler scheduler; private async Task Run() { try { NameValueCollection props = new NameValueCollection { { "quartz.serializer.type", "binary" } }; StdSchedulerFactory factory = new StdSchedulerFactory(props); scheduler = await factory.GetScheduler(); await scheduler.Start(); Jobs.Jobs.Config(scheduler); } catch (SchedulerException ex) { LogHelper.SaveLog(ex); } }
安裝
以管理員的身份開啟cmd
執行:
間隔5秒執行一次後的效果:
通過日誌的方式輸出資料,檢視效果
附加:
一、刪除服務
以管理員的身份開啟cmd
二、除錯window服務
1)安裝並執行服務
2)附加程序
3)在程式碼中加入斷點進行除錯
總結:
1.當我們在需要用到定時執行任務的時候,可以考慮使用通過window服務加上quartz元件結合的方式,實現對任務的定時執行,這也是在很多場景中可以實現的方法,比如:定時輪詢資料庫同步,定時郵件通知,定時處理資料等
2.通過管理工具顯示當前執行的任務和執行情況,也利用除錯工具除錯Window服務中遇到的問題。
3.quartz還有更多的用法,可以參考資料:Quartz.Net官方文件 和 Quartz.Net開源