详解.NET Core使用Quartz执行调度任务进阶
一、前言运用场景
Quartz.Net是一个强大、开源、轻量的作业调度框架,在平时的项目开发当中也会时不时的需要运用到定时调度方面的功能,例如每日凌晨需要统计前一天的数据,又或者每月初需要统计上月的数据。当然也会出现既要统计日的也统计月的还需要进行其他的操作。那我们改如何来写这样的调度任务呢?
二、实际运用(.Net Core 2.2)
在一个解决方案中创建一个.Net控制台应用程序及一个类库,控制台应用程序用来作为程序的启动点。类库用来作为调度任务的执行程序。
然后我们需要完善一下项目的结构,首先我们得在控制台应用程序中创建一个Startup类,这个类也是任务启动的一个重要条件。
public class Startup { public Startup(IConfiguration configuration) { Configuration = configuration; } public IConfiguration Configuration { get; } // This method gets called by the runtime. Use this method to add services to the container. public void ConfigureServices(IServiceCollection services) { services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2); } // This method gets called by the runtime. Use this method to configure the HTTP request pipeline. public void Configure(IApplicationBuilder app, IHostingEnvironment env) { if (env.IsDevelopment()) { app.UseDeveloperExceptionPage(); } else { app.UseExceptionHandler("/Error"); } app.UseMvc(); } }
然后项目会报一定的错误,根据错误信息一步一步解决,解决方案:添加NuGet包 Microsoft.AspNetCore
解决错误信息之后意味着目前启动程序还算ok了,接下来我们可以详细讲下Quartz调度任务执行。
因为我们肯定不仅仅执行一个调度任务,实际项目运行中肯定是多个调度任务一起执行的,所以我们思路可以转变一下。在类库创建一个公共启动中心,同时引用NuGet包:Quartz。然后开始创建调度任务的公共核心
private IScheduler scheduler; /// <summary> /// 创建调度任务的入口 /// </summary> /// <returns></returns> public async Task Start() { await StartJob(); } /// <summary> /// 创建调度任务的公共调用中心 /// </summary> /// <returns></returns> public async Task StartJob() { //创建一个工厂 NameValueCollection param = new NameValueCollection() { { "testJob","test"} }; StdSchedulerFactory factory = new StdSchedulerFactory(param); //创建一个调度器 scheduler = await factory.GetScheduler(); //开始调度器 await scheduler.Start(); //每三秒打印一个info日志 await CreateJob<StartLogInfoJob>("_StartLogInfoJob", "_StartLogInfoJob", " 0/3 * * * * ? "); //每五秒打印一个debug日志 await CreateJob<StartLogDebugJob>("_StartLogDebugJob", "_StartLogDebugJob", " 0/5 * * * * ? "); //调度器时间生成地址-- http://cron.qqe2.com } /// <summary> /// 停止调度器 /// </summary> public void Stop() { scheduler.Shutdown(); scheduler=null; } /// <summary> /// 创建运行的调度器 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="name"></param> /// <param name="group"></param> /// <param name="cronTime"></param> /// <returns></returns> public async Task CreateJob<T>(string name,string group, string cronTime) where T: IJob { //创建一个作业 var job = JobBuilder.Create<T>() .WithIdentity("name" + name, "gtoup" + group) .Build(); //创建一个触发器 var tigger = (ICronTrigger)TriggerBuilder.Create() .WithIdentity("name" + name, "group" + group) .StartNow() .WithCronSchedule(cronTime) .Build(); //把作业和触发器放入调度器中 await scheduler.ScheduleJob(job, tigger); }
然后再去创建两个执行业务逻辑的类,分别是StartLogInfoJob和StartLogDebugJob
public class StartLogInfoJob:IJob { public async Task Execute(IJobExecutionContext context) { await Start(); } public async Task Start() { LogHelp.Debug("调度打印Debug"); } } public class StartLogDebugJob : IJob { public async Task Execute(IJobExecutionContext context) { await Start(); } public async Task Start() { LogHelp.Info("调度打印Info"); } }
到这里就顺利的完成了一个定时调度器来执行任务了,最后我们得把这个Program文件重新写一下,控制台应用程序生成的Program文件不太符合我们需要要求,同时把调度器在这里面启动。
class Program { static void Main(string[] args) { HandleStart(); var webHostArgs = args.Where(arg => arg != "--console").ToArray(); var host = WebHost.CreateDefaultBuilder(webHostArgs) .UseStartup<Startup>() .UseKestrel(options => { options.Limits.MinRequestBodyDataRate = null; }) .Build(); host.Run(); } static void HandleStart() { try { new Scheduler().Start().GetAwaiter().GetResult(); } catch (Exception ex) { LogHelp.Error(ex); } } }
到这里我们的调度就完成了,我们需要使用的时候将打印日志更换成我们日常想要处理的业务逻辑就可以了。刚刚提到打印日志就顺便提一下在.Net Core中如何打印日志吧。
三、.Net Cor打印日志文件
打印日志文件主要是用到了NuGet包:NLog,然后再加上一个NLog.config,首先在项目中安装NLog的包,然后创建一个LogHelper的公共类。
public class LogHelp { static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger(); public static void Debug(string info) { logger.Debug(info); } public static void Info(string info) { logger.Info(info); } public static void Error(Exception ex, string info = "") { logger.Error(ex); } }
然后再添加一个NLog.config文件
<?xml version="1.0" encoding="utf-8" ?> <nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" autoReload="true"> <targets> <target name="defaultlog" xsi:type="File" keepFileOpen="false" encoding="utf-8" fileName="${basedir}/logs/${level}/${shortdate}.log" layout="${longdate}|${level:uppercase=true}|${logger}|${message}" /> </targets> <rules> <logger name="*" minlevel="trace" writeTo="defaultlog" /> </rules> </nlog>
完成这两个就可以实现日志的打印了。。
以上所述是小编给大家介绍的.NET Core使用Quartz执行调度任务进阶详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对猪先飞网站的支持!
相关文章
- php5.3或以上版本可以使用php管理crontab计划任务,下面我先来体验一下,有需要学习了解的朋友可进入参考。 1.使用php-crontab-manager管理计划任务 要求 PHP>=5.3...2016-11-25
tomcat启动完成执行 某个方法 定时任务(Spring)操作
这篇文章主要介绍了tomcat启动完成执行 某个方法 定时任务(Spring)操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-09-25- 这篇文章主要通过一个小demo介绍了C#如何对多线程、多任务管理,需要的朋友可以参考下...2020-06-25
- c#并行任务多种优化方案分享,使用异步委托+回调函数方式实现,大家参考使用吧...2020-06-25
springboot定时任务@Scheduled执行多次的问题
这篇文章主要介绍了springboot定时任务@Scheduled执行多次问题的解决,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-10-18聊聊通过celery_one避免Celery定时任务重复执行的问题
Celery Once 也是利用 Redis 加锁来实现, Celery Once 在 Task 类基础上实现了 QueueOnce 类,该类提供了任务去重的功能,今天通过本文给大家介绍通过celery_one避免Celery定时任务重复执行的问题,感兴趣的朋友一起看看吧...2021-10-31- Web服务器执行一个PHP脚本,有时耗时很长才能返回执行结果,后面的脚本需要等待很长一段时间才能继续执行。如果想实现只简单触发耗时脚本的执行而不等待执行结果就直接执行下一步操作,可以通过fscokopen函数来实现。PHP支...2014-05-31
- 这篇文章主要介绍了Java并行执行任务的几种方案小结,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-11-05
- 这篇文章主要介绍了Golang Cron 定时任务的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-05-11
- 这篇文章主要介绍了Python定义一个Actor任务,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...2020-07-29
- 这篇文章主要介绍了PowerShell 远程执行任务的方法步骤,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-30
- 这篇文章主要介绍了详解PHP执行定时任务的几种实现思路,PHP的定时任务功能必须通过和其他工具结合才能实现,们就来深入的解析几种常见的php定时任务的思路...2015-12-24
- 这篇文章主要介绍了Springboot整合quartz产生错误及解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-06-03
- 这篇文章主要介绍了win2008中设置计划任务执行PHP文件的方法,需要的朋友可以参考下...2016-07-04
- 这篇文章主要为大家详细介绍了Spring定时任务,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助...2021-10-04
spring schedule配置多任务动态cron(增删启停)
这篇文章主要介绍了spring schedule配置多任务动态cron(增删启停),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-16如何在thinkphp中使用windows计划任务定时执行php文件
这篇文章主要介绍了如何在thinkphp中使用windows计划任务定时执行php文件,对定时执行感兴趣的同学,可以参考下...2021-04-21- 这篇文章主要介绍了调试WordPress中定时任务的相关PHP脚本示例,针对使用Cron API及wp_schedule_event()函数来写的定时任务,需要的朋友可以参考下...2015-12-14
- 这篇文章主要介绍了Spring定时服务QuartZ原理及代码案例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-11-20
- 在windows中如果你想让PHP程序自动运行那么我们必须使用windows计划任务来完成了,下面我来给各位同学介绍实现方法。 具体来说,我们若需利用任务计划程序自动运行则...2016-11-25