由于近日在定时器中对特殊的规则（既不能通过表达式直接体现的）的用法初步汇总：
本次使用的Quartz.Net的版本号:2.6
1.触发器测试验证
public class TestQuartz { /// <summary> /// 间隔N周定时触发器写法测试 /// </summary> public static void TestWeeklyIntervalGetFireTimeAfter() { DateTimeOffset startCalendar = DateBuilder.DateOf(1, 10, 0, 1, 1, 2023); var yearlyTrigger = new CalendarIntervalTriggerImpl { StartTimeUtc = startCalendar, RepeatIntervalUnit = IntervalUnit.Week, RepeatInterval = 2, PreserveHourOfDayAcrossDaylightSavings = true }; DateTimeOffset targetCalendar = startCalendar.AddDays(7 * 2); // jump 24 weeks (4 intervals) IList<DateTimeOffset> fireTimes = TriggerUtils.ComputeFireTimes(yearlyTrigger, null, 24); DateTimeOffset fifthTime = fireTimes[1]; // get the fifth fire time Assert.AreEqual(targetCalendar, fifthTime, "Week increment result not as expected."); } /// <summary> /// 间隔N天定时触发器写法测试 /// </summary> public static void TestDayIntervalGetFireTimeAfter() { DateTimeOffset startCalendar = DateBuilder.DateOf(1, 10, 0, 1, 1, 2023); var yearlyTrigger = new CalendarIntervalTriggerImpl { StartTimeUtc = startCalendar, RepeatIntervalUnit = IntervalUnit.Day, RepeatInterval = 1, PreserveHourOfDayAcrossDaylightSavings = true }; DateTimeOffset targetCalendar = startCalendar.AddDays(1); // jump 24 weeks (4 intervals) IList<DateTimeOffset> fireTimes = TriggerUtils.ComputeFireTimes(yearlyTrigger, null, 365); DateTimeOffset fifthTime = fireTimes[1]; // get the fifth fire time Assert.AreEqual(targetCalendar, fifthTime, "Week increment result not as expected."); } /// <summary> /// 间隔N月定时触发器写法测试 /// </summary> public static void TestMonthIntervalGetFireTimeAfter() { DateTimeOffset startCalendar = DateBuilder.DateOf(23, 20, 0, 1, 1, 2023); var yearlyTrigger = new CalendarIntervalTriggerImpl { StartTimeUtc = startCalendar, RepeatIntervalUnit = IntervalUnit.Month, RepeatInterval = 1, PreserveHourOfDayAcrossDaylightSavings = true }; DateTimeOffset targetCalendar = startCalendar.AddMonths(1); // jump 24 weeks (4 intervals) IList<DateTimeOffset> fireTimes = TriggerUtils.ComputeFireTimes(yearlyTrigger, null, 12); DateTimeOffset fifthTime = fireTimes[1]; // get the fifth fire time Assert.AreEqual(targetCalendar, fifthTime, "Week increment result not as expected."); } }
注册工具实现
/// <summary> /// 定时器管理工具类 /// </summary> /// <typeparam name="T"></typeparam> public class QuartzManager<T> where T : class, IJob { #region 变量 /// <summary> /// scheduler工厂 /// </summary> private static ISchedulerFactory schedulerFactory = new StdSchedulerFactory(); /// <summary> /// Job群组名 /// </summary> private static String JOB_GROUP_NAME = "JOBGROUP_NAME"; /// <summary> /// 触发器群组名 /// </summary> private static String TRIGGER_GROUP_NAME = "TRIGGERGROUP_NAME"; private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region 添加，删除，修改Job方法 /// <summary> /// 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名 /// </summary> /// <param name="pStrJobName">任务名</param> /// <param name="pStrCronExpress">触发器表达式</param> public static void addJob(string pStrJobName, string pStrCronExpress, IDictionary<string, object> pDictionary) { try { IScheduler sched = schedulerFactory.GetScheduler(); // 创建任务 IJobDetail job = JobBuilder.Create<T>() .WithIdentity(pStrJobName, JOB_GROUP_NAME) .Build(); // 创建触发器 ITrigger trigger = TriggerBuilder.Create() .WithIdentity(pStrJobName, TRIGGER_GROUP_NAME) .WithCronSchedule(pStrCronExpress) .Build(); //给任务传参数 foreach (KeyValuePair<string, object> kvp in pDictionary) { job.JobDataMap.Put(kvp.Key, kvp.Value); } sched.ScheduleJob(job, trigger); logger.Info("加载了服务:" + pStrJobName); } catch (Exception e) { logger.Info("加载异常:" + e.Message); throw new Exception(e.Message); } } /// <summary> /// 添加一个定时任务，使用自定义规则 /// </summary> /// <param name="pStrJobName">任务名</param> /// <param name="doDailyTime">自定义执行情况</param> /// <param name="doCalendar">自定义执行情况</param> /// <param name="startTimeUtc">触发器执行起点时间</param> public static void addJob(string pStrJobName, Action<DailyTimeIntervalScheduleBuilder> doDailyTime , Action<CalendarIntervalScheduleBuilder> doCalendar, DateTimeOffset startTimeUtc, IDictionary<string, object> pDictionary) { try { IScheduler sched = schedulerFactory.GetScheduler(); // 创建任务 IJobDetail job = JobBuilder.Create<T>() .WithIdentity(pStrJobName, JOB_GROUP_NAME) .Build(); // 创建触发器 ITrigger trigger = TriggerBuilder.Create() .WithIdentity(pStrJobName, TRIGGER_GROUP_NAME) .WithCalendarIntervalSchedule(d => { if (doCalendar != null) { doCalendar(d); } }) .WithDailyTimeIntervalSchedule(d => { if (doCalendar != null) { doDailyTime(d); } }) .StartAt(startTimeUtc) .Build(); //给任务传参数 foreach (KeyValuePair<string, object> kvp in pDictionary) { job.JobDataMap.Put(kvp.Key, kvp.Value); } sched.ScheduleJob(job, trigger); logger.Info("加载了服务:" + pStrJobName); } catch (Exception e) { logger.Info("加载异常:" + e.Message); throw new Exception(e.Message); } } /// <summary> /// 定时器高级注册应用 /// </summary> /// <param name="pStrJobName">任务名</param> /// <param name="myTrigger">自定义</param> /// <param name="pDictionary">自定义参数</param> public static void addJob<TiggerImpl>(string pStrJobName, Func<TiggerImpl, ITrigger> myTrigger, IDictionary<string, object> pDictionary) where TiggerImpl : CalendarIntervalTriggerImpl { try { IScheduler sched = schedulerFactory.GetScheduler(); // 创建任务 IJobDetail job = JobBuilder.Create<T>() .WithIdentity(pStrJobName, JOB_GROUP_NAME) .Build(); // 创建触发器 ITrigger trigger = myTrigger(Activator.CreateInstance<TiggerImpl>()); //给任务传参数 foreach (KeyValuePair<string, object> kvp in pDictionary) { job.JobDataMap.Put(kvp.Key, kvp.Value); } sched.ScheduleJob(job, trigger); logger.Info("加载了服务:" + pStrJobName); } catch (Exception e) { logger.Info("加载异常:" + e.Message); throw new Exception(e.Message); } } /// <summary> /// 移除一个任务(使用默认的任务组名，触发器名，触发器组名) /// </summary> /// <param name="pStrJobName">任务名称</param> public static void RemoveJob(string pStrJobName) { try { IScheduler sched = schedulerFactory.GetScheduler(); JobKey jobKey = new JobKey(pStrJobName); TriggerKey triggerKey = new TriggerKey(pStrJobName, TRIGGER_GROUP_NAME); sched.PauseTrigger(triggerKey);// 停止触发器 sched.UnscheduleJob(triggerKey);// 移除触发器 sched.DeleteJob(jobKey);// 删除任务 logger.Info("卸载了服务:" + pStrJobName); } catch (Exception e) { logger.Info("卸载异常:" + e.Message); throw new Exception(e.Message); } } /// <summary> /// 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名) /// </summary> /// <param name="pStrJobName">任务名</param> /// <param name="pStrCronExpress">触发器表达式</param> public static void ModifyJobTime(string pStrJobName, string pStrCronExpress, IDictionary<string, object> pDictionary) { try { IScheduler sched = schedulerFactory.GetScheduler(); TriggerKey triggerKey = new TriggerKey(pStrJobName, TRIGGER_GROUP_NAME); ICronTrigger trigger = (ICronTrigger)sched.GetTrigger(triggerKey); if (trigger == null) { return; } RemoveJob(pStrJobName); addJob(pStrJobName, pStrCronExpress, pDictionary); } catch (Exception e) { throw new Exception(e.Message); } } #endregion #region 启动，关闭Job /// <summary> /// 启动所有定时任务 /// </summary> public static void startJobs() { try { IScheduler sched = schedulerFactory.GetScheduler(); sched.Start(); } catch (Exception e) { throw new Exception(e.Message); } } /// <summary> /// 关闭所有定时任务 /// </summary> public static void ShutdownJobs() { try { IScheduler sched = schedulerFactory.GetScheduler(); if (!sched.IsShutdown) { sched.Shutdown(); } } catch (Exception e) { throw new Exception(e.Message); } } #endregion }
定制注册示例
public partial class PubDataService : ServiceBase { public PubDataService() { InitializeComponent(); } protected override void OnStart(string[] args) { try { LogHelper.WriteLog("服务开始启动！"); //定时生成病害检查自动任务数据连接服务（0.5时/次） QuartzManager<StcDiseaseManagerTask>.addJob("StcDiseaseManagerTask", ConfigHelper.GetAppSetting("cornExpress01"), new Dictionary<string, object>()); QuartzManager<StcDiseaseManagerTask>.startJobs();//定时生成二次注浆区段自动任务数据连接服务（1月/次） #region 验证已通过 QuartzManager<KeySectionSecondGroutSectionTask>.addJob<CalendarIntervalTriggerImpl>("KeySectionSecondGroutSectionTask", d => { d.StartTimeUtc = DateBuilder.DateOf(23, 20, 0, 1, 1, 2023); d.RepeatIntervalUnit = IntervalUnit.Month; d.RepeatInterval = 1; d.PreserveHourOfDayAcrossDaylightSavings = true; return d; }, new Dictionary<string, object>()); #endregion QuartzManager<KeySectionSecondGroutSectionTask>.startJobs(); //定时生成技术状况2级及以上影响区段自动任务数据连接服务（1月/次） QuartzManager<KeySectionTechnicalValueSectionTask>.addJob("KeySectionTechnicalValueSectionTask", ConfigHelper.GetAppSetting("cornExpress04"), new Dictionary<string, object>()); QuartzManager<KeySectionTechnicalValueSectionTask>.startJobs(); //定时生成技术状况评定计算连接服务-单环评定（1日/次） QuartzManager<TecConditionSingleDataTask>.addJob("TecConditionSingleDataTask", ConfigHelper.GetAppSetting("cornExpress05"), new Dictionary<string, object>()); QuartzManager<TecConditionSingleDataTask>.startJobs(); //定时生成技术状况评定计算连接服务-区段评定（2周/次） #region 验证已通过 QuartzManager<TecConditionStcSectionTask>.addJob<CalendarIntervalTriggerImpl>("TecConditionStcSectionTask", d => { d.StartTimeUtc = DateBuilder.DateOf(23, 30, 0, 1, 1, 2023); d.RepeatIntervalUnit = IntervalUnit.Week; d.RepeatInterval = 2; d.PreserveHourOfDayAcrossDaylightSavings = true; return d; }, new Dictionary<string, object>()); #endregion QuartzManager<TecConditionStcSectionTask>.startJobs(); LogHelper.WriteLog("服务启动成功！"); } catch (Exception ex) { LogHelper.WriteLog("服务启动失败，" + ex.Message, ex); } } protected override void OnStop() { LogHelper.WriteLog("服务开始关闭！"); QuartzManager<StcDiseaseManagerTask>.ShutdownJobs(); QuartzManager<StcDiseaseManagerTask>.RemoveJob("StcDiseaseManagerTask"); QuartzManager<ElectroManagerTask>.ShutdownJobs(); QuartzManager<ElectroManagerTask>.RemoveJob("ElectroManagerTask"); QuartzManager<KeySectionSecondGroutSectionTask>.ShutdownJobs(); QuartzManager<KeySectionSecondGroutSectionTask>.RemoveJob("KeySectionSecondGroutSectionTask"); QuartzManager<KeySectionTechnicalValueSectionTask>.ShutdownJobs(); QuartzManager<KeySectionTechnicalValueSectionTask>.RemoveJob("KeySectionTechnicalValueSectionTask"); QuartzManager<TecConditionSingleDataTask>.ShutdownJobs(); QuartzManager<TecConditionSingleDataTask>.RemoveJob("TecConditionSingleDataTask"); LogHelper.WriteLog("服务关闭成功！"); } }