最新要闻
- 【新视野】GPT已长出眼睛耳朵 周鸿祎:人工智能将会产生意识
- 看点:苏州天使母基金合作子基金接连完成投资
- 曹德旺谈人工智能:能做饭吃吗?如果大家都去研究会饿死
- 当前看点!南方新一轮强降雨将上线!北方大部气温“狂飙” 最高飙到25度
- 今日观点!12款随便挑 太平鸟印花T恤清仓:到手69元
- 全球观热点:苹果WWDC 2023日期曝光!iOS 17首秀来了:或不再支持iPhone X/8
- 广东突降冰雹 多车被砸毁容!保险给赔吗?
- 事关出生证明、免税购物、高铁新路线!4月一大波新规来了
- 精选!AMD新一代APU曝光:大小核架构终于上了
- 动态:我国首次实现固态氢能发电并网,“绿电”与“绿氢”灵活转换
- 易烊千玺代言!九号电动两轮车国内出货突破150万辆
- 转型电动化 韩系车在中国还有救吗?
- 老人故意推倒摩托车案胜诉 老人儿子需赔1.6万!车主回应
- 速讯:孤芳自赏是哪一期蒙面唱将
- 【全球热闻】“韩国宾利”能拿下中国人吗?
- 焦点观察:票房破40亿中国影史第10!《流浪地球2》4月14日上线咪咕视频
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
世界观点:.NET6+Quartz实现定时任务
在实际工作中,经常会有一些需要定时操作的业务,如:定时发邮件,定时统计信息等内容,那么如何实现才能使得我们的项目整齐划一呢?本文通过一些简单的小例子,简述在.Net6+Quartz实现定时任务的一些基本操作,及相关知识介绍,仅供学习分享使用,如有不足之处,还请指正。
什么是定时任务?
定时任务,也叫任务调度,是指在一定的载体上,根据具体的触发规则,执行某些操作。所以定时任务需要满足三个条件:载体(Scheduler),触发规则(Trigger),具体业务操作(Job)。如下所示:
什么是Quartz?
Quartz 是一个开源的作业调度框架,它完全由 Java 写成,并设计用于 J2SE 和 J2EE 应用中。它提供了巨大的灵 活性而不牺牲简单性。你能够用它来为执行一个作业而创建简单的或复杂的调度。它有很多特征,如:数据库支持,集群,插件,EJB 作业预构 建,JavaMail 及其它,支持 cron-like 表达式等等。虽然Quartz最初是为Java编写的,但是目前已经有.Net版本的Quartz,所以在.Net中应用Quartz已经不再是奢望,而是轻而易举的事情了。
(资料图片仅供参考)
Github上开源网址为:https://github.com/quartznet
关于Quartz的快速入门和API文档,可以参考:https://www.quartz-scheduler.net/documentation/quartz-3.x/quick-start.html
涉及知识点
在Quartz框架中,主要接口和API如下所示:
其中IScheduler,ITrigger ,IJob三者之间的关系,如下所示:
Quartz安装
为了方便,本示例创建一个基于.Net6.0的控制台应用程序,在VS2022中,通过Nuget包管理器进行安装,如下所示:
创建一个简单的定时器任务
要开发一个简单,完整且能运行的定时器任务,步骤如下所示:
1. 创建工作单元Job
创建任务需要实现IJob接口,如下所示:
1 using Quartz; 2 using System.Diagnostics; 3 4 namespace DemoQuartz.QuartzA.Job 5 { 6 ///7 /// 测试任务,实现IJob接口 8 /// 9 public class TestJob : IJob10 {11 public TestJob()12 {13 Console.WriteLine("执行构造函数");//表示每一次计划执行,都是一次新的实例14 }15 16 public Task Execute(IJobExecutionContext context)17 {18 return Task.Run(() =>19 {20 Console.WriteLine($"******************************");21 Console.WriteLine($"测试信息{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}");22 Console.WriteLine($"******************************");23 Console.WriteLine();24 });25 }26 }27 }
2. 创建时间轴Scheduler
时间轴也是任务执行的载体,可以通过StdSchedulerFactory进行获取,如下所示:
1 //创建计划单元(时间轴,载体)2 StdSchedulerFactory schedulerFactory = new StdSchedulerFactory();3 var scheduler = await schedulerFactory.GetScheduler();4 await scheduler.Start();
3. 创建触发规则Trigger
触发规则就是那些时间点执行任务,可通过TriggerBuilder进行构建,如下所示:
1 //Trigger时间触发机制2 var trigger = TriggerBuilder.Create()3 .WithIdentity("TestTrigger","TestGroup")4 //.StartNow() //立即执行5 .WithSimpleSchedule(w=>w.WithIntervalInSeconds(5).WithRepeatCount(5))//.RepeatForever()//无限循环6 //.WithCronSchedule("5/10 * * * * ?") //通过Cron表达式定制时间触发规则, 示例表示从5开始,每隔10秒一次7 .Build();
4. 创建任务描述
任务描述定义了具体的任务名称,分组等内容。可通过JobBuilder进行构建,如下所示:
1 //Job详细描述2 var jobDetail = JobBuilder.Create()3 .WithDescription("这是一个测试Job")4 .WithIdentity("TestJob", "TestGroup")5 .Build();
5. 建立三者联系
通过载体,将规则和工作单元串联起来,如下所示:
1 //把时间和任务通过载体关联起来2 await scheduler.ScheduleJob(jobDetail, trigger);
6. 简单示例测试
通过运行程序,示例结果如下所示:
传递参数
在Quartz框架下,如果需要给执行的Job传递参数,可以通过两种方式:
jobDetail.JobDataMap,工作描述时通过JobDataMap传递参数。
trigger.JobDataMap, 时间触发时通过JobDataMap传递参数。
在Job工作单元中,可以通过Context中对应的JobDataMap获取参数。
传递参数,如下所示:
1 //传递参数 2 jobDetail.JobDataMap.Add("name", "Alan"); 3 jobDetail.JobDataMap.Add("age", 20); 4 jobDetail.JobDataMap.Add("sex", true); 5 6 7 //trigger同样可以传递参数 8 trigger.JobDataMap.Add("like1", "meimei"); 9 trigger.JobDataMap.Add("like2", "football");10 trigger.JobDataMap.Add("like3", "sing");
获取参数,如下所示:
1 //获取参数 2 var name = context.JobDetail.JobDataMap.GetString("name"); 3 var age = context.JobDetail.JobDataMap.GetInt("age"); 4 var sex = context.JobDetail.JobDataMap.GetBoolean("sex") ? "男" : "女"; 5 6 var like1 = context.Trigger.JobDataMap.GetString("like1"); 7 var like2 = context.Trigger.JobDataMap.GetString("like2"); 8 var like3 = context.Trigger.JobDataMap.GetString("like3"); 9 10 //context.MergedJobDataMap.GetString("aa");//注意如果使用MergedJobDataMap,JobDetail和Trigger中用到相同的Key,则后面设置的会覆盖前面设置的。
注意:如果使用MergedJobDataMap,JobDetail和Trigger中用到相同的Key,则后面设置的会覆盖前面设置的。
任务特性
假如我们的定时任务,执行一次需要耗时比较久,而且后一次执行需要等待前一次完成,并且需要前一次执行的结果作为参考,那么就需要设置任务的任性。因为默认情况下,工作单元在每一次运行都是一个新的实例,相互之间独立运行,互不干扰。所以如果需要存在一定的关联,就要设置任务的特性,主要有两个,如下所示:
- [PersistJobDataAfterExecution]//在执行完成后,保留JobDataMap数据
- [DisallowConcurrentExecution]//不允许并发执行,即必须等待上次完成后才能执行下一次
以上两个特性,只需要标记在任务对应的类上即可。标记上后,只需要往对应的JobDataMap中添加值即可。
监听器
在Quartz框架下,有三种监听器,分别是:时间轴监听器ISchedulerListener,触发规则监听器ITriggerListener,任务监听器IJobListener。要实现对应监听器,实现对应接口即可。实现监听器步骤:
1. 创建监听器
根据不同的需要,可以创建不同的监听器,如下所示:
时间轴监听器SchedulerListener
1 public class TestSchedulerListener : ISchedulerListener 2 { 3 public Task JobAdded(IJobDetail jobDetail, CancellationToken cancellationToken = default) 4 { 5 return Task.Run(() => { 6 Console.WriteLine("Test Job is added."); 7 }); 8 } 9 10 public Task JobDeleted(JobKey jobKey, CancellationToken cancellationToken = default) 11 { 12 return Task.Run(() => { 13 Console.WriteLine("Test Job is deleted."); 14 }); 15 } 16 17 public Task JobInterrupted(JobKey jobKey, CancellationToken cancellationToken = default) 18 { 19 return Task.Run(() => { 20 Console.WriteLine("Test Job is Interrupted."); 21 }); 22 } 23 24 public Task JobPaused(JobKey jobKey, CancellationToken cancellationToken = default) 25 { 26 return Task.Run(() => { 27 Console.WriteLine("Test Job is paused."); 28 }); 29 } 30 31 public Task JobResumed(JobKey jobKey, CancellationToken cancellationToken = default) 32 { 33 return Task.Run(() => { 34 Console.WriteLine("Test Job is resumed."); 35 }); 36 } 37 38 public Task JobScheduled(ITrigger trigger, CancellationToken cancellationToken = default) 39 { 40 return Task.Run(() => { 41 Console.WriteLine("Test Job is scheduled."); 42 }); 43 } 44 45 public Task JobsPaused(string jobGroup, CancellationToken cancellationToken = default) 46 { 47 return Task.Run(() => { 48 Console.WriteLine("Test Jobs is paused."); 49 }); 50 } 51 52 public Task JobsResumed(string jobGroup, CancellationToken cancellationToken = default) 53 { 54 return Task.Run(() => { 55 Console.WriteLine("Test Jobs is resumed."); 56 }); 57 } 58 59 public Task JobUnscheduled(TriggerKey triggerKey, CancellationToken cancellationToken = default) 60 { 61 return Task.Run(() => { 62 Console.WriteLine("Test Jobs is un schedulered."); 63 }); 64 } 65 66 public Task SchedulerError(string msg, SchedulerException cause, CancellationToken cancellationToken = default) 67 { 68 return Task.Run(() => { 69 Console.WriteLine("Test scheduler is error."); 70 }); 71 } 72 73 public Task SchedulerInStandbyMode(CancellationToken cancellationToken = default) 74 { 75 return Task.Run(() => { 76 Console.WriteLine("Test scheduler is standby mode."); 77 }); 78 } 79 80 public Task SchedulerShutdown(CancellationToken cancellationToken = default) 81 { 82 return Task.Run(() => { 83 Console.WriteLine("Test scheduler is shut down."); 84 }); 85 } 86 87 public Task SchedulerShuttingdown(CancellationToken cancellationToken = default) 88 { 89 return Task.Run(() => { 90 Console.WriteLine("Test scheduler is shutting down."); 91 }); 92 } 93 94 public Task SchedulerStarted(CancellationToken cancellationToken = default) 95 { 96 return Task.Run(() => { 97 Console.WriteLine("Test scheduleer is started."); 98 }); 99 }100 101 public Task SchedulerStarting(CancellationToken cancellationToken = default)102 {103 return Task.Run(() => {104 Console.WriteLine("Test scheduler is starting.");105 });106 }107 108 public Task SchedulingDataCleared(CancellationToken cancellationToken = default)109 {110 return Task.Run(() => {111 Console.WriteLine("Test scheduling is cleared.");112 });113 }114 115 public Task TriggerFinalized(ITrigger trigger, CancellationToken cancellationToken = default)116 {117 return Task.Run(() => {118 Console.WriteLine("Test trigger is finalized.");119 });120 }121 122 public Task TriggerPaused(TriggerKey triggerKey, CancellationToken cancellationToken = default)123 {124 return Task.Run(() => {125 Console.WriteLine("Test trigger is paused.");126 });127 }128 129 public Task TriggerResumed(TriggerKey triggerKey, CancellationToken cancellationToken = default)130 {131 return Task.Run(() => {132 Console.WriteLine("Test trigger is resumed.");133 });134 }135 136 public Task TriggersPaused(string? triggerGroup, CancellationToken cancellationToken = default)137 {138 return Task.Run(() => {139 Console.WriteLine("Test triggers is paused.");140 });141 }142 143 public Task TriggersResumed(string? triggerGroup, CancellationToken cancellationToken = default)144 {145 return Task.Run(() => {146 Console.WriteLine("Test triggers is resumed.");147 });148 }149 }
触发规则监听器TriggerListener
1 ///2 /// 触发器监听 3 /// 4 public class TestTriggerListener : ITriggerListener 5 { 6 public string Name => "TestTriggerListener"; 7 8 public Task TriggerComplete(ITrigger trigger, IJobExecutionContext context, SchedulerInstruction triggerInstructionCode, CancellationToken cancellationToken = default) 9 {10 //任务完成11 return Task.Run(() => {12 Console.WriteLine("Test trigger is complete.");13 14 });15 }16 17 public Task TriggerFired(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)18 {19 return Task.Run(() => {20 Console.WriteLine("Test trigger is fired.");21 22 });23 }24 25 public Task TriggerMisfired(ITrigger trigger, CancellationToken cancellationToken = default)26 {27 return Task.Run(() => {28 Console.WriteLine("Test trigger is misfired.");29 30 });31 }32 33 public TaskVetoJobExecution(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)34 {35 return Task.Run(() => {36 Console.WriteLine("Test trigger is veto.");37 return false;//是否终止38 });39 }40 }
JobListener任务监听器
1 ///2 /// TestJob监听器 3 /// 4 public class TestJobListener : IJobListener 5 { 6 public string Name => "TestJobListener"; 7 8 public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default) 9 {10 //任务被终止时11 return Task.Run(() => {12 Console.WriteLine("Test Job is vetoed.");13 });14 }15 16 public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default)17 {18 //任务被执行时19 return Task.Run(() => {20 Console.WriteLine("Test Job is to be executed.");21 });22 }23 24 public Task JobWasExecuted(IJobExecutionContext context, JobExecutionException? jobException, CancellationToken cancellationToken = default)25 {26 //任务已经执行27 return Task.Run(() => {28 Console.WriteLine("Test Job was executed.");29 });30 }31 }
2. 添加监听
在时间轴上的监听管理器中进行添加,如下所示:
1 //增加监听2 scheduler.ListenerManager.AddJobListener(new TestJobListener());3 scheduler.ListenerManager.AddTriggerListener(new TestTriggerListener());4 scheduler.ListenerManager.AddSchedulerListener(new TestSchedulerListener());
日志管理
在Quartz框架中,创建之前会进行日志创建检测,所以如果需要获取框架中的日志信息,可以进行创建实现ILogProvider,如下所示:
1 public class TestLogProvider : ILogProvider 2 { 3 public Logger GetLogger(string name) 4 { 5 return (level, func, exception, parameters) => 6 { 7 if (level >= Quartz.Logging.LogLevel.Info && func != null) 8 { 9 Console.WriteLine("[" + DateTime.Now.ToLongTimeString() + "] [" + level + "] " + func(), parameters);10 }11 return true;12 };13 }14 15 public IDisposable OpenMappedContext(string key, object value, bool destructure = false)16 {17 throw new NotImplementedException();18 }19 20 public IDisposable OpenNestedContext(string message)21 {22 throw new NotImplementedException();23 }24 }
然后在当前的Scheduler中,添加日志即可,如下所示:
1 //日志2 LogProvider.SetCurrentLogProvider(new TestLogProvider());
完整示例
在添加了监听器,日志,参数传递,任务特性后,完整的目录结构,如下所示:
示例截图
以上就是.Net6.0+Quartz开发控制台定时任务调度的全部内容。以上任务都是硬编码的固定程序,包括任务的启停,那么如果能通过可视化界面来创建以及管理任务,是不是一件很爽的事情呢,这也是后续需要探讨的内容。
关键词:
世界观点:.NET6+Quartz实现定时任务
当前观察:logback的使用和原理
【新视野】GPT已长出眼睛耳朵 周鸿祎:人工智能将会产生意识
环球看热讯:状态观测器(一)
看点:苏州天使母基金合作子基金接连完成投资
曹德旺谈人工智能:能做饭吃吗?如果大家都去研究会饿死
当前看点!南方新一轮强降雨将上线!北方大部气温“狂飙” 最高飙到25度
今日观点!12款随便挑 太平鸟印花T恤清仓:到手69元
全球观热点:苹果WWDC 2023日期曝光!iOS 17首秀来了:或不再支持iPhone X/8
广东突降冰雹 多车被砸毁容!保险给赔吗?
事关出生证明、免税购物、高铁新路线!4月一大波新规来了
精选!AMD新一代APU曝光:大小核架构终于上了
动态:我国首次实现固态氢能发电并网,“绿电”与“绿氢”灵活转换
易烊千玺代言!九号电动两轮车国内出货突破150万辆
转型电动化 韩系车在中国还有救吗?
老人故意推倒摩托车案胜诉 老人儿子需赔1.6万!车主回应
全球关注:读Java性能权威指南(第2版)笔记28_线程和同步性能中
速讯:孤芳自赏是哪一期蒙面唱将
【全球热闻】“韩国宾利”能拿下中国人吗?
焦点观察:票房破40亿中国影史第10!《流浪地球2》4月14日上线咪咕视频
焦点快看:叙利亚外交部谴责美国对叙发动敌对行动
使用 Linux dd 命令测试磁盘读写性能
国际短信平台接口调用的方法步骤,简单5步快速教程
全球信息:Java之大数加减乘除——构建类
张译包场张颂文的新电影《不止不休》!猫眼评分9.3分
世界快消息!2026年亚运会将不建设运动员村:为了削减开支
焦点资讯:3年来最盛大红毯叫停:邓超激动得像买票进场 胡歌刘亦菲杨幂同框梦回仙剑
当前速看:国内这些城市地标为地球熄灯一小时:有你认识的吗?
小米OPPO和vivo实现突破性跨越!微信聊天记录能互相迁移了
天天微资讯!武汉一小伙考研出分后失眠多日,医生支招制定减压计划
linux中conda虚拟环境使用(便于项目切换)、pip和conda换源
原来熊猫的笑声这么粗犷吗 网友直呼没想到:公鸭嗓笑的像反派
天天讯息:被马斯克16亿垄断的工艺 卡了下游企业的脖子
天天热点评!女孩穿汉服乘公交:颜值惊艳众人
环球视点!液体钙和钙片哪个更容易吸收(液体钙和钙片哪个更好吸收)
python 使用 kafka
世界观点:《暗黑4》与《暗黑3》角色截图对比:女性角色更逼真了
捐100亿建大学 曹德旺:我赚了很多钱但不贪婪 会还给社会
女子摔跤上牙磕进嘴唇1月后才发现 医生惊叹不已:网友直呼心太大
徕卡+双长焦史无前例!小米13 Ultra曝光
焦点信息:Vue——initState【十】
当前信息:国外短信平台收不到验证码,怎么解决?
今日快看!什么叫针灸师
全球热文:红心番石榴吃法?
130余年老字号 非遗工艺 吴裕泰特种级茉莉香毫100g装40元
热资讯!灵隐寺旁小溪中大量放生乌龟死亡被吐槽是伪善 放生已成产业链最高2000元一次
【独家焦点】干旱缓解 新疆最大湖泊变了:阿雅克库木湖30年面积扩大近7成
焦点速讯:WPF 入门基础
周鸿祎与库克共话科技未来:惟一被淘汰的是不会用GPT的人
天天观点:12小时保温保冷 朴原良品316不锈钢保温杯16.9元起
世界快讯:代码漏洞暴露用户支付信息 ChatGPT安全存隐患:官方致歉
世界速讯:聚焦险企负债成本管理 监管座谈会释放调整信号
AMD Yes!Zen4回归骨折价 12核锐龙9 7900到手2549元
学生党福音 Redmi小金刚Note 12 Turbo的NFC卡升级:两大功能合体
当前资讯!mp3格式转换器哪个好_mp3格式转换器
dotnet-csharp
焦点精选!C++ sizeof与strlen,并借此明晰内存对齐
女生靠摆地摊还清百万负债 还有人两周赚1万5、月入万元:摆摊真这么赚钱?
【天天速看料】周鸿祎:中国与GPT-4差距两三年 不存在难以逾越技术障碍
当前热文:Windows OpenGL ES 图像 GPUImageAmatorkaFilter
javascript的基础知识
小彭汽车向小鹏汽车道歉:盘点那些神级模仿的老年代步车
【速看料】《三体》动画今日正式完结!豆瓣评分仅3.8:半数一星差评
焦点关注:998的比亚迪秦PLUS DM-i多能跑?博主极端工况实测:合资还怎么打
当前关注:Office2019永久激活工具_Office2019激活工具神龙版v2023.2
天天快播:What is static and dynamic libraries
[白嫖系列] 白嫖一个永久免费的eu.org域名
速看:76人攻防俱佳夺冠有望,湖人防守第一进攻拉胯,勇士卫冕基本无望
全球新资讯:女子模仿网红穿搭遭对方粉丝网暴!法院判网红连续15天道歉、赔偿
男子喝红牛味道不对发现是累牛引热议:康帅傅、雷碧等山寨货为何层出不穷
资讯推荐:关于aws-s3-bucket-静态网站托管相关的查询-S3.Client.get_bucket_website(**kwargs)
天天速读:西班牙经济连续两年增速达5.5%
用4年不卡!Redmi Note 12 Turbo配置公布:16GB+1TB、5000mAh
环球今头条!男子抖音晒夜爬泰山到井盖下躲风 景区回应:核实后会处罚
【焦点热闻】YCSB工具原理重点内容解读(二)
CSS鼠标样式(cursor)总结(转载)
每日速看!因航班延误缺考复试 考研生崩溃大哭:对不起父母 对不起自己的努力
猪肉含量≥85% 一口全是肉:亚明猪肉烤肠29.9元2斤大促
越秀资本03月24日获深股通增持98.52万股
精选!宏基e1471g怎么样
热文:czide-CALLAN自制语言(python)
环球短讯!《安富莱嵌入式周报》第307期:开源智能制冷板,Keil MDK6发布时间,编程助手Github Copilot X,Matlab2023,高品质电容
英特尔联合创始人戈登·摩尔去世:享年94岁 “摩尔定律”提出者
天天热点!公司回应招聘前台要求身材 硬性要求臀围86腰围58:网友吐槽离谱
每日消息!学习 React 需要具备的 JavaScript 知识
全球观点:gs_probackup增量备份ptrack.cpp : 88
农事贵争时 物资“抢运”忙——黑龙江部分地区备春耕铁路运输见闻
环球观焦点:中国驻科威特大使馆发布斋月期间领事温馨提醒
妮维雅SPA级氨基酸洗面奶19.9元官方大促:原价87.9元
库克中国行:晒和黄龄合影、宣布苹果捐赠增加至1亿元支持教育事业
天天时讯:读Java性能权威指南(第2版)笔记27_线程和同步性能上
热资讯!蓝盘、紫盘、黑盘?2023年机械硬盘怎么买?
世界快看点丨《互联网广告管理办法》公布:弹出广告不能“一键关闭”最高可罚3万
今日精选:在 Ubuntu 和 Fedora 中设置 Python 开发环境
世界今日报丨网友修iPhone偶遇苹果CEO库克:让他在碎了的后盖上签了个名
90后情侣3年存100万裸辞飞荷兰 网友热议:有勇气活的很洒脱
信息:俄称打击乌军人员装备 乌称击退俄军进攻
环球短讯!12-指针02
全球今亮点!C++ 虚函数(virtual) 和纯虚函数(pure virtual) 的区别
40秒看天宇上演“星月神话”:被月亮星星浪漫到了 月牙慢慢掩盖金星