各大調度組件優缺點在這就不討論了,使用Quartz.net是由於它能夠執行秒級任務。git
Only.Jobs 項目經過將各Job存儲在數據庫中,啓動一個專門的Job管理任務來循環調度各Job的的調度狀況。github
項目分爲 Web管理系統 、服務運行端 、數據提供邏輯處理層 數據庫
數據訪問使用了 SqlSugar 4.1.1.5版本,目前支持MySql、SqlServerwindows
採用Quartz.net+Topshelf 可安裝爲windows服務。ide
一一介紹下:工具
Only.Jobs.Items 下是建立的測試Job項目。測試
Only.Jobs 是一個調度服務項目,集成了Topshelf,可安裝成windows服務。spa
Only.Jobs.Core 是項目的核心層,對外提供數據操做。.net
Only.Jobs.Web 爲調度任務的管理和狀態監控管理系統。3d
先來看下整體效果吧
運行Only.Jobs.Web項目:
在任務管理模塊可中止、啓用各Job.
BackgroundJob 爲任務信息存儲表
BackgroundJobLog 爲任務執行跟蹤日誌表
經過任務管理模塊將開發好的Job所在的項目配置起來,存儲到BackgroundJob表中。
在Only.Jobs項目中建立ManagerJob 類,Job調度任務管理。
1 [DisallowConcurrentExecution] 2 public class ManagerJob : IJob 3 { 4 private readonly ILog _logger = LogManager.GetLogger(typeof(ManagerJob)); 5 6 public void Execute(IJobExecutionContext context) 7 { 8 Version Ver = System.Reflection.Assembly.GetExecutingAssembly().GetName().Version; 9 _logger.InfoFormat("ManagerJob Execute begin Ver." + Ver.ToString()); 10 try 11 { 12 new QuartzManager().JobScheduler(context.Scheduler); 13 _logger.InfoFormat("ManagerJob Executing ..."); 14 } 15 catch (Exception ex) 16 { 17 JobExecutionException e2 = new JobExecutionException(ex); 18 e2.RefireImmediately = true; 19 } 20 finally 21 { 22 _logger.InfoFormat("ManagerJob Execute end "); 23 } 24 } 25 }
JobScheduler 方法:
1 /// <summary> 2 /// Job狀態管控 3 /// </summary> 4 /// <param name="Scheduler"></param> 5 public void JobScheduler(IScheduler Scheduler) 6 { 7 List<BackgroundJobInfo> list = new BackgroundJobService().GeAllowScheduleJobInfoList(); 8 if (list != null && list.Count > 0) 9 { 10 foreach (BackgroundJobInfo jobInfo in list) 11 { 12 JobKey jobKey = new JobKey(jobInfo.BackgroundJobId.ToString(), jobInfo.BackgroundJobId.ToString() + "Group"); 13 if (Scheduler.CheckExists(jobKey) == false) 14 { 15 if (jobInfo.State == 1 || jobInfo.State == 3) 16 { 17 ScheduleJob(Scheduler, jobInfo); 18 if (Scheduler.CheckExists(jobKey) == false) 19 { 20 new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0); 21 } 22 else 23 { 24 new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 1); 25 } 26 } 27 else if (jobInfo.State == 5) 28 { 29 new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0); 30 } 31 } 32 else 33 { 34 if (jobInfo.State == 5) 35 { 36 Scheduler.DeleteJob(jobKey); 37 new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0); 38 } 39 else if (jobInfo.State == 3) 40 { 41 new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 1); 42 } 43 } 44 } 45 } 46 }
其餘的簡單的就不在這描述了。
接下來看下運行效果:
啓動Only.Jobs項目
僅僅是一個工具項目而已,你們可儘管仍磚頭過來。
代碼已上傳github
https://github.com/mamingbo/Only.Jobs 歡迎下載使用。