Quartz.Net怎么在.Net Core項目中使用

本篇文章給大家分享的是有關Quartz.Net怎么在.Net Core項目中使用，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

一、介紹

Quartz.NET是一個強大、開源、輕量的作業(yè)調度框架，是 OpenSymphony 的 Quartz API 的.NET移植，用C#改寫，可用于winform和asp.net應用中。它靈活而不復雜。你能夠用它來為執(zhí)行一個作業(yè)而創(chuàng)建簡單的或復雜的作業(yè)調度。它有很多特征，如：數(shù)據(jù)庫支持，集群，插件，支持cron-like表達式等等。

實踐教程

以WebApi項目舉例，用VS腳手架功能新建WebApi項目。

public void ConfigureServices(IServiceCollection services)
{
 services.AddMvc();
 services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();//注冊ISchedulerFactory的實例。
 }

[Route("api/[controller]")]
 public class ValuesController : Controller
 {
 private readonly ISchedulerFactory _schedulerFactory;
 private IScheduler _scheduler;
 public ValuesController(ISchedulerFactory schedulerFactory)
 {
  this._schedulerFactory = schedulerFactory;
 }
 [HttpGet]
 public async Task<string[]> Get()
 {
　　　　　　　//1、通過調度工廠獲得調度器
  _scheduler = await _schedulerFactory.GetScheduler();
　　　　　　　//2、開啟調度器
  await _scheduler.Start();
　　　　　　　//3、創(chuàng)建一個觸發(fā)器
  var trigger = TriggerBuilder.Create()
    .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每兩秒執(zhí)行一次
    .Build();
　　　　　　 //4、創(chuàng)建任務
  var jobDetail = JobBuilder.Create<MyJob>()
    .WithIdentity("job", "group")
    .Build();
　　　　　　　//5、將觸發(fā)器和任務器綁定到調度器中
  await _scheduler.ScheduleJob(jobDetail, trigger);
  return await Task.FromResult(new string[] { "value1", "value2" });
 }
 }

public class MyJob : IJob//創(chuàng)建IJob的實現(xiàn)類，并實現(xiàn)Excute方法。
 {
 public Task Execute(IJobExecutionContext context)
 {
　　　　　　return Task.Run(() =>
  　　{
  　　using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
  　　{
   　　sw.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss"));
  　　}
  });
 }
 }

輸出的結果：

2018-08-03 00-03-19
2018-08-03 00-03-20
2018-08-03 00-03-22
2018-08-03 00-03-24
2018-08-03 00-03-26

上面這種執(zhí)行的Job沒有參數(shù)，當需要參數(shù)可以通過下面兩種方法傳遞參數(shù)：

1、在Trigger中添加參數(shù)值

 var trigger3 = TriggerBuilder.Create()
   .WithSimpleSchedule(x =>x.WithIntervalInSeconds(2).RepeatForever())//間隔2秒 一直執(zhí)行
   .UsingJobData("key1", 321) //通過在Trigger中添加參數(shù)值
   .UsingJobData("key2", "123")
   .WithIdentity("trigger2", "group1")
   .Build();

2、在Job中添加參數(shù)值

 IJobDetail job = JobBuilder.Create<MyJob>()
    .UsingJobData("key1", 123)//通過Job添加參數(shù)值
    .UsingJobData("key2", "123")
    .WithIdentity("job1", "group1")
    .Build();

通過下面方法在Job中獲取參數(shù)值

public class MyJob : IJob
 {
 public Task Execute(IJobExecutionContext context)
 {
  var jobData = context.JobDetail.JobDataMap;//獲取Job中的參數(shù)

  var triggerData = context.Trigger.JobDataMap;//獲取Trigger中的參數(shù)

  var data = context.MergedJobDataMap;//獲取Job和Trigger中合并的參數(shù)

  var value1= jobData.GetInt("key1");
  var value2= jobData.GetString("key2");

  var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss");return Task.Run(() =>
  {
  using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
  {
   sw.WriteLine(dateString);
  }
  });
 }
 }

當Job中的參數(shù)和Trigger中的參數(shù)名稱一樣時，用 context.MergedJobDataMap獲取參數(shù)時，Trigger中的值會覆蓋Job中的值。

3、上面那種情況只能適應那種，參數(shù)值不變的情況。

假如有這種情況，這次的參數(shù)值是上一次執(zhí)行后計算的值，就不能使用上面方法了。如 每兩秒實現(xiàn)累加一操作，現(xiàn)在初始值是0，如果按照上面那種獲取值的操作，一直都是0+1，返回值一直都是1。為了滿足這個情況，只需要加一個特性[PersistJobDataAfterExecution]。

[PersistJobDataAfterExecution]//更新JobDetail的JobDataMap的存儲副本，以便下一次執(zhí)行這個任務接收更新的值而不是原始存儲的值
 public class MyJob : IJob
 {
 public Task Execute(IJobExecutionContext context)
 {
  var jobData = context.JobDetail.JobDataMap;
  var triggerData = context.Trigger.JobDataMap;
  var data = context.MergedJobDataMap;

  var value1 = jobData.GetInt("key1");
  var value2 = jobData.GetString("key2");
  var value3 = data.GetString("key2");

  var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss");
  Random random = new Random();

  jobData["key1"] = random.Next(1, 20);//這里面給key賦值，下次再進來執(zhí)行的時候，獲取的值為更新的值，而不是原始值
  jobData["key2"] = dateString;

  return Task.Run(() =>
  {
  using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8))
  {
   sw.WriteLine($"{dateString} value1:{value1} value2:{value2}");
  }
  //context.Scheduler.DeleteJob(context.JobDetail.Key);
  //context.Scheduler.Shutdown();
  });
 }
 }

三、Quartz.Net組成

Quartz主要有三部分組成任務(Job)、觸發(fā)器(Trigger)和調度器(Schedule)。

3.1 任務　

Job就是執(zhí)行的作業(yè)，Job需要繼承IJob接口，實現(xiàn)Execute方法。Job中執(zhí)行的參數(shù)從Execute方法的參數(shù)中獲取。

3.2 觸發(fā)器

觸發(fā)器常用的有兩種：SimpleTrigger觸發(fā)器和CronTrigger觸發(fā)器。

SimpleTrigger:能是實現(xiàn)簡單業(yè)務，如每隔幾分鐘，幾小時觸發(fā)執(zhí)行，并限制執(zhí)行次數(shù)。

var trigger = TriggerBuilder.Create()
   .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).WithRepeatCount(5))//間隔2秒 執(zhí)行6次
   .UsingJobData("key1", 321)
   .WithIdentity("trigger", "group")
   .Build();

CronTrigger:Cron表達式包含7個字段，秒 分 時 月內日期 月 周內日期 年(可選)。

舉例：

 var trigger = TriggerBuilder.Create()
   .WithCronSchedule("0 0 0 1 1 ?")// 每年元旦1月1日 0 點觸發(fā)
   .UsingJobData("key1", 321)
   .UsingJobData("key2", "trigger-key2")
   .WithIdentity("trigger4", "group14")
   .Build();

"0 15 10 * * ? *"         每天上午10:15觸發(fā) 

"0 0-5 14 * * ?"          每天下午2點到下午2:05期間的每1分鐘觸發(fā) 

3.3 調度器

調度器就是將任務和觸發(fā)器綁定，讓觸發(fā)器觸發(fā)的時候去執(zhí)行任務。

以上就是Quartz.Net怎么在.Net Core項目中使用，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業(yè)資訊頻道。