詳解.NET Core使用Quartz執(zhí)行調(diào)度任務(wù)進(jìn)階
一、前言運用場景
Quartz.Net是一個強(qiáng)大、開源、輕量的作業(yè)調(diào)度框架,在平時的項目開發(fā)當(dāng)中也會時不時的需要運用到定時調(diào)度方面的功能,例如每日凌晨需要統(tǒng)計前一天的數(shù)據(jù),又或者每月初需要統(tǒng)計上月的數(shù)據(jù)。當(dāng)然也會出現(xiàn)既要統(tǒng)計日的也統(tǒng)計月的還需要進(jìn)行其他的操作。那我們改如何來寫這樣的調(diào)度任務(wù)呢?
二、實際運用(.Net Core 2.2)
在一個解決方案中創(chuàng)建一個.Net控制臺應(yīng)用程序及一個類庫,控制臺應(yīng)用程序用來作為程序的啟動點。類庫用來作為調(diào)度任務(wù)的執(zhí)行程序。
然后我們需要完善一下項目的結(jié)構(gòu),首先我們得在控制臺應(yīng)用程序中創(chuàng)建一個Startup類,這個類也是任務(wù)啟動的一個重要條件。
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(); } }
然后項目會報一定的錯誤,根據(jù)錯誤信息一步一步解決,解決方案:添加NuGet包 Microsoft.AspNetCore
解決錯誤信息之后意味著目前啟動程序還算ok了,接下來我們可以詳細(xì)講下Quartz調(diào)度任務(wù)執(zhí)行。
因為我們肯定不僅僅執(zhí)行一個調(diào)度任務(wù),實際項目運行中肯定是多個調(diào)度任務(wù)一起執(zhí)行的,所以我們思路可以轉(zhuǎn)變一下。在類庫創(chuàng)建一個公共啟動中心,同時引用NuGet包:Quartz。然后開始創(chuàng)建調(diào)度任務(wù)的公共核心
private IScheduler scheduler; /// <summary> /// 創(chuàng)建調(diào)度任務(wù)的入口 /// </summary> /// <returns></returns> public async Task Start() { await StartJob(); } /// <summary> /// 創(chuàng)建調(diào)度任務(wù)的公共調(diào)用中心 /// </summary> /// <returns></returns> public async Task StartJob() { //創(chuàng)建一個工廠 NameValueCollection param = new NameValueCollection() { { "testJob","test"} }; StdSchedulerFactory factory = new StdSchedulerFactory(param); //創(chuàng)建一個調(diào)度器 scheduler = await factory.GetScheduler(); //開始調(diào)度器 await scheduler.Start(); //每三秒打印一個info日志 await CreateJob<StartLogInfoJob>("_StartLogInfoJob", "_StartLogInfoJob", " 0/3 * * * * ? "); //每五秒打印一個debug日志 await CreateJob<StartLogDebugJob>("_StartLogDebugJob", "_StartLogDebugJob", " 0/5 * * * * ? "); //調(diào)度器時間生成地址-- http://cron.qqe2.com } /// <summary> /// 停止調(diào)度器 /// </summary> public void Stop() { scheduler.Shutdown(); scheduler=null; } /// <summary> /// 創(chuàng)建運行的調(diào)度器 /// </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 { //創(chuàng)建一個作業(yè) var job = JobBuilder.Create<T>() .WithIdentity("name" + name, "gtoup" + group) .Build(); //創(chuàng)建一個觸發(fā)器 var tigger = (ICronTrigger)TriggerBuilder.Create() .WithIdentity("name" + name, "group" + group) .StartNow() .WithCronSchedule(cronTime) .Build(); //把作業(yè)和觸發(fā)器放入調(diào)度器中 await scheduler.ScheduleJob(job, tigger); }
然后再去創(chuàng)建兩個執(zhí)行業(yè)務(wù)邏輯的類,分別是StartLogInfoJob和StartLogDebugJob
public class StartLogInfoJob:IJob { public async Task Execute(IJobExecutionContext context) { await Start(); } public async Task Start() { LogHelp.Debug("調(diào)度打印Debug"); } } public class StartLogDebugJob : IJob { public async Task Execute(IJobExecutionContext context) { await Start(); } public async Task Start() { LogHelp.Info("調(diào)度打印Info"); } }
到這里就順利的完成了一個定時調(diào)度器來執(zhí)行任務(wù)了,最后我們得把這個Program文件重新寫一下,控制臺應(yīng)用程序生成的Program文件不太符合我們需要要求,同時把調(diào)度器在這里面啟動。
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); } } }
我們?nèi)タ次募A下面Log文件會發(fā)現(xiàn)有一個Debug和一個Info
到這里我們的調(diào)度就完成了,我們需要使用的時候?qū)⒋蛴∪罩靖鼡Q成我們?nèi)粘O胍幚淼臉I(yè)務(wù)邏輯就可以了。剛剛提到打印日志就順便提一下在.Net Core中如何打印日志吧。
三、.Net Cor打印日志文件
打印日志文件主要是用到了NuGet包:NLog,然后再加上一個NLog.config,首先在項目中安裝NLog的包,然后創(chuàng)建一個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>
完成這兩個就可以實現(xiàn)日志的打印了。。
以上所述是小編給大家介紹的.NET Core使用Quartz執(zhí)行調(diào)度任務(wù)進(jìn)階詳解整合,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
相關(guān)文章
.net 像hao123的快捷郵箱登陸的實現(xiàn)代碼
.net實現(xiàn)的像hao123的快捷郵箱登陸的代碼,需要的朋友可以參考下。2010-03-03asp.net Excel轉(zhuǎn)換為SQL Server的方法
辦公軟件Excel是一種常用的電子表格軟件,在編程項目中有需要將Excel轉(zhuǎn)換為SQL Server數(shù)據(jù)庫的需求,本文對此進(jìn)行一些介紹并給出設(shè)計代碼。2009-06-06Asp.Net其他頁面如何調(diào)用Web用戶控件寫的分頁
這篇文章主要介紹了Asp.Net其他頁面如何調(diào)用Web用戶控件寫的分頁,需要的朋友可以參考下2014-05-05輕量級ORM框架Dapper應(yīng)用之實現(xiàn)Join操作
本文詳細(xì)講解了使用Dapper實現(xiàn)Join操作,文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-03-03一步步打造簡單的MVC電商網(wǎng)站BooksStore(3)
這篇文章主要和大家一起一步步打造一個簡單的MVC電商網(wǎng)站,MVC電商網(wǎng)站BooksStore第三篇,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-04-04AJAX使用post發(fā)送數(shù)據(jù)xml格式接受數(shù)據(jù)
AJAX使用post發(fā)送數(shù)據(jù)xml格式接受數(shù)據(jù),需要的朋友可以參考一下2013-03-03