作業調度系統quartz.net

        任務調度在我們日常開發過程中非常常見，比如：每天晚上0點自動執行某某操作；每周三晚上2點執行某某操作；......當然，我們處理這類問題的方法也有很多，比如：sql的自動任務；windows上創建任務計划；寫windows服務等等。如果系統比較復雜，相互調用比較頻繁，任務非常多，幾百上千條甚至上萬條，那么本身對任務的管理就是比較昂貴的代價；如何提高任務的高可用？任務的測試是否便捷等等問題就會出現。上述的方案是否還能從容應對？

        這時我們就迫切地需要一個作業調度系統來處理這些場景。

        Quartz.NET是一個強大、開源、輕量的作業調度框架，是 OpenSymphony 的 Quartz API 的.NET移植，它有很多特征，如：數據庫支持，集群，插件，支持cron-like表達式等等。官方網址：https://www.quartz-scheduler.net；GitHub地址：

https://github.com/quartznet/quartznet，各種用法可以參考示例程序。

        但如果想方便的知道某個作業執行情況，需要暫停，啟動等操作行為，這時候就需要個Job管理的界面。CrystalQuartz可以實現遠程管理。

        多數系統都會涉及到“后台服務”的開發，一般是為了調度一些自動執行的任務或從隊列中消費一些消息，開發 windows service 有一點不爽的是：調試麻煩，當然你還需要知道 windows service 相關的一些開發知識（也不難），TopShelf框架，可以你讓 console application 封裝為 windows service，這樣你就非常方便的開發和調試 windows service。TopShelf框架的官網為Url:http://topshelf-project.com

        用TopShelf和quartz.net編寫任務，CrystalQuartz管理任務。本文就是搭建一個簡易的任務調度方案，啟動任務調度、添加Job、移除Job、遠程管理等。

        1、建立一個名為TaskScheduling的Asp.net MVC項目

       

        2、新建一個類RemoteServerExample，主要代碼：

//ILog log = LogManager.GetLogger(typeof(RemoteServerExample));

            NameValueCollection properties = new NameValueCollection();
            properties["quartz.scheduler.instanceName"] = "RemoteAutoTaskServer";

            properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
            properties["quartz.threadPool.threadCount"] = "5";
            properties["quartz.threadPool.threadPriority"] = "Normal";

            // 設置服務器
            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";

            #region 2.3.0版本可用

            //properties["quartz.scheduler.exporter.channelName"] = "httpQuartz";
            // 拒絕遠程
            //properties["quartz.scheduler.exporter.rejectRemoteRequests"] = "true";

            #endregion 2.3.0版本可用

            #region 持久化所用

            //存儲類型
            //properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz";
            ////表明前綴
            //properties["quartz.jobStore.tablePrefix"] = "QRTZ_";
            ////驅動類型
            //properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz";
            ////數據源名稱
            //properties["quartz.jobStore.dataSource"] = "myDS";
            ////連接字符串
            //properties["quartz.dataSource.myDS.connectionString"] = @"Data Source=(local);Initial Catalog=quartz;User ID=sa;Password=Ayy123";
            ////sqlserver版本
            //properties["quartz.dataSource.myDS.provider"] = "SqlServer-20";

            #endregion 持久化所用

            ISchedulerFactory sf = new StdSchedulerFactory(properties);
            IScheduler sched = sf.GetScheduler();
            sched.Start();

            SchedulerMetaData metaData = sched.GetMetaData();

            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("remotelyAddedJob", "default")
                .Build();

            JobDataMap map = job.JobDataMap;
            map.Put("msg", "信息");

            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("remotelyAddedTrigger", "default")
                .ForJob(job.Key)
                .WithCronSchedule("/5 * * ? * *")
                .Build();

            string name = sched.SchedulerName;
            sched.ScheduleJob(job, trigger);

3、新建一個類RemoteClientExample，主要代碼：

ILog log = LogManager.GetLogger(typeof(RemoteClientExample));

            NameValueCollection properties = new NameValueCollection();
            properties["quartz.scheduler.instanceName"] = "RemoteClient";

            // 設置線程池
            properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
            properties["quartz.threadPool.threadCount"] = "5";
            properties["quartz.threadPool.threadPriority"] = "Normal";

            // 設置遠程連接
            //properties["quartz.scheduler.proxy"] = "true";
            //properties["quartz.scheduler.proxy.address"] = "tcp://127.0.0.1:556/QuartzScheduler";

            ISchedulerFactory sf = new StdSchedulerFactory(properties);
            IScheduler scheduler = sf.GetScheduler("RemoteAutoTaskServer");

            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("remotelyAddedJob1", "default")
                .Build();

            JobDataMap map = job.JobDataMap;
            map.Put("msg", "信息");

            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("remotelyAddedTrigger1", "default")
                .ForJob(job.Key)
                .WithCronSchedule("/5 * * ? * *")
                .Build();

            string name = scheduler.SchedulerName;
            scheduler.ScheduleJob(job, trigger);

            log.Info("向服務器添加計划任務");

4、SimpleJob代碼：

[PersistJobDataAfterExecution]
    [DisallowConcurrentExecution]
    public class SimpleJob : IJob
    {
        public const string Message = "msg";

        public virtual void Execute(IJobExecutionContext context)
        {
            try
            {
                JobKey jobKey = context.JobDetail.Key;
                string message = context.JobDetail.JobDataMap.GetString(Message);

                string strLog = String.Format("{0} 執行時間 {1}", jobKey, DateTime.Now.ToString());
            }
            catch (Exception ex)
            {
            }
        }
    }

5、程序運行界面：

點擊啟動調度器，啟動服務器監聽且默認有一個名為remotelyAddedJob的job，並且允許遠程管理；點擊添加任務，會加入一個名為remotelyAddedJob1的job；刪除任務會刪除所有job。

如果我們已經啟動了調度器，有一個任務，比如，我們用TopShelf和quartz.net寫了一個windows服務，在本地運行，如果要加入到遠程管理中，怎么辦呢？

可以按照上述RemoteClientExample代碼，配置properties，調用的時候通過反射的方式獲取，然后加入到調度器中，進行遠程管理。

quartz.net還有持久化、集群等等特性，提高任務的高可用。

分享一個corn表達式生成器：https://files.cnblogs.com/files/net-yuan/CronExpBuilder.zip

大神張善友 的quartz.net系列：https://www.cnblogs.com/shanyou/category/102991.html

GitHub：https://github.com/net-yuan/TaskScheduling