基於Quartz.Net的任務管理平台開發(2) —— Quartz.Net使用

Quartz.Net的使用

引用組件

Quartz.Net作為開源組件，可以使用Nuget進行集成，需要注意的是Quartz.Net的版本，不同的Quartz.Net版本依賴的其他組件的版本會有區別，具體使用上時，需要確認好版本。

net framwork 4.0 需要注意quartz其他引用組件的依賴，如Commn.logging 版本3.4 會要求MicroSoft.CSharp版本>=4.0.1,，而DMS的版本為4.0，為兼容已有項目，綜合考慮下來，可以采用如下版本組件：

<packages>
  <package id="Common.Logging" version="3.3.1" targetFramework="net40" />
  <package id="Common.Logging.Core" version="3.3.1" targetFramework="net40" />
  <package id="Common.Logging.Log4Net1213" version="3.3.1" targetFramework="net40" />
  <package id="log4net" version="2.0.3" targetFramework="net40" />
  <package id="Quartz" version="2.6.0" targetFramework="net40" />
  <package id="Topshelf" version="3.3.1" targetFramework="net40" />
</packages>

 

Quartz.net配置：

（1） 文件配置：

默認的quartz任務配置文件為quartz_jobs.xml，在quartz服務的根目錄下，可以通過quartz.config中quartz.plugin.xml.fileNames = ~/quartz_jobs.xml進行設置。

quartzt.config的配置：

# You can configure your scheduler in either <quartz> configuration section  
# or in quartz properties file  
# Configuration section has precedence  
  
quartz.scheduler.instanceName = ServerScheduler  
  
# 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  

　　

任務配置quartz_jobs.xml:

<?xml version="1.0" encoding="utf-8" ?>
<!-- This file contains job definitions in schema version 2.0 format -->

<!--在2.0版本中根結點由<quartz> 變為了<job-scheduling-data>-->
<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>
        <!--2.0版本中的job相當於1.x版本中的<job-detail>，這個節點是用來定義每個具體的任務的，多個任務請創建多個job節點即可-->
        <job>
            <!--任務名稱，同一個group中多個job的name不能相同，若未設置group則所有未設置group的job為同一個分組（必須設置）-->
            <name>sampleJob</name>
            <!--任務所屬分組，用於標識任務所屬分組-->
            <group>sampleGroup</group>
            <!--工作任務的描述，用於描述任務具體內容-->
            <description>Sample job for Quartz Server</description>
            <!--任務類型，任務的具體類型及所屬程序集，格式：實現了IJob接口的包含完整命名空間的類名,程序集名稱-->
            <job-type>Quartz.Server.SampleJob, Quartz.Server</job-type>
            <!--<durable>（持久性）-如果一個Job是不持久的， 一旦沒有觸發器與之關聯，它就會被從scheduler 中自動刪除-->
            <durable>true</durable>
            <recover>false</recover>

        </job>
        <!--trigger 任務觸發器，用於定義使用何種方式觸發任務(job)，同一個job可以定義多個trigger ，多個trigger 各自獨立的執行調度，每個trigger 中必須且只能定義一種觸發器類型(calendar-interval、simple、cron)
     calendar-interval 一種觸發器類型，使用較少，此處略過-->
        <trigger>
            <!--簡單任務的觸發器，可以調度用於重復執行的任務-->
            <simple>
                <!--觸發器名稱，同一個分組中的名稱必須不同-->
                <name>sampleSimpleTrigger</name>
                <!--觸發器組-->
                <group>sampleSimpleGroup</group>
                <!--觸發器描述-->
                <description>Simple trigger to simply fire sample job</description>
                <!--要調度的任務名稱，該job-name必須和對應job節點中的name完全相同-->
                <job-name>sampleJob</job-name>
                <!--調度任務(job)所屬分組，該值必須和job中的group完全相同-->
                <job-group>sampleGroup</job-group>
                <!--start-time(選填) 任務開始執行時間utc時間，北京時間需要+08:00，如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京時間2012年4月1日上午8:00開始執行，注意服務啟動或重啟時都會檢測此屬性，若沒有設置此屬性或者start-time設置的時間比當前時間較早，則服務啟動后會立即執行一次調度，若設置的時間比當前時間晚，服務會等到設置時間相同后才會第一次執行任務，一般若無特殊需要請不要設置此屬性-->
                <misfire-instruction>SmartPolicy</misfire-instruction>
                <!--任務執行次數，如:<repeat-count>-1</repeat-count>表示無限次執行-->
                <repeat-count>-1</repeat-count>
                <!--任務觸發間隔(毫秒)-->
                <repeat-interval>10000</repeat-interval>
            </simple>
        </trigger>
        <job>
            <name>CommissionJob</name>
            <group>CommissionJob</group>
            <description>Sample job for Quartz Server</description>
            <job-type>Settlement.Jobs.CommissionJob, Settlement.Jobs</job-type>
            <durable>true</durable>
            <recover>false</recover>

        </job>
        <trigger>
            <!--cron復雜任務觸發器使用cron表達式定制任務調度-->
            <cron>
                <name>sampleSimpleTrigger2</name>
                <group>sampleSimpleTrigger2</group>
                <job-name>sampleJob2</job-name>
                <job-group>sampleGroup2</job-group>
                <!--start-time(選填) 任務開始執行時間utc時間，北京時間需要+08:00，如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京時間2012年4月1日上午8:00開始執行，注意服務啟動或重啟時都會檢測此屬性，若沒有設置此屬性，服務會根據cron-expression的設置執行任務調度；若start-time設置的時間比當前時間較早，則服務啟動后會忽略掉cron-expression設置，立即執行一次調度，之后再根據cron-expression執行任務調度；若設置的時間比當前時間晚，則服務會在到達設置時間相同后才會應用cron-expression，根據規則執行任務調度，一般若無特殊需要請不要設置此屬性-->
                <!--cron表達式-->
                <cron-expression>0/10 * * * * ?</cron-expression>
            </cron>
        </trigger>
    </schedule>
</job-scheduling-data>

 

PS：在集成到已有系統時，quartz.config可以配置在Web配置中

<configuration>
  <configSections>
    　　<!--任務調度配置-->
    　　<section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089" />
  </configSections>
<quartz>
　　<add key="quartz.scheduler.instanceName" value="TaskManager" />
　　<!--緩沖池配置-->
　　<add key="quartz.threadPool.type" value="Quartz.Simpl.SimpleThreadPool, Quartz" />
　　<add key="quartz.threadPool.threadCount" value="10" />
　　<add key="quartz.threadPool.threadPriority" value="2" />
　　<!--遠程輸出配置-->
　　<add key="quartz.scheduler.exporter.type" value="Quartz.Simpl.RemotingSchedulerExporter, Quartz" />
　　<add key="quartz.scheduler.exporter.port" value="556" />
　　<add key="quartz.scheduler.exporter.bindName" value="TaskManager" />
　　<add key="quartz.scheduler.exporter.channelType" value="tcp" />
　　<!--驅動類型-->
　　<add key="quartz.jobStore.driverDelegateType" value="Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz" />
　　<!--數據源名稱-->
　　<add key="quartz.jobStore.dataSource" value="QuartzDB" />
　　<!--數據庫版本-->
　　<add key="quartz.dataSource.QuartzDB.provider" value="SqlServer-20" />
　　<!--連接字符串-->
　　<add key="quartz.dataSource.QuartzDB.connectionString" value="server=192.168.2.88;database=QuartzDB;uid=sa;pwd=winner@001" />
　　<!--事物類型-->
　　<add key="quartz.jobStore.type" value="Quartz.Impl.AdoJobStore.JobStoreTX, Quartz" />
　　<!--表名前綴-->
　　<add key="quartz.jobStore.tablePrefix" value="QRTZ_" />
　　<!--Quartz Scheduler唯一實例ID，auto：自動生成-->
　　<add key="quartz.scheduler.instanceId" value="AUTO" />
　　<!--集群-->
　　<add key="quartz.jobStore.clustered" value="true" />
　　<add key="quartz.jobStore.useProperties" value="false" />
　　<add key="quartz.jobStore.lockHandler.type" value="Quartz.Impl.AdoJobStore.UpdateLockRowSemaphore, Quartz" />
</quartz>
</configuration>

(2)  代碼配置：

                NameValueCollection properties = new NameValueCollection();
                    properties["quartz.scheduler.instanceName"] = "QuartzDBDemo";
                    // 設置線程池
                    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"] = "556";
                    properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";
                    properties["quartz.scheduler.exporter.channelType"] = "tcp";
                    // 驅動類型，這里用的mysql，目前支持如下驅動：
                    //Quartz.Impl.AdoJobStore.FirebirdDelegate
                    //Quartz.Impl.AdoJobStore.MySQLDelegate
                    //Quartz.Impl.AdoJobStore.OracleDelegate
                    //Quartz.Impl.AdoJobStore.SQLiteDelegate
                    //Quartz.Impl.AdoJobStore.SqlServerDelegate
                    properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz";

                    // 數據源名稱
                    //properties["quartz.jobStore.dataSource"] = "QuartzDB";
                    ///* 數據庫版本    MySql.Data.dll版本,二者必須保持一致
                    // * MySql-10    1.0.10.1
                    // * MySql-109   1.0.9.0
                    // * MySql-50    5.0.9.0
                    // * MySql-51    5.1.6.0
                    // * MySql-65    6.5.4.0
                    // * MySql-695   6.9.5.0
                    // *             System.Data
                    // * SqlServer-20         2.0.0.0
                    // * SqlServerCe-351      3.5.1.0
                    // * SqlServerCe-352      3.5.1.50
                    // * SqlServerCe-400      4.0.0.0
                    // * 其他還有OracleODP，Npgsql，SQLite，Firebird，OleDb
                    //*/
                    //properties["quartz.dataSource.QuartzDB.provider"] = "SqlServer-20";

                    // 連接字符串
                    properties["quartz.dataSource.QuartzDB.connectionString"] = "server=192.168.2.88;database=QuartzDB;uid=sa;pwd=winner@001";
                    // 事物類型JobStoreTX自動管理 JobStoreCMT應用程序管理
                    properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz";
                    // 表明前綴
                    properties["quartz.jobStore.tablePrefix"] = "QRTZ_";
                    // Quartz Scheduler唯一實例ID，auto：自動生成
                    properties["quartz.scheduler.instanceId"] = "AUTO";
                    // 集群
                    //properties["quartz.jobStore.clustered"] = "true";

                    #endregion
                    //ISchedulerFactory schedulerFactory = new StdSchedulerFactory(properties);
                    ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
                    _scheduler = schedulerFactory.GetScheduler();