.net core中Quartz的使用方法

我们在日常开发中,总会遇到这样的需求:每隔一段时间,执行一次某个任务。固定某个时间执行任务,例如凌晨12点对当天的数据进行统计。每个月的第几天,执行某个任务。

Quartz.Net是根据Java的Quartz用C#改写而来,Quartz.NET是一个开源的作业调度框架,非常适合在平时的工作中,定时轮询数据库同步,定时邮件通知,定时处理数据等。Quartz.NET允许开发人员根据时间间隔来调度作业。

fcfc0ea208d3bbad261f49d0f1b575ce.png

Quartz版本:3.3.2

1.NuGet中下载安装Quartz

2.新建Quartz帮助类

(1)新建JobSchedule类

public class JobSchedule{public JobSchedule(Type jobType, string cronExpression){JobType = jobType;CronExpression = cronExpression;}public Type JobType { get; }public string CronExpression { get; }

新建QuartzFactory类

public class QuartzFactory : IJobFactory{private readonly IServiceProvider _serviceProvider;public QuartzFactory(IServiceProvider serviceProvider){_serviceProvider = serviceProvider;}public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler){return _serviceProvider.GetRequiredService(bundle.JobDetail.JobType) as IJob;}public void ReturnJob(IJob job){ }

新建QuartzService类

public class QuartzHostedService : IHostedService{private readonly ISchedulerFactory _schedulerFactory;private readonly IJobFactory _jobFactory;private readonly IEnumerable<JobSchedule> _jobSchedules;public QuartzHostedService(ISchedulerFactory schedulerFactory,IJobFactory jobFactory,IEnumerable<JobSchedule> jobSchedules){_schedulerFactory = schedulerFactory;_jobSchedules = jobSchedules;_jobFactory = jobFactory;}public IScheduler Scheduler { get; set; }public async Task StartAsync(CancellationToken cancellationToken){Scheduler = await _schedulerFactory.GetScheduler(cancellationToken);Scheduler.JobFactory = _jobFactory;foreach (var jobSchedule in _jobSchedules){var job = CreateJob(jobSchedule);var trigger = CreateTrigger(jobSchedule);await Scheduler.ScheduleJob(job, trigger, cancellationToken);}await Scheduler.Start(cancellationToken);}public async Task StopAsync(CancellationToken cancellationToken){await Scheduler?.Shutdown(cancellationToken);}private static IJobDetail CreateJob(JobSchedule schedule){var jobType = schedule.JobType;return JobBuilder.Create(jobType).WithIdentity(jobType.FullName).WithDescription(jobType.Name).Build();}private static ITrigger CreateTrigger(JobSchedule schedule){return TriggerBuilder.Create().WithIdentity($"{schedule.JobType.FullName}.trigger").WithCronSchedule(schedule.CronExpression).WithDescription(schedule.CronExpression).Build();}}

在Startup.cs中注册代码

services.AddControllers();#region Quartz Service// Add Quartz servicesservices.AddSingleton<IJobFactory, QuartzFactory>();services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();// Add our jobservices.AddTransient<DeleteFileJob>();services.AddJob();services.AddHostedService<QuartzHostedService>();

Quartz.Net源码:

https://github.com/quartznet/quartznet

官方学习文档:

http://www.quartz-scheduler.net/documentation/index.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/279790.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

AspectJ学习笔记

介绍 AspectJ是一个基于Java语言的AOP框架Spring2.0以后新增了对AspectJ切点表达支持AspectJ是AspectJ1.5新增功能&#xff0c;通过JDK5注解技术&#xff0c;允许Bean类中定义切面&#xff0c;新版本Spring框架&#xff0c;建议使用AspectJ方式来开发AOP主要用途&#xff1a;自…

windows10访客_如何在Windows 10中创建访客帐户

windows10访客If you find that your guests are asking fairly often to use your computer temporarily to check their email or look something up on the web, you don’t have to let them use your personal account or create a special account for each guest. 如果发…

C#使用 System.Net.Mail发送邮件功能

介绍System.Net.Mail命名空间是在.NET Framework中新增的&#xff0c;该命名空间提供了发送电子邮件的功能。通过对本章的学习&#xff0c;读者可以轻松地使用.NET Framework提供的类库来发送电子邮件。System.Net.Mail 命名空间包含用于将电子邮件发送到SMTP服务器的类&#x…

初识smarty

个人体会(不完全正确)&#xff1a;就是smarty就是为了更好的使得php/html结合做出来的一个框架。 , 转载于:https://www.cnblogs.com/nul1/p/9357694.html

几个有趣的算法题目

本文首发 http://svtter.cn最接近的数字 题目 一个K位的数N $$ (K\leq2000&#xff0c;N\leq10^{20}) $$ 找出一个比N大且最接近的数&#xff0c;这个数的每位之和与N相同&#xff0c;用代码实现之。 例如&#xff1a;0050 所求书数字为0104&#xff1b;112 所求数为121&#x…

获取一篇新闻的全部信息

给定一篇新闻的链接newsUrl&#xff0c;获取该新闻的全部信息 标题、作者、发布单位、审核、来源 发布时间:转换成datetime类型 点击&#xff1a; newsUrlnewsId(使用正则表达式re)clickUrl(str.format(newsId))requests.get(clickUrl)newClick(用字符串处理&#xff0c;或正则…

上twitter_如何在Twitter上更改您的显示名称

上twitterUnlike Facebook, Twitter has never insisted people user their real names. In fact, there’s a long tradition of people changing their names to a joke or pun because it’s Christmas or Halloween, or just for no reason at all. 与Facebook不同&#xf…

技术走向管理一些思考(1)-性格特质和自我管理

技术走向管理一些思考-文件夹 1&#xff0c;管理需具备的性格特质 赞赏他人&#xff1a;以一种不以自我为中心的合作的方式和他人相处&#xff0c;能平静和客观地接受不同的人。放下自己的性格、喜好&#xff0c;去赞赏不同类型的人。不是通过个人友谊或者熟悉程度。而是通过某…

网桥

配置实现网桥 网桥&#xff1a;即桥接 把一套机器上的若干个网络接口 “连接” 起来&#xff0c;其结果是&#xff0c;其中一个网口收到的报文会被复制给其他网口并发送出去。以使得网口之间的报文能够互相转发。网桥就是这样一个设备&#xff0c;它有若干个网口&#xff0c;并…

Newtonsoft.Json Deserialize Type 或者 同类型 变量 反序列化

Newtonsoft.Json 经常再用 这样的需求 还是很少用 场景 方法一&#xff1a;根据 Type 反序列化 int demo 0; string jsongString JsonConvert.SerializeObject(demo); int jsonDemo JsonConvert.DeserializeObject(jsongString, demo.GetType()); 方法二 根据 同类型变量 序…

raspberry pi_在月光下将Raspberry Pi变成蒸汽机

raspberry piValve’s Steam Machines aim to bring your Steam game library right into your living room (but at a rather steep premium). Today we’ll show you how to bring your Steam library (plus all your other computer games) to your living room for a fract…

文档测试【转载】

原文来自&#xff1a;51Testing软件测试网采编 作者&#xff1a; 仙灵测试(sinablog) 原文链接&#xff1a;http://www.51testing.com/html/61/n-237961.html 1、文档的种类 ● 联机帮助文档或用户手册 这是人们最容易想到的文档。用户手册是随软件发布而印制的小册子…

NOI2019省选模拟赛 第三场

传送门 明明没参加过却因为点进去结果狂掉\(rating\)…… \(A\) 集合 如果我们记 \[f_k\sum_{i1}^nT^i{n-i\choose k}\] 那么答案显然就是\(f_{k-1}\) 然后就可以开始推倒了 \[ \begin{aligned} f_k &\sum_{i1}^nT^i{n-i\choose k}\\ &\sum_{i1}^nT^i{n-i-1\choose k}\…

MySql数据库出现 1396错误

1、安装MySql数据库后。创建新的用户。有可能会出现 1396这个错误&#xff0c; 2、解决的办法如下&#xff1a;假装有你需要创建的这个用户、先删了。再创建。 3、这样就可以解决用户创建不成功的问题了。 转载于:https://www.cnblogs.com/chifa/p/9362882.html

如何使用wink框架_如何解决Wink Hub的Z-Wave连接问题

如何使用wink框架Overall, the Wink hub works extremely well…but sometimes the devices you have connected to it can act a little wonky. Here are some things you can do in order to fix any connection issues with all of those Z-Wave sensors and devices connec…

Tomcat服务器启动错误之Offending class: javax/servlet/Servlet.class

引子 最近在基于Wex5项目开发中&#xff0c;遇到使用过程中与Tomcat功能有关的错误提示&#xff0c; 如题所示。最终的解决方法就是删除掉项目上与tomcat冲突的jar包。 org.apache.catalina.loader.WebappClassLoader validateJarFile ??: validateJarFile(/Users/zxzpc/…

面向对象进阶(二)----------类的内置方法

一、isinstance(obj,cls)和issubclass(sub,super) 1. isinstance(obj,cls): 检查是否obj是否是类 cls 的对象 class Player:passp Player()print(isinstance(p, Player))>>> Ture 2. issubclass(sub, super): 检查sub类是否是 super 类的派生类 class Player:passcla…

BZOJ.3265.志愿者招募加强版(费用流SPFA)

题目链接 见上题。 每类志愿者可能是若干段&#xff0c;不满足那个...全幺模矩阵(全单位模矩阵)的条件&#xff0c;所以线性规划可能存在非整数解。 于是就可以用费用流水过去顺便拿个rank2 233. //20704kb 300ms #include <queue> #include <cstdio> #include &…

谷歌相册_Google相册中的新存档功能是什么?

谷歌相册If you’re a Google Photos user, you’ve may have seen a new feature called “Archive” show up in the app’s sidebar. if not, don’t stress—it’s just now rolling out and not everyone has it yet. Since it’s new, here’s a quick look at what it i…

CenterOS 7安装Nginx

1.wget http://nginx.org/packages/centos/7/noarch/RPMS/nginx-release-centos-7-0.el7.ngx.noarch.rpm下载对应当前系统版本的nginx包(package) 2.rpm -ivh nginx-release-centos-7-0.el7.ngx.noarch.rpm建立nginx的yum仓库 3.yum install nginx 下载并安装nginx systemctl s…