一. 背景
工作中我们难免会有这样一些需求:定时任务,说白了就是在某一时间,让我们的程序来执行一些工作.
说道这里,也你会想到windows计划任务,但在一些时候它并没有很好的扩展性,一些复杂的任务并不能很好的完成,不能满足的我们的工作需要,我们需要的是一个集群部署的作业调度框架。
二. Quartz.Net介绍
Quartz.NET是一个开源的作业调度框架,非常适合在平时的工作中,定时轮询数据库同步,定时邮件通知,定时处理数据等。 Quartz.NET允许开发人员根据时间间隔(或天)来调度作业。它实现了作业和触发器的多对多关系,还能把多个作业与不同的触发器关联。整合了Quartz.NET的应用程序可以重用来自不同事件的作业,还可以为一个事件组合多个作业.
它一些很好的特性:
1:支持集群,作业分组,作业远程管理。
2:自定义精细的时间触发器,使用简单,作业和触发分离。
3:数据库支持,可以寄宿Windows服务,WebSite,winform等。
三. 实战
利用nuget来安装 Quartz.Net
Quartz框架的基础概念解释:
Scheduler 作业调度器。
IJob 作业接口,继承并实现Execute, 编写执行的具体作业逻辑。
JobBuilder 根据设置,生成一个详细作业信息(JobDetail)。
TriggerBuilder 根据规则,生产对应的Trigger
编写类CronTask.cs 实现IJob,在Execute方法里编写要处理的业务逻辑,系统就会按照Quartz的配置,定时处理。
public sealed class CronTask : IJob
{
private static Logger logger = LogManager.GetCurrentClassLogger();
public void Execute(IJobExecutionContext context)
{
//可以通过context对象来获取传递过来的一些数据数据
JobDataMap dataMap = context.MergedJobDataMap;
string tag = dataMap.GetString("tag");
string title = dataMap.GetString("title");
string content = dataMap.GetString("content");
string description = dataMap.GetString("description");
string tels = dataMap.GetString("tels");
//执行定时任务 发送短信
SendMsg(tels,content);
context.Scheduler.Shutdown();
logger.InfoFormat("定时任务测试");
}
//定义任务
public static void SetTask(string tag, string starttime, string title, string content, string description,string tels)
{
try
{
DateTime time = DateTime.Parse(starttime);
//下面用到的执行时间要使用Cron表达式(如:"/5 * * ? * *"),下面我会介绍一下
string cronstr = GetCron(time);
//从工厂中获取一个调度器实例化
IScheduler scheduler = StdSchedulerFactory.GetDefaultScheduler();
scheduler.Start();
var jobData = new JobDataMap();
jobData.Add("tag", tag);
jobData.Add("title", title);
jobData.Add("content", content);
jobData.Add("description", description);
jobData.Add("tels", tels);
IJobDetail job = JobBuilder.Create<CronTask>()
.WithIdentity("job", DateTime.Now.ToLongDateString())
.SetJobData(jobData)
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("msmtriger", "group")
.StartNow() //现在开始
.WithCronSchedule(cronstr)
.Build();
// ITrigger trigger2 = TriggerBuilder.Create()
// .WithIdentity("mytrigger", "group1")
// .StartNow()
// .WithCronSchedule("/5 * * ? * *") //时间表达式,5秒一次
// .Build();
scheduler.ScheduleJob(job, trigger);//把作业,触发器加入调度器。
}
catch (Exception ex)
{
logger.Error(ex);
}
}
public static string GetCron(DateTime dt)
{
string retulut = "";
retulut = string.Format("0,{0} 0,{1} 0,{2} {3} {4} ? {5}", dt.Second, dt.Minute, dt.Hour, dt.Day, dt.Month, dt.Year);
return retulut;
}
}
WithCronSchedule("") 拥有强大的Cron时间表达式,正常情况下WithSimpleSchedule(x) 已经满足大部分对日期设置的要求了。
上面说道的cron表达式可以参考:
http://www.cnblogs.com/yanweidie/p/3537144.html
里面的在线地址已经不能用了,我这里给大家准备了一个:
Quartz Cron表达式在线生成器