c# 实现Quartz任务调度

  • c# 实现Quartz任务调度已关闭评论
  • 19 次浏览
  • A+
所属分类:.NET技术
摘要

使用 Quartz.NET,你可以很容易地安排任务在应用程序启动时运行,或者每天、每周、每月的特定时间运行,甚至可以基于更复杂的调度规则。

使用 Quartz.NET,你可以很容易地安排任务在应用程序启动时运行,或者每天、每周、每月的特定时间运行,甚至可以基于更复杂的调度规则。

官网:http://www.quartz-scheduler.net/

实现任务类

创建一个实现了 IJob 接口的类(MailJobTest),该接口包含一个 Execute 方法,该方法将在作业运行时调用。例如:

using Quartz; using System; using System.Threading.Tasks; using UploadLogiData.Util;  namespace UploadLogiData {     /// <summary>     /// 邮件任务测试(每天三点固定时间检测Logi数据并发送内部邮件)     /// </summary>     //对于耗时任务,需要上一次执行完成后,才执行下次任务,覆盖之前设置的执行周期     [DisallowConcurrentExecution]     public class MailJobTest : IJob     {         public async Task Execute(IJobExecutionContext context)         {             try             {                 DisplayListboxMsg("邮箱开始调度");              } catch (Exception ex)             {                   UpUtil.LogWrite("ExceptionLog",$"定时器异常_{ex.StackTrace}");             }         }     } } 

实现一个LogiDownloadJob任务类

using MechTE_480.DateTimeCategory; using Quartz; using System; using System.Threading.Tasks; using UploadLogiData.Util;  namespace UploadLogiData.Quartzs {     /// <summary>     /// 监听启动时间,执行任务下载logi数据     /// </summary>     //对于耗时任务,需要上一次执行完成后,才执行下次任务,覆盖之前设置的执行周期     [DisallowConcurrentExecution]     public class LogiDownloadJob : IJob     {         public async Task Execute(IJobExecutionContext context)         {             DisplayListboxMsg("启动时间开始调度");         }     } } 

启动调度

实例化并启动调度程序,并调度要执行的作业:

IScheduler scheduler1; /// <summary> /// 执行任务调度 /// </summary> /// <returns></returns> public async Task ExLogiQuartz() {     DisplayListboxMsg("检测任务启动!");     //1、创建一个调度     var factory = new StdSchedulerFactory();     var scheduler = await factory.GetScheduler();     await scheduler.Start();      //2、创建一个任务     var job = JobBuilder.Create<LogiDownloadJob>()         .WithIdentity("LogiJob","LogiGroup")         .Build();     //3、创建一个触发器     var trigger = TriggerBuilder.Create()         .WithIdentity("LogiTrigger","LogiTriggerGroup")         .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次         .Build();     await scheduler.ScheduleJob(job,trigger);      // 第二个任务     var job2 = JobBuilder.Create<MailJobTest>()        .WithIdentity("MailJob","MailGroup")        .Build();     //3、创建一个触发器     var trigger2 = TriggerBuilder.Create()         .WithIdentity("MailTrigger","MailTriggerGroup")         .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次         .Build();     await scheduler.ScheduleJob(job2,trigger2);      scheduler1 = scheduler; // 对象赋值 }  

为作业指定身份:

var job = JobBuilder.Create<SimpleJob>()         .WithIdentity("LogiJob","LogiGroup") // // 作业名称为 "LogiJob",组名为 "LogiGroup"           .Build(); 

为触发器指定身份:

ITrigger trigger = TriggerBuilder.Create()       .WithIdentity("myTrigger", "myTriggerGroup") // 触发器名称为 "myTrigger",组名为 "myTriggerGroup"       .StartNow()       .WithSimpleSchedule(x => x.WithIntervalInHours(1).RepeatForever())       .Build(); 

创建第二个任务:

 // 创建并调度第二个作业    // 第二个任务  var job2 = JobBuilder.Create<MailJobTest>()     .WithIdentity("MailJob","MailGroup")     .Build();  //3、创建一个触发器  var trigger2 = TriggerBuilder.Create()      .WithIdentity("MailTrigger","MailTriggerGroup")      .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次      .Build();  await scheduler.ScheduleJob(job2,trigger2);        // 可以继续添加更多的作业和触发器...   

重要性

  • 唯一性:确保每个作业和触发器在调度器中具有唯一的标识,从而避免冲突。
  • 组织性:通过组名,可以将相关的作业或触发器组织在一起,便于管理。
  • 灵活性:通过使用不同的组,可以轻松地启用、禁用或删除一组相关的作业或触发器。
  • 查询和更新:有了明确的身份标识,可以更容易地查询作业或触发器的状态,或者对其进行更新。

取消任务调度

// 关闭 scheduler1.Shutdown().Wait(); 
 //方法外部访问调度器实例 IScheduler scheduler1;  public async void ExQuartz()  {      DisplayListboxMsg("检测任务启动!");      //1、创建一个调度      var factory = new StdSchedulerFactory();      var scheduler = await factory.GetScheduler();      await scheduler.Start();      //2、创建一个任务      var job = JobBuilder.Create<SimpleJob>()          .WithIdentity("job1","group1")          .Build();      //3、创建一个触发器      var trigger = TriggerBuilder.Create()          .WithIdentity("trigger1","group1")          .WithCronSchedule("0/2 * * * * ?")     //5秒执行一次          .Build();      await scheduler.ScheduleJob(job,trigger);       scheduler1 = scheduler; // 对象赋值     } 

把ExQuartz封装到类里面

ExLogiQuartz方法示例,同时考虑了scheduler的存储和访问:

QuartzScheduler类中

using Quartz; using Quartz.Impl; using System.Threading.Tasks;  namespace UploadLogiData.Quartzs {      /// <summary>     /// 封装了ExLogiQuartz方法和对scheduler的访问     /// </summary>     public class QuartzScheduler     {         /// <summary>         /// 方法外部访问调度器实例         /// </summary>         IScheduler logiScheduler;          //先静态定义一下主窗体         public static Form1 form;          public async Task ExLogiQuartz()         {             form.DisplayListboxMsg("检测任务启动!");             // 创建一个调度器实例               var factory = new StdSchedulerFactory();             logiScheduler = await factory.GetScheduler();             await logiScheduler.Start();              // 创建一个任务:LogiDownloadJob,每5秒执行一次               var job = JobBuilder.Create<LogiDownloadJob>()                 .WithIdentity("LogiJob","LogiGroup")                 .Build();             var trigger = TriggerBuilder.Create()                 .WithIdentity("LogiTrigger","LogiTriggerGroup")                 .WithCronSchedule("0/5 * * * * ?") // 5秒执行一次                   .Build();             await logiScheduler.ScheduleJob(job,trigger);              // 创建第二个任务:MailJobTest,每天下午3点10分执行一次               var job2 = JobBuilder.Create<MailJobTest>()                 .WithIdentity("MailJob","MailGroup")                 .Build();             var trigger2 = TriggerBuilder.Create()                 .WithIdentity("MailTrigger","MailTriggerGroup")                 .WithCronSchedule("0 10 15 * * ?") // 每天下午3点10分执行一次                   .Build();             await logiScheduler.ScheduleJob(job2,trigger2);              // 如果需要在其他地方访问scheduler,可以通过类属性或方法获取           }         public IScheduler Scheduler => logiScheduler;      } } 

调用示例

// 使用示例   public class Program   {       public static async Task Main(string[] args)       {           var quartzScheduler = new QuartzScheduler();           await quartzScheduler.ExLogiQuartz();                    // 如果需要在其他地方访问scheduler,可以通过以下方式获取           var scheduler = quartzScheduler.Scheduler;                  // 如调用关闭         quartzScheduler.Scheduler.Shutdown().Wait();         // 其他逻辑...       }   }