Quartz.NET开源作业调度框架系列(四):Plugin Job

　　如果在Quartz.NET作业运行时我们想动态修改Job和Trigger的绑定关系,同时修改一些参数那么该怎么办呢?Quartz.NET提供了插件技术,可以通过在XML文件中对Job和Trigger的参数进行配置,然后定期去加载配置文件来实例化任务和Trigger,这样就解决了此类问题.

1 PlugInJobExample

using System;

using System.Collections.Specialized;

using System.Threading;

using Common.Logging;

using Quartz;

using Quartz.Impl;

using Quartz.Job;

using System.Windows.Forms;

namespace QuartzDemo

{

    public class PlugInJobExample

    {

        public string Name

        {

            get { return GetType().Name; }

        }

        public virtual IScheduler Run()

        {

            var properties = new NameValueCollection();

            properties["quartz.plugin.triggHistory.type"] = "Quartz.Plugin.History.LoggingJobHistoryPlugin";

            properties["quartz.plugin.jobInitializer.type"] = "Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin";

            //配置文件名称

            properties["quartz.plugin.jobInitializer.fileNames"] = "quartz_jobs.xml";

            properties["quartz.plugin.jobInitializer.failOnFileNotFound"] = "true";

            //每隔120秒进行探查,看配置文件是否更改

            properties["quartz.plugin.jobInitializer.scanInterval"] = "";

            // 用插件XML定义的propertie来实例化一个ISchedulerFactory

            ISchedulerFactory sf = new StdSchedulerFactory(properties);

            IScheduler sched = sf.GetScheduler();

            //启动

            sched.Start();

            //返回

            return sched;

        }

    }

}

2 SimpleJob1

 using System;

 using System.Collections.Generic;

 using Common.Logging;

 using Quartz;

 using Quartz.Impl;

 using Quartz.Job;

 using System.Windows.Forms;

 namespace QuartzDemo

 {

     public class SimpleJob1 : IJob

     {

         public virtual void Execute(IJobExecutionContext context)

         {

             JobKey jobKey = context.JobDetail.Key;

             if (isOpen("FrmConsole"))

             {

                 try

                 {

                     //获取当前Form1实例

                     __instance = (FrmConsole)Application.OpenForms["FrmConsole"];

                     //获取当前执行的线程ID

                     __instance.SetInfo(" - "+jobKey + "Thread ID " + System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());

                     //通过方法更新消息

                     __instance.SetInfo(string.Format(" - {0} exec at {1}",

                     jobKey,

                     System.DateTime.Now.ToString()));

                 }

                 catch (Exception ex)

                 {

                     Console.WriteLine(ex.Message);

                 }

             }

             // This job simply prints out its job name and the

             if (context.MergedJobDataMap.Count > )

             {

                 ICollection<string> keys = context.MergedJobDataMap.Keys;

                 foreach (string key in keys)

                 {

                     String val = context.MergedJobDataMap.GetString(key);

                     __instance.SetInfo(string.Format(" - MergedJobDataMap entry: {0} = {1}", key, val));

                 }

             }

             context.Result = "exec ok";

         }

         private static FrmConsole __instance = null;

         /// <summary>

         /// 判断窗体是否打开

         /// </summary>

         /// <param name="appName"></param>

         /// <returns></returns>

         private bool isOpen(string appName)

         {

             FormCollection collection = Application.OpenForms;

             foreach (Form form in collection)

             {

                 if (form.Name == appName)

                 {

                     return true;

                 }

             }

             return false;

         }

     }

 }

3 xml配置文件

下面第一个是简单的Trigger配置,第二个是用CronTrigger:

 <?xml version="1.0" encoding="UTF-8"?>

 <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>

     <job>

       <name>jobName1</name>

       <group>jobGroup1</group>

       <description>jobDesciption1</description>

       <job-type>QuartzDemo.SimpleJob1, QuartzDemo</job-type>

       <durable>true</durable>

       <recover>false</recover>

       <job-data-map>

         <entry>

           <key>key0</key>

           <value>value0</value>

         </entry>

         <entry>

           <key>key1</key>

           <value>value1</value>

         </entry>

         <entry>

           <key>key2</key>

           <value>value2</value>

         </entry>

       </job-data-map>

     </job>

     <trigger>

       <simple>

         <name>simpleName</name>

         <group>simpleGroup</group>

         <description>SimpleTriggerDescription</description>

         <job-name>jobName1</job-name>

         <job-group>jobGroup1</job-group>

         <start-time>2015-12-02T10:15:00.0Z</start-time>

         <end-time>2020-05-04T18:13:51.0Z</end-time>

         <misfire-instruction>SmartPolicy</misfire-instruction>

         <repeat-count>100</repeat-count>

         <repeat-interval>1000</repeat-interval>

       </simple>

     </trigger>

   </schedule>

 </job-scheduling-data>

 <?xml version="1.0" encoding="UTF-8"?>

 <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>

     <job>

       <name>SimpleJob1</name>

       <group>myJobGroup1</group>

       <description>SimpleJob1</description>

       <job-type>QuartzDemo.SimpleJob1, QuartzDemo</job-type>

       <durable>true</durable>

       <recover>false</recover>

       <job-data-map>

         <entry>

           <key>author</key>

           <value>jackwangcumt</value>

         </entry>

           <entry>

           <key>blog</key>

           <value>isaboy</value>

         </entry>

         <entry>

           <key>jobType</key>

           <value>XML Plugin Job</value>

         </entry>

       </job-data-map>

     </job>

     <trigger>

       <cron>

         <name>trigger1</name>

         <group>myTriggerGroup</group>

         <job-name>SimpleJob1</job-name>

         <job-group>myJobGroup1</job-group>

         <cron-expression>0/2 * * * * ?</cron-expression>

       </cron>

     </trigger>

   </schedule>

 </job-scheduling-data>

4 效果

(可以将下图在另一个页签打开,看无压缩GIF图片)