如何在.NET Core中使用Quartz執(zhí)行調(diào)度任務(wù)

如何在.NET Core中使用Quartz執(zhí)行調(diào)度任務(wù)？相信很多沒有經(jīng)驗的人對此束手無策，為此本文總結(jié)了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個問題。

一、前言運用場景

 Quartz.Net是一個強大、開源、輕量的作業(yè)調(diào)度框架,在平時的項目開發(fā)當(dāng)中也會時不時的需要運用到定時調(diào)度方面的功能，例如每日凌晨需要統(tǒng)計前一天的數(shù)據(jù)，又或者每月初需要統(tǒng)計上月的數(shù)據(jù)。當(dāng)然也會出現(xiàn)既要統(tǒng)計日的也統(tǒng)計月的還需要進行其他的操作。那我們改如何來寫這樣的調(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了，接下來我們可以詳細講下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)粘Ｏ胍幚淼臉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>

看完上述內(nèi)容，你們掌握如何在.NET Core中使用Quartz執(zhí)行調(diào)度任務(wù)的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！