详解.NET Core使用Quartz执行调度任务进阶

站长资源 2024/11/30 佚名

2 0 1

一、前言运用场景

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文件

<"1.0" encoding="utf-8" "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执行调度任务进阶详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

.NET,Core使用Quartz调度任务进阶,.NET,Core使用Quartz进阶

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！

评论“详解.NET Core使用Quartz执行调度任务进阶”

暂无评论...

www.wwsws.com 伏龙阁资源网

39,976影音资源

44,792技术资源

21,817软件资源

651,128站长资源

详解.NET Core使用Quartz执行调度任务进阶

详解asp.net core重新加载应用配置

.NET CORE中使用AutoMapper进行对象映射的方法

评论“详解.NET Core使用Quartz执行调度任务进阶”

RTX 5090要首发性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

详解.NET Core使用Quartz执行调度任务进阶

详解asp.net core重新加载应用配置

.NET CORE中使用AutoMapper进行对象映射的方法

评论“详解.NET Core使用Quartz执行调度任务进阶”

RTX 5090要首发 性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

RTX 5090要首发性能要翻倍！三星展示GDDR7显存