C#基於Quartz.NET實現任務調度並部署Windows服務

一、Quartz.NET介紹

Quartz.NET是一個強大、開源、輕量的作業調度框架，是 OpenSymphony 的 Quartz API 的.NET移植，用C#改寫，可用於winform和asp.net mvc、.Net Core應用中。它靈活而不復雜。你能夠用它來為執行一個作業而創建簡單的或復雜的作業調度。它有很多特征，如：數據庫支持，集群，插件，支持cron-like表達式等等。

官網：http://www.quartz-scheduler.net/

源碼：https://github.com/quartznet/quartznet

二、Quartz.NET用途

 一，可以定時發郵件通知。 

二 ， 電商網站的定時打折活動。（比如規定11月11日 淘寶購買女朋友打八折）

三， 定時對數據更新 或者添加。

四，自己朋友生日。 可以定時發生日祝福。 等等 （我也不一一舉例了） 

三、Quartz.NET安裝

我使用的VS版本是2017的  選擇工具  - NuGet包管理 - 管理解決方案的NuGet包   輸入 Quartz.NET 安裝

還可以通過NuGet控制台 通過安裝命令  

Install-Package Quartz

四、Quartz.NET實現思路

一：繼承並實現IJob接口，在Execute 方法中寫你要定時執行的事情（切記 ）

二：使用Quartz創建任務調度核心代碼步驟

　　1、配置Quartz，創建工廠，開啟調度。

　　2、創建工作任務

　　3、創建觸發器

　　4、將任務加入到任務池

三：添加任務，使用Topshelf部署Windows服務，定時執行

五、代碼步驟講解

一：繼承並實現IJob接口，在Execute 方法中寫你要做的事情（切記 ）

　　　

using Quartz.Utility;
using System;
using System.IO;
using System.Threading.Tasks;

namespace Quartz.JobWork
{
    public class MyJob : IJob
    {
        public Task Execute(IJobExecutionContext context)
        {
            Task task = null;
            try
            {
                string fileName = "printlog.txt";
                StreamWriter writer = new StreamWriter(fileName, true);
                task = writer.WriteLineAsync(string.Format("{0},測試", DateTime.Now.ToLongTimeString()));
                writer.Close();
                writer.Dispose();
            }
            catch (Exception ex)
            {
                LogHelper.WriteLog(ex.Message.ToString(), ex);
            }
            return task;
        }
    }
}

 

二：使用Quartz創建任務調度核心代碼步驟

注：這里提供一個QuartzHelper幫助類，直接把以下代碼copy過去即可用，只需要重寫Execute方法即可。Quartz3.0及以上的版本是采用的異步，3.0以下的版本沒有采用異步，使用方法是一樣的

using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Quartz.Utility
{
    public class QuartzHelper
    {
        static readonly IScheduler _scheduler;
        static QuartzHelper()
        {
            //創建一個工廠
            var schedulerFactory = new StdSchedulerFactory();
            //啟動
            _scheduler = schedulerFactory.GetScheduler().Result;
            //1、開啟調度
            _scheduler.Start();
        }
        /// <summary>
        /// 時間間隔執行任務
        /// </summary>
        /// <typeparam name="T">任務類，必須實現IJob接口</typeparam>
        /// <param name="seconds">時間間隔(單位：秒)</param>
        public static async Task<bool> ExecuteInterval<T>(int seconds) where T : IJob
        {
            //2、創建工作任務
            IJobDetail job = JobBuilder.Create<T>().Build();
            // 3、創建觸發器
            ITrigger trigger = TriggerBuilder.Create()
           .StartNow()
           .WithSimpleSchedule(
                x =>x.WithIntervalInSeconds(seconds)
                //x.WithIntervalInMinutes(1)
                .RepeatForever())
           .Build();
            //4、將任務加入到任務池
            await _scheduler.ScheduleJob(job, trigger);
            return true;
        }

        /// <summary>
        /// 指定時間執行任務
        /// </summary>
        /// <typeparam name="T">任務類，必須實現IJob接口</typeparam>
        /// <param name="cronExpression">cron表達式，即指定時間點的表達式</param>
        public static async Task<bool> ExecuteByCron<T>(string cronExpression) where T : IJob
        {
            //2、創建工作任務
            IJobDetail job = JobBuilder.Create<T>().Build();
            //3、創建觸發器
            ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create()
            .StartNow()
            .WithCronSchedule(cronExpression)
            .Build();
            //4、將任務加入到任務池
            await _scheduler.ScheduleJob(job, trigger);
            return true;
        }
    }
}

 

 三：添加任務，Topshelf部署Windows服務，定時執行

　　　　

namespace Quartz
{
    public class Program
    {
        static void Main(string[] args)
        {
            string cronExpression = "0 0 8,23 * * ? ";  //=>這是指每天的9點和16點執行任務
            cronExpression = "30 0/1 * * * ?";
            //QuartzHelper.ExecuteByCron<MyJob>(cronExpression).Wait();　　//=>這是調用Cron計划方法
            QuartzHelper.ExecuteInterval<MyJob>(180).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’
            */
            HostFactory.Run(x =>
            {
                x.UseLog4Net();
                x.Service<TownCrier>(s =>
                {
                    s.ConstructUsing(name => new TownCrier());
                    s.WhenStarted(tc => tc.Start());
                    s.WhenStopped(tc => tc.Stop());
                });
                x.RunAsLocalSystem();
                x.SetDescription("QuartzJob任務定時發送");
                x.SetDisplayName("QuartzJob");
                x.SetServiceName("QuartzJob");

                x.EnablePauseAndContinue();
            });
        }
    }
}

　　TownCrier服務實現類

public class TownCrier
    {
        readonly Timer _timer;
        public TownCrier()
        {
            _timer = new Timer(1000) { AutoReset = true };
            _timer.Elapsed += (sender, eventArgs) => Console.WriteLine("---------------------DateTime： {0} ------------------- ", DateTime.Now);
        }
        public void Start() { _timer.Start(); }
        public void Stop() { _timer.Stop(); }
    }