.Net Core 下使用 Quartz —— 【7】作业和触发器之简单触发器

1、为特定时间建立触发器，不要重复

            //在某个时间点执行一次，不重复
            ISimpleTrigger trigger = (ISimpleTrigger)TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartAt(DateTime.Parse("2020-10-27 15:41"))
                .Build();

2、每隔3秒触发一次，重复三次（触发4次）

            //每隔3秒触发一次，重复三次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger3", "group1")
                .StartAt(DateTime.Parse("2020-10-27 15:48")) // 如果不写开始时间，将从当前时间开始
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(3)
                    .WithRepeatCount(3)) // 写的3次，但是会触发4次（算上最开始的一次）             
                .Build();

3、在未来5秒触发一次

            //在未来5秒触发一次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger5", "group1")
                .StartAt(DateBuilder.FutureDate(5, IntervalUnit.Second)) 
                .Build();

4、每5s执行一次，直到22点

            //每5s执行一次，直到22点
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger7", "group1")
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(5)
                    .RepeatForever())
                .EndAt(DateBuilder.DateOf(22, 0, 0))
                .Build();

5、从下一分钟的头部开始，每5秒执行一次

            //从下一分钟的头部开始，每5秒执行一次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger8") 
                .StartAt(DateBuilder.EvenMinuteDate(null))
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(5)
                    .RepeatForever()) 
                .Build();

完整代码：

Startup.cs

        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllersWithViews();

            //注册调度器工厂
            services.AddSingleton<ISchedulerFactory>(new StdSchedulerFactory());
        }

HomeController.cs

using Microsoft.AspNetCore.Mvc;
using Quartz;
using Quartz.Impl.Calendar;
using System;
using System.Threading.Tasks;

namespace QuartzLearn.Controllers
{
    public class HomeController : Controller
    {
        //调度器工厂
        private readonly ISchedulerFactory _schedulerFactory;

        //构造函数注入
        public HomeController(ISchedulerFactory schedulerFactory)
        {
            //注入调度器工厂
            _schedulerFactory = schedulerFactory;
        }

        public async Task<IActionResult> Index()
        {
            IScheduler scheduler = await _schedulerFactory.GetScheduler();

            await scheduler.Start();


            IJobDetail job = JobBuilder.Create<HelloJob>()
                .WithIdentity("job1", "jobGroup1")
                .UsingJobData("name", "zhangsan")
                .Build();

            //在某个时间点执行一次，不重复
            //ISimpleTrigger trigger = (ISimpleTrigger)TriggerBuilder.Create()
            //    .WithIdentity("trigger1", "group1")
            //    .StartAt(DateTime.Parse("2020-10-27 15:41"))
            //    .Build();

            //每隔3秒触发一次，重复三次
            //ITrigger trigger = TriggerBuilder.Create()
            //    .WithIdentity("trigger3", "group1")
            //    .StartAt(DateTime.Parse("2020-10-27 15:48")) // 如果不写开始时间，将从当前时间开始
            //    .WithSimpleSchedule(x => x
            //        .WithIntervalInSeconds(3)
            //        .WithRepeatCount(3)) // 写的3次，但是会触发4次（算上最开始的一次）             
            //    .Build();

            //在未来5秒触发一次
            //ITrigger trigger = TriggerBuilder.Create()
            //    .WithIdentity("trigger5", "group1")
            //    .StartAt(DateBuilder.FutureDate(5, IntervalUnit.Second)) 
            //    .Build();

            //每5s执行一次，直到22点
            //ITrigger trigger = TriggerBuilder.Create()
            //    .WithIdentity("trigger7", "group1")
            //    .WithSimpleSchedule(x => x
            //        .WithIntervalInSeconds(5)
            //        .RepeatForever())
            //    .EndAt(DateBuilder.DateOf(22, 0, 0))
            //    .Build();

            //从下一分钟的头部开始，每5秒执行一次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger8") 
                .StartAt(DateBuilder.EvenMinuteDate(null))
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(5)
                    .RepeatForever()) 
                .Build();

            await scheduler.ScheduleJob(job, trigger);

            return View();
        }
    }

    [DisallowConcurrentExecution]
    [PersistJobDataAfterExecution]
    public class HelloJob : IJob
    {
        public string Name { private get; set; }
        public async Task Execute(IJobExecutionContext context)
        {
            await Console.Out.WriteLineAsync($"This is HelloJob {DateTime.Now}");
        }
    }
}