Quartz.NET实现作业调度

Quartz.NET实现作业调度

  • 商品编号:
    #66450567_664
    • 原价:
      免费
    • 会员价:
      免费
  • 分类:
    • V框架下载
    • V示例代码
  • 数量:

购物车中已存在此商品,请在购物车中操作单击跳转购物车

  • 开发者:笔记
  • 开发语言:C#,Quartz.NET
  • 开发环境:Visual Studio
  • 数据库:无
  • 商品架构:B/S
  • 代码管理工具:百度云盘
  • 编码格式:utf-8
  • 是否开源:是
  • 开源协议:BSD

目录

    一、Quartz.NET介绍

    二、依赖框架

        2.1、使用Nuget添加引用

            2.1.0、创建一个项目

            2.1.1、安装Nuget

            2.1.2、修改Nuget镜像

            2.1.3、使用nuget安装Quartz.NET

        2.2、手动引用

    三、应用框架

        3.1、定义要执行的任务

        3.2、创建一个调度器

        3.3、创建一个任务对象

        3.4、创建一个触发器

        3.5、将任务与触发器添加到调度器中并执行

        3.6、应用关闭时结束任务

        3.7、运行结果

        3.8、Global.asax中的完整代码

    四、框架说明

        4.1、Quartz的cron表达式

        4.2、其它帮助

    五、总结

一、Quartz.NET介绍

    Quartz.NET是一个强大、开源、轻量的作业调度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改写,可用于winform和asp.net应用中。它灵活而不复杂。你能够用它来为执行一个作业而创建简单的或复杂的作业调度。它有很多特征,如:数据库支持,集群,插件,支持cron-like表达式等等。

    通俗说它的功能是:比如说我想每天晚上2点让程序或网站执行某些代码,或者每隔5秒种我想查看是否有新的任务要处理等。

    官网:http://www.quartz-scheduler.net/

    源码:https://github.com/quartznet/quartznet

    示例:http://www.quartz-scheduler.net/documentation/quartz-2.x/quick-start.html

    其实Quartz是一个完全由java编写的开源作业调度框架,Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。而Quartz.Net与NPOI一样是一个DoNet平台下的对应版本。如果您使用Java直接访问这里就好了http://www.quartz-scheduler.org/

63651-20171013083602387-915538817

二、依赖框架

引入框架的方法非常简单你可以直接用nuget管理包也可以在项目中添加引用:

2.1、使用Nuget添加引用

2.1.0、创建一个项目

创建一个新项目,可以是ASP.NET MVC,WebForms,Winforms等多种.Net项目,这里使用的是VS2013,创建了一个MVC项目:

63651-20171012224623043-892226651

2.1.1、安装Nuget

新版本的Visual Studio默认情况是安装了Nuget的,如Visual Studio2015,但如果没有安装,打开VS菜单“工具”->"扩展与更新"

63651-20171012223016934-995666461

在扩展与更新中搜索“nuget”,可以新安装或卸载后升级:

63651-20171012223124121-123706179

2.1.2、修改Nuget镜像

为解决国内访问NuGet服务器速度不稳定的问题建议你最好选择一些镜像服务器,这样可以加速下载。

在Visual Studio中的添加方法是:打开“工具”->“选项”菜单

63651-20171012223454449-808476121

在左侧菜单中找到“NuGet包管理器”

63651-20171012223603887-982095821

点击右上角的加号,添加两个镜像,这些地址可以上网搜索,我使用的是如下两个:

https://nuget.cnblogs.com/v3/index.json

http://api.nuget.org/v3/index.json

设置一下顺序就OK了。

2.1.3、使用nuget安装Quartz.NET

点击“工具”->"NuGet包管理器"->“程序包管理器控制台”

63651-20171012224017871-1516557009

输入安装包的命令:

Install-Package Quartz

安装结果如下:

63651-20171012224302621-1085127632

此时包管理器中就下载了需要的程序集与相关文件,程序中也添加了引用。

63651-20171012224826621-890604781

2.2、手动引用

当然如果您不愿意使用nuget也可以下载到Quartz后直接引用,可以在本文尾部下载到框架。

63651-20171012225101012-991445052

框架下载地址:链接: https://pan.baidu.com/s/1slDM5JJ 密码: 9x5m

三、应用框架

假定我现在想当前的MVC应用每隔5秒钟向C:\Quartz.txt文件中记录当前时间。

因为这是一个Web应用,我想网站一启动时就开始该项工作,这里我们需要打开Global.asax,将代码写在Application_Start方法中

3.1、定义要执行的任务

定义一个类,实现Quartz.IJob接口,实现方法Execute,TimeJob.cs文件的代码如下:

using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace MvcApplication1
{
    public class TimeJob : IJob
    {
        public void Execute(IJobExecutionContext context)
        {
            //向c:\Quartz.txt写入当前时间并换行
            System.IO.File.AppendAllText(@"c:\Quartz.txt", DateTime.Now+Environment.NewLine);
        }
    }
}

3.2、创建一个调度器

调度器负责管理与控制任务的执行,在Global.asax文件的Application_Start方法中添加如下代码:

//调度器
IScheduler scheduler;
//调度器工厂
ISchedulerFactory factory;

//创建一个调度器
factory = new StdSchedulerFactory();
scheduler = factory.GetScheduler();
scheduler.Start();

3.3、创建一个任务对象

这个任务对象就是我们将要执行的工作,job1是名称,group1是组名。

//2、创建一个任务
IJobDetail job = JobBuilder.Create<TimeJob>().WithIdentity("job1", "group1").Build();

3.4、创建一个触发器

触发器定义了什么时间任务开始或每隔多久执行一次。

//3、创建一个触发器
//DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);
ITrigger trigger = TriggerBuilder.Create()
    .WithIdentity("trigger1", "group1")
    .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次
    //.StartAt(runTime)
    .Build();

3.5、将任务与触发器添加到调度器中并执行

//4、将任务与触发器添加到调度器中
scheduler.ScheduleJob(job, trigger);
//5、开始执行
scheduler.Start();

3.6、应用关闭时结束任务

当网站关闭时结束正在执行的工作,在Global.asax中的Application_End方法中添加如下代码:

protected void Application_End(object sender, EventArgs e)
{
    //   在应用程序关闭时运行的代码
    if (scheduler != null)
    {
        scheduler.Shutdown(true);
    }
}

shutdown方法中的参数true的意思为:是否等待任务的完成再结束。

3.7、运行结果

63651-20171012231926059-1482884164

3.8、Global.asax中的完整代码

using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Http;
using System.Web.Mvc;
using System.Web.Optimization;
using System.Web.Routing;

namespace MvcApplication1
{
    public class MvcApplication : System.Web.HttpApplication
    {
        //调度器
        IScheduler scheduler;
        //调度器工厂
        ISchedulerFactory factory;
        protected void Application_Start()
        {
            AreaRegistration.RegisterAllAreas();

            WebApiConfig.Register(GlobalConfiguration.Configuration);
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);
            AuthConfig.RegisterAuth();

            //1、创建一个调度器
            factory = new StdSchedulerFactory();
            scheduler = factory.GetScheduler();
            scheduler.Start();

            //2、创建一个任务
            IJobDetail job = JobBuilder.Create<TimeJob>().WithIdentity("job1", "group1").Build();

            //3、创建一个触发器
            //DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次
                //.StartAt(runTime)
                .Build();

            //4、将任务与触发器添加到调度器中
            scheduler.ScheduleJob(job, trigger);
            //5、开始执行
            scheduler.Start();
        }

        protected void Application_End(object sender, EventArgs e)
        {
            //   在应用程序关闭时运行的代码
            if (scheduler != null)
            {
                scheduler.Shutdown(true);
            }
        }
    }
}

四、框架说明

看官方的示例、源码或帮助文档可以了解更多的使用方法,官方帮助的地址是:https://www.quartz-scheduler.net/documentation/index.html

4.1、Quartz的cron表达式

cron表达式就是用于设定时间的一个字符串,在前面的代码中我们就用到了,如下所示:

//3、创建一个触发器
//DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);
ITrigger trigger = TriggerBuilder.Create()
    .WithIdentity("trigger1", "group1")
    .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次
    //.StartAt(runTime)
    .Build();

官方英文介绍:http://www.quartz-scheduler.net/documentation/quartz-2.x/tutorial/crontrigger.html

cron expressions 整体上还是非常容易理解的,只有一点需要注意:"?"号的用法,看下文可以知道“?”可以用在 day of month 和 day of week中,他主要是为了解决如下场景,如:每月的1号的每小时的31分钟,正确的表达式是:* 31 * 1 * ?,而不能是:* 31 * 1 * *,因为这样代表每周的任意一天。

/*
由7段构成:秒 分 时 日 月 星期 年(可选)

"-" :表示范围  MON-WED表示星期一到星期三
"," :表示列举 MON,WEB表示星期一和星期三
"*" :表是“每”,每月,每天,每周,每年等
"/" :表示增量:0/15(处于分钟段里面) 每15分钟,在0分以后开始,3/20 每20分钟,从3分钟以后开始
"?" :只能出现在日,星期段里面,表示不指定具体的值
"L" :只能出现在日,星期段里面,是Last的缩写,一个月的最后一天,一个星期的最后一天(星期六)
"W" :表示工作日,距离给定值最近的工作日
"#" :表示一个月的第几个星期几,例如:"6#3"表示每个月的第三个星期五(1=SUN...6=FRI,7=SAT)

如果Minutes的数值是 '0/15' ,表示从0开始每15分钟执行

如果Minutes的数值是 '3/20' ,表示从3开始每20分钟执行,也就是‘3/23/43’
*/

官方示例:

表达式解释
0 0 12 * * ?每天中午12点触发
0 15 10 ? * *每天上午10:15触发
0 15 10 * * ?每天上午10:15触发
0 15 10 * * ? *每天上午10:15触发
0 15 10 * * ? 20052005年的每天上午10:15触发
0 * 14 * * ?在每天下午2点到下午2:59期间的每1分钟触发
0 0/5 14 * * ?在每天下午2点到下午2:55期间的每5分钟触发
0 0/5 14,18 * * ?在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
0 0-5 14 * * ?在每天下午2点到下午2:05期间的每1分钟触发
0 10,44 14 ? 3 WED每年三月的星期三的下午2:10和2:44触发
0 15 10 ? * MON-FRI周一至周五的上午10:15触发
0 15 10 15 * ?每月15日上午10:15触发
0 15 10 L * ?每月最后一日的上午10:15触发
0 15 10 L-2 * ?每个月的第二天到最后一天的上午10:15触发
0 15 10 ? * 6L每月的最后一个星期五上午10:15触发
0 15 10 ? * 6L每个月最后一个星期五上午10时15分触发
0 15 10 ? * 6L 2002-20052002年至2005年的每月的最后一个星期五上午10:15触发
0 15 10 ? * 6#3每月的第三个星期五上午10:15触发
0 0 12 1/5 * ?每月每隔5天下午12点(中午)触发, 从每月的第一天开始
0 11 11 11 11 ?每11月11日上午11时11分触发

63651-20171012232811387-601242689

4.2、其它帮助

请查看帮助文档、示例或上网搜索,:),后面有空再补充吧

五、总结

1、实现定时任务的方法有很多,如果非常简单的话直接使用系统内置的Timer,Scheduler,Cache都是可以达到的,但要注意GC回收的问题,一般会定义成静态的。

2、本文只是非常粗浅的介绍了一下零配置的方法,您也可以选择使用XML配置的方式替代部分的硬编码。


权利声明:本站所有商品信息、客户评价等信息是初心商城重要的数据资源,未经许可,禁止非法转载使用。 注:本站商品信息均来自初心商城,其真实性、准确性和合法性由初心商城负责。

                  初心源说明:初心商城主要为程序员提供开发基础的代码源以及成熟项目,网站中所有的商品有提供收费版本的, 也有提供免费版本的,按照大家各自不同的需求进行购买。实实在在的让程序员只用专注于自己的业务实现你的小梦想, 如果您对我们的成果表示认同并且觉得对你有所帮助我们愿意接受来自各方面的支持^_^。

                  支持:用手机扫描二维码支付

                  支付宝支持我们 微信支持我们

                  您的支持将被用于:
                  1、持续深入的上传更多更好的源代码
                  2、建立更加完善的技术社区
                  3、完善现在系统出现各种问题
                  4、购买域名和租赁服务器

                  1、交易规则

                  2、发货方式

                  1、自动:在上方保障服务中标有自动发货的商品,拍下后,将会自动收到来自卖家的商品获取(下载)链接

                  2、手动:在上方保障服务中标有手动发货的商品,拍下后,卖家会收到邮件,也可通过QQ或订单中的电话联系对方。

                  3、退款说明

                  1、描述:源码描述(含标题)与实际源码不一致的(例:描述PHP实际为ASP、描述的功能实际缺少、版本不符等)

                  2、演示:有演示站时,与实际源码小于95%一致的(但描述中有"不保证完全一样、有变化的可能性"类似显著声明的除外)

                  3、发货:手动发货源码,在卖家未发货前,已申请退款的

                  4、服务:卖家不提供安装服务或需额外收费的(但描述中有显著声明的除外)

                  5、其它:如质量方面的硬性常规问题等

                  备注:经核实符合上述任一,均支持退款,但卖家予以积极解决问题则除外。交易中的商品,卖家无法对描述进行修改!

                  4、注意事项

                  1、客户买完之后未确认收货,将不会收到下载地址和下载码,确认收货之后才能收到下载地址和下载码。

                  2、在未拍下前,双方在QQ上所商定的内容,亦可成为纠纷评判依据(商定与描述冲突时,商定为准);

                  3、在商品同时有网站演示与图片演示,且站演与图演不一致时,默认按图演作为纠纷评判依据(特别声明或有商定除外);

                  4、在没有"无任何正当退款依据"的前提下,写有"一旦售出,概不支持退款"等类似的声明,视为无效声明;

                  5、虽然交易产生纠纷的几率很小,但请尽量保留如聊天记录这样的重要信息,以防产生纠纷时出现问题不明确的情况。

                  5、交易声明

                  1、本站作为直卖平台,依据交易合同(商品描述、交易前商定的内容)来保障交易的安全及买卖双方的权益;

                  2、非平台线上交易的商品,出现任何后果均与本站无关;无论卖家以何理由要求线下交易的,请联系管理举报。

                  初心Logo

                  初心商城| 初心系列| 初心博客| 初心公告| 系统反馈

                  © 2016-2018 山西米立信息技术有限公司 保留所有权利 京ICP备16055626号
                  违法和不良信息举报电话:186-2950-9347,本网站所列数据,除特殊说明,所有数据均出自我工作室
                  本网站兼容所有主流浏览器,不支持手机自适应