Quartz.net基於數據庫的任務調度管理(Only.Jobs)

一 前言：

各大調度組件優缺點在這就不討論了，使用Quartz.net是因為它可以執行秒級任務。

Only.Jobs 項目通過將各Job存儲在數據庫中，啟動一個專門的Job管理任務來循環調度各Job的的調度情況。

 

項目分為 Web管理系統  、服務運行端   、數據提供邏輯處理層 

數據訪問使用了 SqlSugar 4.1.1.5版本，目前支持MySql、SqlServer

采用Quartz.net+Topshelf  可安裝為windows服務。

 

二 項目結構：

一一介紹下：

Only.Jobs.Items 下是創建的測試Job項目。

Only.Jobs  是一個調度服務項目，集成了Topshelf，可安裝成windows服務。

Only.Jobs.Core  是項目的核心層，對外提供數據操作。

Only.Jobs.Web 為調度任務的管理和狀態監控管理系統。

先來看下總體效果吧

運行Only.Jobs.Web項目：

 

 

在任務管理模塊可停止、啟用各Job.

 

三 表結構介紹

BackgroundJob  為任務信息存儲表

BackgroundJobLog 為任務執行跟蹤日志表

 

四 實現介紹

通過任務管理模塊將開發好的Job所在的項目配置起來，存儲到BackgroundJob表中。

在Only.Jobs項目中創建ManagerJob 類，Job調度任務管理。

    [DisallowConcurrentExecution]
    public class ManagerJob : IJob
    {
        private readonly ILog _logger = LogManager.GetLogger(typeof(ManagerJob));

        public void Execute(IJobExecutionContext context)
        {
            Version Ver = System.Reflection.Assembly.GetExecutingAssembly().GetName().Version;
            _logger.InfoFormat("ManagerJob Execute begin Ver." + Ver.ToString());
            try
            {
                new QuartzManager().JobScheduler(context.Scheduler);
                _logger.InfoFormat("ManagerJob Executing ...");
            }
            catch (Exception ex)
            {
                JobExecutionException e2 = new JobExecutionException(ex);
                e2.RefireImmediately = true;
            }
            finally
            {
                _logger.InfoFormat("ManagerJob Execute end ");
            }
        }
    }

 

JobScheduler 方法：

 /// <summary>
        /// Job狀態管控
        /// </summary>
        /// <param name="Scheduler"></param>
        public void JobScheduler(IScheduler Scheduler)
        {
            List<BackgroundJobInfo> list = new BackgroundJobService().GeAllowScheduleJobInfoList();
            if (list != null && list.Count > 0)
            {
                foreach (BackgroundJobInfo jobInfo in list)
                {
                    JobKey jobKey = new JobKey(jobInfo.BackgroundJobId.ToString(), jobInfo.BackgroundJobId.ToString() + "Group");
                    if (Scheduler.CheckExists(jobKey) == false)
                    {
                        if (jobInfo.State == 1 || jobInfo.State == 3)
                        {
                            ScheduleJob(Scheduler, jobInfo);
                            if (Scheduler.CheckExists(jobKey) == false)
                            {
                                new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0);
                            }
                            else
                            {
                                new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 1);
                            }
                        }
                        else if (jobInfo.State == 5)
                        {
                            new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0);
                        }
                    }
                    else
                    {
                        if (jobInfo.State == 5)
                        {
                            Scheduler.DeleteJob(jobKey);
                            new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 0);
                        }
                        else if (jobInfo.State == 3)
                        {
                            new BackgroundJobService().UpdateBackgroundJobState(jobInfo.BackgroundJobId, 1);
                        }
                    }
                }
            }
        }

 

其他的簡單的就不在這描述了。

接下來看下運行效果：

啟動Only.Jobs項目

 

 

 

 

 

僅僅是一個工具項目而已，大家可盡管仍磚頭過來。

代碼已上傳github

https://github.com/mamingbo/Only.Jobs  歡迎下載使用。