Window服务基于Quartz.Net组件实现定时任务调度（二）

2019 年 10 月 3 日
笔记

前言：

在上一章中，我们通过利用控制台实现定时任务调度，已经大致了解了如何基于Quartz.Net组件实现任务，至少包括三部分：job(作业），trigger（触发器），scheduler（调度器）。其中job是需要在一个定时任务中具体执行的业务逻辑，trigger通过规定job何时并按照何种指定的规则进行执行，最后job和trigger会被注册到scheduler中，利用scheduler（调度器）来负责协调job和trigger的搭配运行。

你是否在工作中会遇到需要软件具有自动执行任务的功能，但是又不希望直接启动软件来手动执行任务？

这个时候，我们可以考虑用到window服务，基于Quartz.Net组件定时轮询数据库同步，定时邮件通知，定时处理数据等功能。

开始：

首先创建一个windows服务项目

在创建好的项目中，Service1.cs文件中点击“单击此处切换到代码视图”切换到代码

这个时候我们可以注意到两个方法：OnStart （服务启动）和 OnStop（服务停止）

        /// <summary>          /// 服务启动          /// </summary>          /// <param name="args"></param>          protected override void OnStart(string[] args)          {          }

        /// <summary>          /// 服务停止          /// </summary>          protected override void OnStop()          {          }

一、创建一个scheduler的引用：

            ISchedulerFactory schedFact = new StdSchedulerFactory();              IScheduler sched = await schedFact.GetScheduler();

二、启动 scheduler：

            await sched.Start();

三、实现IJob:

SyncJob.cs 实现IJob，在Execute方法里编写要处理的业务逻辑，系统就会按照Quartz的配置，定时处理

    [Invoke(Name = "SyncJob", Remark = "Quartz服务", Group = "Quartz服务管理", Begin = "2018-05-01 12:00:00", Interval = 5)]      public class SyncJob : IJob      {          public Task Execute(IJobExecutionContext context)          {              try              {                  //每次执行 获取当前时间 输出当前时间                  //可以在这里编写每次定时执行需要的方法                  LogHelper.SaveLog("输出日志", "在当前时间:" + DateTime.Now + "--上一次执行时间：" + DateTime.Now.AddSeconds(-5));              }              catch (Exception ex)              {                  LogHelper.SaveLog(ex);              }                return null;          }      }

四、创建trigger：（建立一个某个时间点的触发器，并且每5秒执行一次）

            ITrigger trigger = TriggerBuilder.Create()                  .WithIdentity("trigger1", "group1")  //触发器 组                  .WithSimpleSchedule(x => x.WithIntervalInSeconds(5).RepeatForever())                  .Build();

五、触发器执行任务：

            await sched.ScheduleJob(job, trigger);

将几个步骤整合后代码如下：

        /// <summary>          /// 服务启动          /// </summary>          /// <param name="args"></param>          protected override void OnStart(string[] args)          {              Run().GetAwaiter().GetResult();              LogHelper.SaveLog("服务", "开始");          }          /// <summary>          /// 服务停止          /// </summary>          protected override void OnStop()          {              try              {                  if (scheduler != null)                  {                      scheduler.Shutdown();                  }              }              catch (Exception ex)              {                  LogHelper.SaveLog(ex);              }              LogHelper.SaveLog("服务", "结束");          }            IScheduler scheduler;          private async Task Run()          {              try              {                  NameValueCollection props = new NameValueCollection                  {                      { "quartz.serializer.type", "binary" }                  };                  StdSchedulerFactory factory = new StdSchedulerFactory(props);                  scheduler = await factory.GetScheduler();                    await scheduler.Start();                  Jobs.Jobs.Config(scheduler);              }              catch (SchedulerException ex)              {                  LogHelper.SaveLog(ex);              }            }