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

时间:2021-11-16 15:46:55

前言:

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

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

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

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

概念:

Scheduler        作业调度器

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

所有的scheduler都应该由SchedulerFactory来创建

 //创建scheduler
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

IJob             作业接口,继承并实现Execute, 编写执行的具体作业逻辑。

通过实现IJob接口来使你的.NET组件可以很简单地被scheduler执行

    public class ConsoleJob : IJob
    {
        public Task Execute(IJobExecutionContext context)
        {
            return Console.Out.WriteLineAsync($"执行作业");
        }
    }

JobBuilder       根据设置,生成一个详细作业信息(JobDetail)。

JobBuilder是一个建造者模式,链式建造。通过静态方法构建一个JobBuilder实例,然后再调用类方法Build()创建一个IJobDetail的实现。

public static JobBuilder Create(Type jobType)
{
    JobBuilder b = new JobBuilder();
    b.OfType(jobType);
    return b;
}

TriggerBuilder   根据规则,生产对应的Trigger,触发器可以规划执行任务

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

通过静态方法构建一个TriggerBuilder实例,然后再调用类方法Build()创建一个ITrigger的实现。

public static TriggerBuilder Create()
{
    return new TriggerBuilder();
}

根据任务设置触发的开始时间和结束时间

    /// <summary>
    /// 开始时间
    /// </summary>
    /// <param name="startTimeUtc"></param>
    /// <returns></returns>
    public TriggerBuilder StartAt(DateTimeOffset startTimeUtc)
    {
        startTime = startTimeUtc;
        return this;
    }
    /// <summary>
    /// 结束时间
    /// </summary>
    /// <param name="endTimeUtc"></param>
    /// <returns></returns>
    public TriggerBuilder EndAt(DateTimeOffset? endTimeUtc)
    {
        endTime = endTimeUtc;
        return this;
    }

步骤:

1、创建一个ISchedulerFactory,然后并且获取 Scheduler

2、启动 Scheduler

3、创建 job 任务

4、创建 trigger 触发器

5、使用触发器规划执行任务

开始:

首先创建一个windows服务项目

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

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

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

这个时候我们可以注意到两个方法: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 = )]
    public class SyncJob : IJob
    {
        public Task Execute(IJobExecutionContext context)
        {
            try
            {
                //每次执行 获取当前时间 输出当前时间
                //可以在这里编写每次定时执行需要的方法
                LogHelper.SaveLog());
            }
            catch (Exception ex)
            {
                LogHelper.SaveLog(ex);
            }

            return null;
        }
    }

四、创建trigger:(建立一个某个时间点的触发器,并且每5秒执行一次)

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

五、触发器执行任务:

            await sched.ScheduleJob(job, trigger);

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

        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);
            }

        }

安装

以管理员的身份打开cmd

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

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

运行:

间隔5秒执行一次后的效果:

通过日志的方式输出数据,查看效果

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

附加:

一、删除服务

以管理员的身份打开cmd

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

二、调试window服务

1)安装并运行服务

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

2)附加进程

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

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

3)在代码中加入断点进行调试

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

总结:

1.当我们在需要用到定时执行任务的时候,可以考虑使用通过window服务加上quartz组件结合的方式,实现对任务的定时执行,这也是在很多场景中可以实现的方法,比如:定时轮询数据库同步,定时邮件通知,定时处理数据等

2.通过管理工具显示当前执行的任务和执行情况,也利用调试工具调试Window服务中遇到的问题。

3.quartz还有更多的用法,可以参考资料:Quartz.Net官方文档   和  Quartz.Net开源地址