.NetCore中使用Quartz.Net实践记录

public void ConfigureServices(IServiceCollection services)
{
 services.AddMvc();
 services.AddSingleton();//注册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 Get()
 {
　　　　　　　//1、通过调度工厂获得调度器
  _scheduler = await _schedulerFactory.GetScheduler();
　　　　　　　//2、开启调度器
  await _scheduler.Start();
　　　　　　　//3、创建一个触发器
  var trigger = TriggerBuilder.Create()
    .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每两秒执行一次
    .Build();
　　　　　　 //4、创建任务
  var jobDetail = JobBuilder.Create()
    .WithIdentity("job", "group")
    .Build();
　　　　　　　//5、将触发器和任务器绑定到调度器中
  await _scheduler.ScheduleJob(jobDetail, trigger);
  return await Task.FromResult(new string[] { "value1", "value2" });
 }
 }

public class MyJob : IJob//创建IJob的实现类，并实现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"));
  　　}
  });
 }
 }

 var trigger3 = TriggerBuilder.Create()
   .WithSimpleSchedule(x =>x.WithIntervalInSeconds(2).RepeatForever())//间隔2秒 一直执行
   .UsingJobData("key1", 321) //通过在Trigger中添加参数值
   .UsingJobData("key2", "123")
   .WithIdentity("trigger2", "group1")
   .Build();

 IJobDetail job = JobBuilder.Create()
    .UsingJobData("key1", 123)//通过Job添加参数值
    .UsingJobData("key2", "123")
    .WithIdentity("job1", "group1")
    .Build();

public class MyJob : IJob
 {
 public Task Execute(IJobExecutionContext context)
 {
  var jobData = context.JobDetail.JobDataMap;//获取Job中的参数

  var triggerData = context.Trigger.JobDataMap;//获取Trigger中的参数

  var data = context.MergedJobDataMap;//获取Job和Trigger中合并的参数

  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);
  }
  });
 }
 }

[PersistJobDataAfterExecution]//更新JobDetail的JobDataMap的存储副本，以便下一次执行这个任务接收更新的值而不是原始存储的值
 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赋值，下次再进来执行的时候，获取的值为更新的值，而不是原始值
  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();
  });
 }
 }

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

 var trigger = TriggerBuilder.Create()
   .WithCronSchedule("0 0 0 1 1 &＃63;")// 每年元旦1月1日 0 点触发
   .UsingJobData("key1", 321)
   .UsingJobData("key2", "trigger-key2")
   .WithIdentity("trigger4", "group14")
   .Build();