Net作业调度(二) - Quartz.Net进阶

介绍

前面我们介绍Quartz.Net的基本用法，但在实际应用中，往往有更多的特性需求。   比如记录job执行的执行历史，发邮件等。

目录

1：Quartz.Net插件

2：TriggerListener,JobListener

3：Cron表达式

4：Quartz.Net 线程池

5：总结

Quartz.Net插件

Quartz.net 自身提供了一个插件接口(ISchedulerPlugin)用来增加附加功能。 我们来看下官方定义：

  public interface ISchedulerPlugin
    {
        void Initialize(string pluginName, IScheduler sched);
       //关闭调度器
        void Shutdown();
        //插件启动
        void Start();
    }

　继承接口，实现自己的插件。

 public class MyPlugin : ISchedulerPlugin
    {
        public void  Initialize(string pluginName, IScheduler sched)
        {
            Console.WriteLine("实例化");
        }
        public  void Start()
        {
             Console.WriteLine("启动");
        }
        public  void Shutdown()
        {
            Console.WriteLine("关闭");
        }
    }

　　主函数里面配置我们实现的插件，注释部分，一句话搞定。

static void Main(string[] args)
        {
            var properties = new NameValueCollection();
           //MyPlugin 自定义名称。    "命名空间.类名,程序名称"
            properties["quartz.plugin.MyPlugin.type"] = "QuartzDemo3.MyPlugin,QuartzDemo3"; 

            var schedulerFactory = new StdSchedulerFactory(properties);
            var scheduler = schedulerFactory.GetScheduler();

            var job = JobBuilder.Create<HelloJob>()
                .WithIdentity("myJob", "group1")
                .Build();

            var trigger = TriggerBuilder.Create()
                                .WithIdentity("mytrigger", "group1")
                                .WithCronSchedule("/2 * * ? * *")
                                .Build();

            scheduler.ScheduleJob(job, trigger);
            scheduler.Start();
            Thread.Sleep(6000);
            scheduler.Shutdown(true);
            Console.ReadLine();

        }

　　运行结果如下：

TriggerListener，JobListener

ITriggerListener官方定义的接口，这里我们直接继承实现。

public class MyTriggerListener : ITriggerListener
    {
        private string name;

        public void TriggerComplete(ITrigger trigger, IJobExecutionContext context, SchedulerInstruction triggerInstructionCode)
        {
            Console.WriteLine("job完成时调用");
        }
        public void TriggerFired(ITrigger trigger, IJobExecutionContext context)
        {
            Console.WriteLine("job执行时调用");
        }
        public void TriggerMisfired(ITrigger trigger)
        {
            Console.WriteLine("错过触发时调用(例：线程不够用的情况下)");
        }
        public bool VetoJobExecution(ITrigger trigger, IJobExecutionContext context)
        {
            //Trigger触发后，job执行时调用本方法。true即否决，job后面不执行。
            return false;
        }
        public string Name { get { return name; } set { name = value; } }
    }

main函数添加：

           //添加监听器到指定的trigger
            scheduler.ListenerManager.AddTriggerListener(myJobListener, KeyMatcher<TriggerKey>.KeyEquals(new TriggerKey("mytrigger", "group1")));

            ////添加监听器到指定分类的所有监听器。
            //scheduler.ListenerManager.AddTriggerListener(myJobListener, GroupMatcher<TriggerKey>.GroupEquals("myJobGroup"));

            ////添加监听器到指定分类的所有监听器。
            //scheduler.ListenerManager.AddTriggerListener(myJobListener, GroupMatcher<TriggerKey>.GroupEquals("myJobGroup"));

           ////添加监听器到指定的2个分组。
            //scheduler.ListenerManager.AddTriggerListener(myJobListener, GroupMatcher<TriggerKey>.GroupEquals("myJobGroup"), GroupMatcher<TriggerKey>.GroupEquals("myJobGroup2"));

            ////添加监听器到所有的触发器上。
            //scheduler.ListenerManager.AddTriggerListener(myJobListener, GroupMatcher<TriggerKey>.AnyGroup());

            scheduler.Start();

JobListener同理，这里不多做描述。

Cron表达式

quartz中的cron表达式和Linux下的很像。 像  "/5 * * ? * * *"  这样的7位表达式，最后一位年非必选。 从左到右，下面是属性。

实例介绍

”0 0 10,14,16 * * ?"    每天10点，14点，16点 触发。

"0 0/5 14,18 * * ?"    每天14点或18点中，每5分钟触发 。

"0 4/15 14-18 * * ?"       每天14点到18点期间,  从第四分钟触发，每15分钟一次。

"0 15 10 ? * 6L"        每月的最后一个星期五上午10:15触发。

ThreadPool

properties["quartz.threadPool.threadCount"] = "5";  //线程池设置

这个线程池的设置，是指同时间。调度器能执行Job的最大数量。

quartz是用每个线程跑一个job。 上面的设置，可以解释是job并发时能执行5个job。剩下的job如果触发时间恰好到了，当前job会暂停状态，直到有可用的线程。

如果在指定的时间还没可用线程，会触发misfired。

quartz 给我提供了IThreadPool接口，我们也可以用其他的线程实现。下面是配置项。

properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";

一般来说我们的作业调度很少并发触发大量job。当然如果你有上百个，那就根据实际需要评估，增加线程数量吧。

总结

官方有LoggingTriggerHistoryPlugin，LoggingJobHistoryPlugin  已实现的，触发器和job历史记录的插件。

Quartz.Plugin 命名空间下有官方实现的一些插件，也可以自己增加扩展。

quartz中监听器还有SchedulerListener，使用方法基本一样。 另外监听器都是操作的。

本文基于自用经验，和官方文档代码来写的，有些是直接翻译的。 如果错误之处，希望请指出。