詳解.NET Core使用Quartz執(zhí)行調度任務進階

更新時間：2019年04月19日 09:42:28 作者：小世界的野孩子

這篇文章主要介紹了.NET Core使用Quartz執(zhí)行調度任務進階，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

一、前言運用場景

Quartz.Net是一個強大、開源、輕量的作業(yè)調度框架,在平時的項目開發(fā)當中也會時不時的需要運用到定時調度方面的功能，例如每日凌晨需要統(tǒng)計前一天的數據，又或者每月初需要統(tǒng)計上月的數據。當然也會出現(xiàn)既要統(tǒng)計日的也統(tǒng)計月的還需要進行其他的操作。那我們改如何來寫這樣的調度任務呢？

二、實際運用(.Net Core 2.2)

在一個解決方案中創(chuàng)建一個.Net控制臺應用程序及一個類庫，控制臺應用程序用來作為程序的啟動點。類庫用來作為調度任務的執(zhí)行程序。

然后我們需要完善一下項目的結構，首先我們得在控制臺應用程序中創(chuàng)建一個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調度任務執(zhí)行。

因為我們肯定不僅僅執(zhí)行一個調度任務，實際項目運行中肯定是多個調度任務一起執(zhí)行的，所以我們思路可以轉變一下。在類庫創(chuàng)建一個公共啟動中心，同時引用NuGet包：Quartz。然后開始創(chuàng)建調度任務的公共核心

private IScheduler scheduler;
    /// <summary>

    /// 創(chuàng)建調度任務的入口

    /// </summary>

    /// <returns></returns>

    public async Task Start()
    {
      await StartJob();
    }

    /// <summary>
    /// 創(chuàng)建調度任務的公共調用中心
    /// </summary>
    /// <returns></returns>
    public async Task StartJob()
    {
      //創(chuàng)建一個工廠
      NameValueCollection param = new NameValueCollection()
      {
        { "testJob","test"}
      };

      StdSchedulerFactory factory = new StdSchedulerFactory(param);
      //創(chuàng)建一個調度器
      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>
    /// 創(chuàng)建運行的調度器
    /// </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ā)器放入調度器中
      await scheduler.ScheduleJob(job, tigger);
    }

然后再去創(chuàng)建兩個執(zhí)行業(yè)務邏輯的類，分別是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");
    }
  }

到這里就順利的完成了一個定時調度器來執(zhí)行任務了，最后我們得把這個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文件會發(fā)現(xiàn)有一個Debug和一個Info

到這里我們的調度就完成了，我們需要使用的時候將打印日志更換成我們日常想要處理的業(yè)務邏輯就可以了。剛剛提到打印日志就順便提一下在.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í)行調度任務進階詳解整合，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持！

您可能感興趣的文章: