数码控科技猎奇Iphone动漫星座游戏电竞lolcosplay王者荣耀攻略allcnewsBLOGNEWSBLOGASKBLOGBLOGZSK全部技术问答问答技术问答it问答代码软件新闻开发博客电脑/网络手机/数码笔记本电脑互联网操作系统软件硬件编程开发360产品资源分享电脑知识文档中心IT全部全部分类全部分类技术牛文全部分类教程最新网页制作cms教程平面设计媒体动画操作系统网站运营网络安全服务器教程数据库工具网络安全软件教学vbscript正则表达式javascript批处理更多»编程更新教程更新游戏更新allitnewsJava新闻网络医疗信息化安全创业站长电商科技访谈域名会议专栏创业动态融资创投创业学院 / 产品经理创业公司人物访谈营销开发数据库服务器系统虚拟化云计算嵌入式移动开发作业作业1常见软件all电脑网络手机数码生活游戏体育运动明星影音休闲爱好文化艺术社会民生教育科学医疗健康金融管理情感社交地区其他电脑互联网软件硬件编程开发360相关产品手机平板其他电子产品摄影器材360硬件通讯智能设备购物时尚生活常识美容塑身服装服饰出行旅游交通汽车购房置业家居装修美食烹饪单机电脑游戏网页游戏电视游戏桌游棋牌游戏手机游戏小游戏掌机游戏客户端游戏集体游戏其他游戏体育赛事篮球足球其他运动球类运动赛车健身运动运动用品影视娱乐人物音乐动漫摄影摄像收藏宠物幽默搞笑起名花鸟鱼虫茶艺彩票星座占卜书画美术舞蹈小说图书器乐声乐小品相声戏剧戏曲手工艺品历史话题时事政治就业职场军事国防节日风俗法律法规宗教礼仪礼节自然灾害360维权社会人物升学入学人文社科外语资格考试公务员留学出国家庭教育学习方法语文物理生物工程学农业数学化学健康知识心理健康孕育早教内科外科妇产科儿科皮肤科五官科男科整形中医药品传染科其他疾病医院两性肿瘤科创业投资企业管理财务税务银行股票金融理财基金债券保险贸易商务文书国民经济爱情婚姻家庭烦恼北京上海重庆天津黑龙江吉林辽宁河北内蒙古山西陕西宁夏甘肃青海新疆西藏四川贵州云南河南湖北湖南山东江苏浙江安徽江西福建广东广西海南香港澳门台湾海外地区

.Net Core中使用Quartz.Net实践记录

来源:脚本之家  责任编辑:小易  

一、介绍

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

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

Quartz.Net是根据Java的Quartz用C#改写而来,最新的版本是3.0.6,源码在https://github.com/quartznet/quartznet (本地下载)。

实践教程

以WebApi项目举例,用VS脚手架功能新建WebApi项目。

public void ConfigureServices(IServiceCollection services)
{
 services.AddMvc();
 services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();//注册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<string[]> 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<MyJob>()
    .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<MyJob>()
    .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 调度器

调度器就是将任务和触发器绑定,让触发器触发的时候去执行任务。

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。

您可能感兴趣的文章:


  • 本文相关:
  • .net下quartz.net的使用方法
  • 详解免费开源的dotnet任务调度组件quartz.net(.net组件介绍之五)
  • quartz.net调度框架配置解析
  • asp.net数据绑定databind使用方法
  • asp.net backgroundworker之在后台下载文件
  • asp.net 页面间传值方法小结
  • c# 数组查找与排序实现代码
  • repeater的footertemplate显示某列总计思路与代码
  • asp.net封装的sql数据库访问类
  • 使用customvalidator自定义验证控件检查是否有对listbox控件选择
  • asp.net下出现其中的组件“访问被拒绝”的解决方法
  • .net core cors中间件的深入讲解
  • .net微信开发 如何获取accesstoken
  • 免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved