C#中Quartz的使用

思哲

• 安装 NuGet 包：在 Visual Studio 中打开项目，右键单击项目名称，选择“管理 NuGet 包”，搜索“Quartz”并安装。
  
• 创建作业：创建一个实现了 IJob 接口的类，该接口包含一个 Execute 方法，该方法将在作业运行时调用。例如：
  1. public class MyJob : IJob
  2. {
  3.     public Task Execute(IJobExecutionContext context)
  4.     {
  5.         Console.WriteLine("Hello, world!");
  6.         return Task.CompletedTask;
  7.     }
  8. }

  复制代码
• 给Job传递数据：
  1. // 创建一个JobDataMap对象
  2. JobDataMap jobDataMap = new JobDataMap();
  4. // 向JobDataMap中添加参数
  5. jobDataMap.Add("param1", "Hello");
  6. jobDataMap.Add("param2", "World");
  8. // 创建一个JobDetail对象，设置JobDataMap
  9. JobDetail jobDetail = JobBuilder.Create<MyJob>()
  10.     .UsingJobData(jobDataMap)
  11.     .Build();
  13. // 在Job类中获取参数
  14. public class MyJob : IJob
  15. {
  16.     public void Execute(IJobExecutionContext context)
  17.     {
  18.         JobDataMap jobDataMap = context.JobDetail.JobDataMap;
  19.         string param1 = jobDataMap.GetString("param1");
  20.         string param2 = jobDataMap.GetString("param2");
  22.         Console.WriteLine("{0} {1}", param1, param2);
  23.     }
  24. }

  复制代码

　　　　注意：每次执行job时，都会创建一个新的job对象，并将JobDataMap中的数据传递给它。这意味着，即使您在job中存储了一些状态或数据，它们也不会在下一次执行job时保留。

• 创建触发器：创建一个触发器来指定何时运行作业。例如，以下触发器将在每天上午 10 点运行作业：
  

 

1. ITrigger trigger = TriggerBuilder.Create()
2.     .WithIdentity("trigger1", "group1")
3.     .WithDailyTimeIntervalSchedule(
4.         x => x.OnEveryDay()
5.               .StartingDailyAt(TimeOfDay.HourAndMinuteOfDay(10, 0))
6.     )
7.     .Build();

复制代码

　　　　也可以不使用WithDailyTimeIntervalSchedule，使用WithCronSchedule，例如：下面是每天9点触发

1. .WithCronSchedule(cron) //"0 0 9 * * ?"

复制代码

 
 
　　　　　这个表达式的含义是：
 

• 
  
  
  
  • 第一字段：0，表示秒数为0。
    
  • 第二字段：0，表示分钟数为0。
    
  • 第三字段：14，表示小时数为14，即下午2点。
    
  • 第四字段：*，表示每天都匹配。
    
  • 第五字段：*，表示每月都匹配。
    
  • 第六字段：?，表示不指定星期几。
    
  • 第七字段：未使用。
    
  
  

• 创建调度器：使用 StdSchedulerFactory 创建调度器，并将作业和触发器添加到调度器中：
  

1. ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
2. IScheduler scheduler = await schedulerFactory.GetScheduler();
3. IJobDetail job = JobBuilder.Create<MyJob>()
4.     .WithIdentity("job1", "group1")
5.     .Build();
7. await scheduler.ScheduleJob(job, trigger);

复制代码

 

• 运行作业：调用 Start 方法启动调度器，使作业按照指定的触发器运行：
  1. await scheduler.Start();

  复制代码
  注意：这里只是启动调度器，并不会立刻执行作业，需要触发器触发才会执行。
  

 
来源:https://www.cnblogs.com/log9527blog/archive/2023/04/14/17318118.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！