Quartz.NET總結（一）入門

　　前段時間，花了大量的時間，將原先的計划任務，切換到Quartz.NET來進行管理。原先的后台定時服務都是通過計划任務來實現的，但是隨着業務增長，計划任務也越來越多，每個后台服務，都得創建一個計划任務。日常的維護和管理非常麻煩。

 

　　於是乎，一咬牙，決定引入Quartz.NET框架，統一都管理全部的后台定時服務。切換過程確實很麻煩。直到今天，才終於有時間整理總結Quartz.NET的相關內容。

 

　　Quartz.NET的優點和使用場景，這里不再多說，網上有很多說明，總的來說就是，Quartz.NET是一個開源的作業調度框架，非常適合在平時的工作中，定時輪詢數據庫同步，定時郵件通知，定時處理數據等。 Quartz.NET允許開發人員根據時間間隔（或天）來調度作業。它實現了作業和觸發器的多對多關系，還能把多個作業與不同的觸發器關聯，配置靈活方便。

 

　　參考官方學習文檔：http://www.quartz-scheduler.net/documentation/index.html

　　快速搭建一個Quartz，源代碼下載

 

　　第一步：新建解決方案和相關項目,並安裝相關程序包，如下圖所示：

      

        Quartz依賴Common.Logging和Common.Logging.Log4Net，而且Log4Net也是比較熟悉的日志工具，因此我們實際使用中，也是log4net記錄日志，另外定時作業一般都是在window服務中，我們也可用Topshelf來創建我們的window服務。

 

　　第二步：創建兩個Job類Job1，Job2。實現IJob，在Execute方法里編寫要處理的業務邏輯，系統就會按照Quartz的配置，定時處理。

　　using System;

　　using System.Threading;
　　namespace Quartz.Net.Jobs
　　{
　　　　/// <summary>
　　　　/// 實現IJob接口
　　　　/// </summary>
　　　　public class Job1 : IJob
　　　　{
　　　　　　private static readonly Common.Logging.ILog logger = Common.Logging.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
　　　　　　public void Execute(IJobExecutionContext context)
　　　　　　{
　　　　　　　　try
　　　　　　　　{
　　　　　　　　　　logger.Info("Job1 任務運行開始");

　　　　　　　　　　for (int i = 0; i < 5; i++)
　　　　　　　　　　{

　　　　　　　　　　　　Thread.Sleep(100);
　　　　　　　　　　　　logger.InfoFormat("Job1 正在運行{0}", i);
　　　　　　　　　　}

　　　　　　　　　　logger.Info("Job1任務運行結束");
　　　　　　　　}
　　　　　　　　catch (Exception ex)
　　　　　　　　{
　　　　　　　　　　logger.Error("Job1 運行異常", ex);
　　　　　　　　}

　　　　　　}
　　　　}
　　}

 

　　第三步：配置quartz.config、quartz_jobs.xml

　　　Quartz 實例的基礎配置：quartz.config

　　# You can configure your scheduler in either <quartz> configuration section

　　# or in quartz properties file

　　# Configuration section has precedence

　　quartz.scheduler.instanceName = QuartzTest

　　# configure thread pool info

　　quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz

　　quartz.threadPool.threadCount = 10

　　quartz.threadPool.threadPriority = Normal

　　# job initialization plugin handles our xml reading, without it defaults are used

　　quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz

　　quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

　　# export this server to remoting context

　　#quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz

　　#quartz.scheduler.exporter.port = 555

　　#quartz.scheduler.exporter.bindName = QuartzScheduler

　　#quartz.scheduler.exporter.channelType = tcp

　　#quartz.scheduler.exporter.channelName = httpQuartz

 

　　　各個Job 任務的配置 ：quartz_jobs.xml

<?xml version="1.0" encoding="UTF-8"?>
　　<!-- This file contains job definitions in schema version 2.0 format -->
　　<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
　　<processing-directives>
　　　　<overwrite-existing-data>true</overwrite-existing-data>
　　</processing-directives>
　　<schedule>
　　　　<!--定義Job1 Job-->
　　　　<job>
　　　　　　<name>Job1</name>
　　　　　　<group>JobGroup</group>
　　　　　　<description>Quartz Job1</description>
　　　　　　<job-type>Quartz.Net.Jobs.Job1,Quartz.Net.Jobs</job-type>
　　　　　　<durable>true</durable>
　　　　　　<recover>false</recover>
　　　　</job>
　　　　<!--定義Job2 Job-->
　　　　<job>
　　　　　　<name>Job2</name>
　　　　　　<group>JobGroup</group>
　　　　　　<description>Quartz Job2</description>
　　　　　　<job-type>Quartz.Net.Jobs.Job2,Quartz.Net.Jobs</job-type>
　　　　　　<durable>true</durable>
　　　　　　<recover>false</recover>
　　　　</job>
　　　　<!--定義Job1 觸發器 每30秒執行一次Job1任務-->
　　　　<trigger>
　　　　　　<cron>
　　　　　　　　<name>Job1Trigger</name>
　　　　　　　　<group>JobTriggerGroup</group>
　　　　　　　　<job-name>Job1</job-name>
　　　　　　　　<job-group>JobGroup</job-group>
　　　　　　　　<cron-expression>0/30 * * * * ?</cron-expression>
　　　　　　</cron>
　　　　</trigger>
　　　　<!--定義Job2 觸發器 每分鍾執行一次Job2任務-->
　　　　<trigger>
　　　　　　<cron>
　　　　　　　　<name>Job2Trigger1</name>
　　　　　　　　<group>JobTriggerGroup</group>
　　　　　　　　<job-name>Job2</job-name>
　　　　　　　　<job-group>JobGroup</job-group>
　　　　　　　　<cron-expression>0 * * * * ?</cron-expression>
　　　　　　</cron>
　　　　</trigger>
　　</schedule>
　　</job-scheduling-data>

 

　　第四步：宿主程序，可以是window服務，也可以是后台Console程序，如何用Topshelf來創建我們的window服務,請看另外一篇文章《使用Topshelf 開發windows服務》。

　namespace Quartz.Net.Console
　　{
　　　　class Program
　　　　{
　　　　　　private static IScheduler scheduler;
　　　　　　static void Main(string[] args)
　　　　　　{
　　　　　　　　ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
　　　　　　　　scheduler = schedulerFactory.GetScheduler();

　　　　　　　　scheduler.Start();
　　　　　　}
　　　　}
　　}

 

　　注意：quartz_jobs.xml和quartz.config這兩個文件，要手動復制到輸出目錄下，或者在vs中，分別選中這兩個文件→右鍵屬性→復制到輸入目錄設為：始終復制。

　　否則讀取不到這兩個配置文件，程序無法運行。

　　運行后，效果如下圖：