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);
}
}
}
我們去看文件夾下面Log文件會發現有一個Debug和一個Info
到這里我們的調度就完成了，我們需要使用的時候將打印日志更換成我們日常想要處理的業務邏輯就可以了。剛剛提到打印日志就順便提一下在.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>
完成這兩個就可以實現日志的打印了。。