RDIFramework.NET框架基于Quartz.Net实现任务调度详解及效果展现
在上一篇Quartz.Net实现做业定时调度详解，咱们经过实例代码详细讲解与演示了基于Quartz.NET开发的详细方法。本篇咱们主要讲述基于RDIFramework.NET框架整合Quartz.NET，以实现任务调度,并对任务持久化操做的全过程。本文主要经过如下几个方面讲解：数据库
- 一、任务调度概述
- 2 任务调度管理
- 2.一、Cron表达式
- 2.二、建立用户过程调度任务
- 2.三、建立程序集任务
一、任务调度概述
任务调度在各类应用中都会存在，在业务系统中咱们为了调度一些自动执行的任务或从队列中消费一些消息，因此基本上都会涉及到后台服务的开发。在了解任务调度以前，咱们先了解一下实现任务调度的Quartz.NET框架。编程
Quartz.NET是一个开源的做业调度框架，是OpenSymphony 的 Quartz API的.NET移植，它用C#写成，可用于winform和asp.net应用中。它提供了巨大的灵活性而不牺牲简单性。你可以用它来为执行一个做业而建立简单的或复杂的调度。它有不少特征，如：数据库支持，集群，插件，支持cron-like表达式等等。你曾经须要应用执行一个任务吗？这个任务天天或每周星期二晚上11：30，或许仅仅每月的最后一天执行。一个自动执行而无须干预的任务在执行过程当中若是发生一个严重错误，应用可以知到其执行失败并尝试从新执行吗？你和你的团队是用.NET编程吗？若是这些问题中任何一个你回答是，那么你应该使用Quartz.NET调度器。 Quartz.NET容许开发人员根据时间间隔（或天）来调度做业。它实现了做业和触发器的多对多关系，还能把多个做业与不一样的触发器关联。整合了 Quartz.NET的应用程序能够重用来自不一样事件的做业，还能够为一个事件组合多个做业。api
总的来讲就是Quartz.NET是一个开源的做业调度框架，很是适合在平时的工做中，定时轮询数据库同步，定时邮件通知，定时处理数据等。 Quartz.NET容许开发人员根据时间间隔（或天）来调度做业。它实现了做业和触发器的多对多关系，还能把多个做业与不一样的触发器关联，配置灵活方便。至关于数据库中的 Job、Windows 的计划任务、Unix/Linux 下的 Cron，但 Quartz 能够把排程控制的更精细，对任务调度的领域问题进行了高度的抽象，实现做业的灵活调度。微信
咱们框架的任务调度就是基于Quartz.NET框架的整合使用，并对任务作了持久化的操做。微信开发
二、任务调度管理
“任务列表”管理模块是放在“系统配置”->“任务调度”下的“任务列表”，任务列表以下图所示。任务列表主界面左侧显示的是已经建立的任务，右侧为当前选中任务的执行状况列表。在左侧的任务列表最左边的操做栏，能够经过操做按钮对当前任务作删除、暂停、启动、删除任务日志的操做。app
在任务列表主界面顶部的工具栏中的按钮可用来建立任务，建立的任务分为两种类型：框架
建立用户过程调度任务。asp.net
建立程序集任务。jsp
每种类型下的任务又能够分为简单任务与复杂任务。简单任务相似于定时器每隔特定的间隔时间触发，复杂任务主要是主要是借助CronTrigger表达式来实现相似数据库中的计划任务类型的工做。使用CronTrigger你能够指定诸如“每一个周五中午”，或者“每一个工做日的9:30”或者“从每一个周1、周3、周五的上午9：00到上午10：00之间每隔五分钟”这样日程安排来触发。甚至像SimpleTrigger（简单任务）同样，CronTrigger也有一个StartTime以指定日程从何时开始，也有一个（可选的）EndTime以指定什么时候日程再也不继续。
下面的章节咱们分别对这两种任务类型作介绍。在介绍以前先了解学习一下Cron 表达式。分布式
2.一、Quartz的cron表达式
Cron表达式是一个字符串，字符串以5或6个空格隔开，分为6或7个域，每个域表明一个含义，Cron有以下两种语法格式：
（1） Seconds Minutes Hours DayofMonth Month DayofWeek Year
（2）Seconds Minutes Hours DayofMonth Month DayofWeek
1、结构
corn从左到右（用空格隔开）：秒 分 小时 月份中的日期 月份 星期中的日期 年份
2、各字段的含义
注意：每个域都使用数字，但还能够出现以下特殊字符，它们的含义是：
（1）：表示匹配该域的任意值。假如在Minutes域使用, 即表示每分钟都会触发事件。
（2）?：只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值，但实际不会。由于DayofMonth和DayofWeek会相互影响。例如想在每个月的20日触发调度，无论20日究竟是星期几，则只能使用以下写法： 13 13 15 20 * ?, 其中最后一位只能用？，而不能使用，若是使用表示无论星期几都会触发，实际上并非这样。
（3）-：表示范围。例如在Minutes域使用5-20，表示从5分到20分钟每分钟触发一次
（4）/：表示起始时间开始触发，而后每隔固定时间触发一次。例如在Minutes域使用5/20,则意味着5分钟触发一次，而25，45等分别触发一次.
（5）,：表示列出枚举值。例如：在Minutes域使用5,20，则意味着在5和20分每分钟触发一次。
（6）L：表示最后，只能出如今DayofWeek和DayofMonth域。若是在DayofWeek域使用5L,意味着在最后的一个星期四触发。
（7）W:表示有效工做日(周一到周五),只能出如今DayofMonth域，系统将在离指定日期的最近的有效工做日触发事件。例如：在 DayofMonth使用5W，若是5日是星期六，则将在最近的工做日：星期五，即4日触发。若是5日是星期天，则在6日(周一)触发；若是5日在星期一到星期五中的一天，则就在5日触发。另一点，W的最近寻找不会跨过月份 。
（8）LW:这两个字符能够连用，表示在某个月最后一个工做日，即最后一个星期五。
（9）#:用于肯定每月第几个星期几，只能出如今DayofMonth域。例如在4#2，表示某月的第二个星期三。
3、经常使用表达式例子
（1）0 0 2 1 * ? * 表示在每个月的1日的凌晨2点调整任务
（2）0 15 10 ? * MON-FRI 表示周一到周五天天上午10:15执行做业
（3）0 15 10 ? 6L 2002-2006 表示2002-2006年的每月的最后一个星期五上午10:15执行做
（4）0 0 10,14,16 * * ? 天天上午10点，下午2点，4点
（5）0 0/30 9-17 * * ? 朝九晚五工做时间内每半小时
（6）0 0 12 ? * WED 表示每一个星期三中午12点
（7）0 0 12 * * ? 天天中午12点触发
（8）0 15 10 ? * * 天天上午10:15触发
（9）0 15 10 * * ? 天天上午10:15触发
（10）0 15 10 * * ? * 天天上午10:15触发
（11）0 15 10 * * ? 2005 2005年的天天上午10:15触发
（12）0 * 14 * * ? 在天天下午2点到下午2:59期间的每1分钟触发
（13）0 0/5 14 * * ? 在天天下午2点到下午2:55期间的每5分钟触发
（14）0 0/5 14,18 * * ? 在天天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
（15）0 0-5 14 * * ? 在天天下午2点到下午2:05期间的每1分钟触发
（16）0 10,44 14 ? 3 WED 每一年三月的星期三的下午2:10和2:44触发
（17）0 15 10 ? * MON-FRI 周一至周五的上午10:15触发
（18）0 15 10 15 * ? 每个月15日上午10:15触发
（19）0 15 10 L * ? 每个月最后一日的上午10:15触发
（20）0 15 10 ? * 6L 每个月的最后一个星期五上午10:15触发
（21）0 15 10 ? * 6L 2002-2005 2002年至2005年的每个月的最后一个星期五上午10:15触发
（22）0 15 10 ? * 6#3 每个月的第三个星期五上午10:15触发
注：
（1）有些子表达式能包含一些范围或列表
例如：
子表达式（天（星期））能够为 “MON-FRI”，“MON，WED，FRI”，“MON-WED,SAT”
“*”字符表明全部可能的值，
所以，“”在子表达式（月）里表示每月的含义，“”在子表达式（天（星期））表示星期的每一天
“/”字符用来指定数值的增量
例如：在子表达式（分钟）里的“0/15”表示从第0分钟开始，每15分钟
在子表达式（分钟）里的“3/20”表示从第3分钟开始，每20分钟（它和“3，23，43”）的含义同样
“？”字符仅被用于天（月）和天（星期）两个子表达式，表示不指定值
当2个子表达式其中之一被指定了值之后，为了不冲突，须要将另外一个子表达式的值设为“？”
“L” 字符仅被用于天（月）和天（星期）两个子表达式，它是单词“last”的缩写
可是它在两个子表达式里的含义是不一样的。
在天（月）子表达式中，“L”表示一个月的最后一天
在天（星期）自表达式中，“L”表示一个星期的最后一天，也就是SAT
若是在“L”前有具体的内容，它就具备其余的含义了
例如：“6L”表示这个月的倒数第６天，“FRIL”表示这个月的最一个星期五
注意：在使用“L”参数时，不要指定列表或范围，由于这会致使问题
4、表达式生成器
有不少的cron表达式在线生成器，这里给你们推荐几款
http://www.pdtools.net/tools/becron.jsp
或者
2.二、建立用户过程调度任务
过程调度任务简单的理解就是能够执行SQL语句或存储过程等。建立用户过程调度任务以下图所示。
在建立用户过程调试界面，“过程SQL”就是执行的SQL语句或存储过程或函数等。过程参数就是过程SQL中的参数列表对应的参数值。建立的任务默认是简单任务，如上图咱们建立了一个每1分钟执行一次的简单过程任务，其实“无限次”选中就表示不限次数，不然能够指定执行的次数。要建立复杂任务能够单击“复杂任务”选项卡，以下图所示。
复杂任务中的各时间项的配置就是Cron表达式，每单击一个配置项，右侧都对该配置项进行了详细的设置说明。设置好后能够单击“检查表达式”来验证Cron表达式的正确性，以下图所示。
单击确认按钮便可成功建立任务。要删除、暂停、重启、删除任务日志，只需选中任务后单击当前任务左侧的操做按钮区域对应的操做按钮便可，以下图所示。
2.三、建立程序集任务
程序集任务简单的理解就是建立一个自动执行的C#方法，程序集任务与用户过程调度任务相似，也分简单的任务与复杂的任务，建立程序集任务以下图所示。
咱们在微信公众号开发系列-玩转微信开发-目录汇总系列文章中对微信开发进行了详细的讲解，咱们知道微信提供的API大多都是以微信分配给咱们的一个access_token为基础，Access Token至关于打开这些服务的钥匙，正常状况下会在7200秒内失效。对于access_tokenr的详细介绍可参考咱们的：微信公众号开发系列-四、获取接口调用凭证
前面的开发咱们都是失效后各自应用去从新获取access_token。虽然这样操做可行但不是理想的操做方式，理想的操做方式应该是后台定时自动刷新咱们获得的access_token。咱们可使用任务调度来实现access_token的获取。
在上图中咱们建立了一个每30分钟自动更新微信公众号开发中的access_token，配置项的中程序集名称格式为：命名空间+类，具体的开发方法能够参考咱们任务调度中的Job事例。编写的job只须要继承咱们的基类：ITaskJob，并实现如下方法便可。
一、public string RunJob(ref JobDataMap dataMap, string jobName, string id, string taskName) 二、public string RunJobBefore(JobEntity jobModel) 三、public string CloseJob(JobEntity jobModel)
参考代码以下：
public class WeChatGetTokenJob : ITaskJob
{
public string RunJob(ref JobDataMap dataMap, string jobName, string id, string taskName)
{
int returnValue = 0;
List<KeyValuePair<string, object>> parmeters = new List<KeyValuePair<string, object>>
{
new KeyValuePair<string, object>(WeixinOfficialAccountTable.FieldDeleteMark, 0)
};
var listOfficialAccount = BaseEntity.GetList<WeixinOfficialAccountEntity>(RDIFrameworkService.Instance.WeixinBasicService.GetOfficialAccountDTByValues(parmeters));
if (listOfficialAccount != null && listOfficialAccount.Count() > 0)
{
foreach (WeixinOfficialAccountEntity entity in listOfficialAccount)
{
try
{
if (entity.Category == (int)WeChatSubscriberEnum.EnterpriseSubscriber)
{
if (!string.IsNullOrEmpty(entity.AppId) && !string.IsNullOrEmpty(entity.AppSecret))
{
//方法一：使用Senparc.WeiXin SDK的方法
entity.AccessToken = Senparc.Weixin.QY.CommonAPIs.CommonApi.GetToken(entity.AppId, entity.AppSecret).access_token;
entity.ModifiedBy = "job_rdiframework";
//方式二，直接调用微信的接口方法
//var url = string.Format("https://api.weixin.qq.com/cgi-bin/token?grant_type={0}&appid={1}&secret={2}", "client_credential".AsUrlData(), entity.AppId.AsUrlData(), entity.AppSecret.AsUrlData());
//AccessTokenResult result = Get.GetJson<AccessTokenResult>(url);
//entity.AccessToken = result.access_token;
entity.ModifiedOn = DateTime.Now;
returnValue += RDIFrameworkService.Instance.WeixinBasicService.UpdateOfficialAccount(entity);
}
}
else
{
if (!string.IsNullOrEmpty(entity.AppId) && !string.IsNullOrEmpty(entity.AppSecret))
{
//方法一：使用Senparc.WeiXin SDK的方法
entity.AccessToken = Senparc.Weixin.MP.CommonAPIs.CommonApi.GetToken(entity.AppId, entity.AppSecret).access_token;
entity.ModifiedBy = "job_rdiframework";
//方式二，直接调用微信的接口方法
//var url = string.Format("https://api.weixin.qq.com/cgi-bin/token?grant_type={0}&appid={1}&secret={2}", "client_credential".AsUrlData(), entity.AppId.AsUrlData(), entity.AppSecret.AsUrlData());
//AccessTokenResult result = Get.GetJson<AccessTokenResult>(url);
//entity.AccessToken = result.access_token;
entity.ModifiedOn = DateTime.Now;
returnValue += RDIFrameworkService.Instance.WeixinBasicService.UpdateOfficialAccount(entity);
}
}
}
catch (Exception ex)
{
LogHelper.WriteException(ex);
}
}
}
if (returnValue > 0)
{
TaskJob.UpdateState(jobName, 1, "成功");
}
return "批量更新Access_Token！";
}
public string RunJobBefore(JobEntity jobModel)
{
Log.Write("RunJobBefor", jobModel.taskName,"运行");
List<KeyValuePair<string, object>> parmeters = new List<KeyValuePair<string, object>>
{
new KeyValuePair<string, object>(WeixinOfficialAccountTable.FieldDeleteMark, 0)
};
var listOfficialAccount = BaseEntity.GetList<WeixinOfficialAccountEntity>(RDIFrameworkService.Instance.WeixinBasicService.GetOfficialAccountDTByValues(parmeters));
if (listOfficialAccount == null || listOfficialAccount.Count() <= 0)
{
return "没有符合获取Access_Token的数据！";
}
return null;
}
public string CloseJob(JobEntity jobModel)
{
Log.Write("CloseJob", jobModel.taskName,"关闭");
TaskJob.UpdateState(jobModel.id, 3, "挂起");
return "关闭获取Access_Token任务";
}
}
三、相关文章参考
一路走来数个年头，感谢RDIFramework.NET框架的支持者与使用者，你们能够经过下面的地址了解详情。
RDIFramework.NET官方网站：http://www.rdiframework.net/
RDIFramework.NET官方博客：http://blog.rdiframework.net/
同时须要说明的，之后的全部技术文章以官方网站为准，欢迎你们收藏！
RDIFramework.NET框架由专业团队长期打造、一直在更新、一直在升级，请放心使用！
欢迎关注RDIFramework.net框架官方公众微信（微信号：guosisoft），及时了解最新动态。
扫描二维码当即关注
- 1. RDIFramework.NET框架基于Quartz.Net实现任务调度详解及效果展现
- 2. ASP.NET MVC5 实现基于Quartz.NET任务调度
- 3. 任务调度之集群（基于Quartz.net）
- 4. .NET 任务调度 ，基于Quartz.Net
- 5. 基于taskctl实现kettle任务调度
- 6. Quartz.NET做业调度框架详解
- 7. Quartz.NET实现做业调度 Quartz.NET实现做业调度
- 8. windows 服务实现定时任务调度（Quartz.Net）
- 9. .net Windows服务采用Quartz.NET实现任务调度
- 10. TopShelf+Quartz.net实现基于window服务的定时调度
- 更多相关文章...
- • Spring声明式事务管理（基于XML方式实现） - Spring教程
- • Spring声明式事务管理（基于Annotation注解方式实现） - Spring教程
- • ☆基于Java Instrument的Agent实现
- • Spring Cloud 微服务实战(三) - 服务注册与发现
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. RDIFramework.NET框架基于Quartz.Net实现任务调度详解及效果展现
- 2. ASP.NET MVC5 实现基于Quartz.NET任务调度
- 3. 任务调度之集群（基于Quartz.net）
- 4. .NET 任务调度 ，基于Quartz.Net
- 5. 基于taskctl实现kettle任务调度
- 6. Quartz.NET做业调度框架详解
- 7. Quartz.NET实现做业调度 Quartz.NET实现做业调度
- 8. windows 服务实现定时任务调度（Quartz.Net）
- 9. .net Windows服务采用Quartz.NET实现任务调度
- 10. TopShelf+Quartz.net实现基于window服务的定时调度