13518219792
本篇文章给大家分享的是有关Quartz.Net怎么在.Net Core项目中使用，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
创新互联建站-专业网站定制、快速模板网站建设、高性价比安新网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式安新网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖安新地区。费用合理售后完善，十多年实体公司更值得信赖。一、介绍
Quartz.NET是一个强大、开源、轻量的作业调度框架，是 OpenSymphony 的 Quartz API 的.NET移植，用C#改写，可用于winform和asp.net应用中。它灵活而不复杂。你能够用它来为执行一个作业而创建简单的或复杂的作业调度。它有很多特征，如：数据库支持，集群，插件，支持cron-like表达式等等。
实践教程
以WebApi项目举例，用VS脚手架功能新建WebApi项目。
public void ConfigureServices(IServiceCollection services)
{
services.AddMvc();
services.AddSingleton();//注册ISchedulerFactory的实例。
} [Route("api/[controller]")]
public class ValuesController : Controller
{
private readonly ISchedulerFactory _schedulerFactory;
private IScheduler _scheduler;
public ValuesController(ISchedulerFactory schedulerFactory)
{
this._schedulerFactory = schedulerFactory;
}
[HttpGet]
public async Task Get()
{
//1、通过调度工厂获得调度器
_scheduler = await _schedulerFactory.GetScheduler();
//2、开启调度器
await _scheduler.Start();
//3、创建一个触发器
var trigger = TriggerBuilder.Create()
.WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每两秒执行一次
.Build();
//4、创建任务
var jobDetail = JobBuilder.Create()
.WithIdentity("job", "group")
.Build();
//5、将触发器和任务器绑定到调度器中
await _scheduler.ScheduleJob(jobDetail, trigger);
return await Task.FromResult(new string[] { "value1", "value2" });
}
} public class MyJob : IJob//创建IJob的实现类，并实现Excute方法。
{
public Task Execute(IJobExecutionContext context)
{
return Task.Run(() =>
{
using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
{
sw.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss"));
}
});
}
}输出的结果：
2018-08-03 00-03-19
2018-08-03 00-03-20
2018-08-03 00-03-22
2018-08-03 00-03-24
2018-08-03 00-03-26
上面这种执行的Job没有参数，当需要参数可以通过下面两种方法传递参数：
1、在Trigger中添加参数值
var trigger3 = TriggerBuilder.Create()
.WithSimpleSchedule(x =>x.WithIntervalInSeconds(2).RepeatForever())//间隔2秒 一直执行
.UsingJobData("key1", 321) //通过在Trigger中添加参数值
.UsingJobData("key2", "123")
.WithIdentity("trigger2", "group1")
.Build();2、在Job中添加参数值
IJobDetail job = JobBuilder.Create() .UsingJobData("key1", 123)//通过Job添加参数值 .UsingJobData("key2", "123") .WithIdentity("job1", "group1") .Build();
通过下面方法在Job中获取参数值
public class MyJob : IJob
{
public Task Execute(IJobExecutionContext context)
{
var jobData = context.JobDetail.JobDataMap;//获取Job中的参数
var triggerData = context.Trigger.JobDataMap;//获取Trigger中的参数
var data = context.MergedJobDataMap;//获取Job和Trigger中合并的参数
var value1= jobData.GetInt("key1");
var value2= jobData.GetString("key2");
var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss");return Task.Run(() =>
{
using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
{
sw.WriteLine(dateString);
}
});
}
}当Job中的参数和Trigger中的参数名称一样时，用 context.MergedJobDataMap获取参数时，Trigger中的值会覆盖Job中的值。
3、上面那种情况只能适应那种，参数值不变的情况。
假如有这种情况，这次的参数值是上一次执行后计算的值，就不能使用上面方法了。如 每两秒实现累加一操作，现在初始值是0，如果按照上面那种获取值的操作，一直都是0+1，返回值一直都是1。为了满足这个情况，只需要加一个特性[PersistJobDataAfterExecution]。
[PersistJobDataAfterExecution]//更新JobDetail的JobDataMap的存储副本，以便下一次执行这个任务接收更新的值而不是原始存储的值
public class MyJob : IJob
{
public Task Execute(IJobExecutionContext context)
{
var jobData = context.JobDetail.JobDataMap;
var triggerData = context.Trigger.JobDataMap;
var data = context.MergedJobDataMap;
var value1 = jobData.GetInt("key1");
var value2 = jobData.GetString("key2");
var value3 = data.GetString("key2");
var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss");
Random random = new Random();
jobData["key1"] = random.Next(1, 20);//这里面给key赋值，下次再进来执行的时候，获取的值为更新的值，而不是原始值
jobData["key2"] = dateString;
return Task.Run(() =>
{
using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
{
sw.WriteLine($"{dateString} value1:{value1} value2:{value2}");
}
//context.Scheduler.DeleteJob(context.JobDetail.Key);
//context.Scheduler.Shutdown();
});
}
}三、Quartz.Net组成
Quartz主要有三部分组成任务(Job)、触发器(Trigger)和调度器(Schedule)。
3.1 任务
Job就是执行的作业，Job需要继承IJob接口，实现Execute方法。Job中执行的参数从Execute方法的参数中获取。
3.2 触发器
触发器常用的有两种：SimpleTrigger触发器和CronTrigger触发器。
SimpleTrigger:能是实现简单业务，如每隔几分钟，几小时触发执行，并限制执行次数。
var trigger = TriggerBuilder.Create()
.WithSimpleSchedule(x => x.WithIntervalInSeconds(2).WithRepeatCount(5))//间隔2秒 执行6次
.UsingJobData("key1", 321)
.WithIdentity("trigger", "group")
.Build();CronTrigger:Cron表达式包含7个字段，秒 分 时 月内日期 月 周内日期 年(可选)。
举例：
var trigger = TriggerBuilder.Create()
.WithCronSchedule("0 0 0 1 1 ?")// 每年元旦1月1日 0 点触发
.UsingJobData("key1", 321)
.UsingJobData("key2", "trigger-key2")
.WithIdentity("trigger4", "group14")
.Build();"0 15 10 * * ? *" 每天上午10:15触发
"0 0-5 14 * * ?" 每天下午2点到下午2:05期间的每1分钟触发
3.3 调度器
调度器就是将任务和触发器绑定，让触发器触发的时候去执行任务。
以上就是Quartz.Net怎么在.Net Core项目中使用，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。
