任务调度框架-Quartz.Net

 1 using Quartz;
 2 using Quartz.Impl;
 3 using System;
 4 using System.Collections.Generic;
 5 using System.Linq;
 6 using System.Text;
 7 using System.Threading.Tasks;
 8 
 9 namespace Test
10 {
11     public class SchedulerHelper
12     {
13         /// <summary>
14         /// 任务调度器实例
15         /// </summary>
16         public static IScheduler scheduler { get; }
17         static SchedulerHelper()
18         {
19             //实例化任务调度器对象
20             scheduler = StdSchedulerFactory.GetDefaultScheduler();
21         }
22 
23         /// <summary>
24         /// 添加任务
25         /// </summary>
26         /// <typeparam name="T">IJob类型</typeparam>
27         /// <param name="jobIdentity">job唯一标识</param>
28         /// <param name="triggerIdentity">trigger唯一标识</param>
29         /// <param name="cronExpression">cron表达式</param>
30         /// <param name="jobGroup">任务所属分组[可选]</param>
31         /// <param name="triggerGroup">触发器所属分组[可选]</param>
32         public static void AddScheduleJob<T>(string jobIdentity, string triggerIdentity, string cronExpression, string jobGroup = "", string triggerGroup = "")
33             where T : IJob
34         {
35             var jobBuilder = JobBuilder.Create<T>();
36             if (string.IsNullOrEmpty(jobGroup))
37                 jobBuilder.WithIdentity(jobIdentity);
38             else
39                 jobBuilder.WithIdentity(jobIdentity, jobGroup);
40 
41             var currentJob = jobBuilder.Build();
42 
43             var triggerBuilder = TriggerBuilder.Create();
44             if (string.IsNullOrEmpty(triggerGroup))
45                 triggerBuilder.WithIdentity(triggerIdentity);
46             else
47                 triggerBuilder.WithIdentity(triggerIdentity, triggerGroup);
48 
49             var currentTrigger = triggerBuilder
50                                 .StartNow()
51                                 .WithCronSchedule(cronExpression)
52                                 .Build();
53 
54             //把作业，触发器加入调度器。
55             scheduler.ScheduleJob(currentJob, currentTrigger);
56         }
57 
58         public static void Start()
59         {
60             if (scheduler == null)
61                 throw new ArgumentNullException("scheduler", "任务调度器实例对象不能为null");
62             if (!scheduler.IsStarted)
63                 scheduler.Start();
64         }
65 
66         public static void ShutDown()
67         {
68             if (scheduler == null)
69                 throw new ArgumentNullException("scheduler", "任务调度器实例对象不能为null");
70             if (!scheduler.IsShutdown)
71                 scheduler.Shutdown();
72         }
73     }
74 }

using NLog;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Test
{
    public class WriteLogJob : IJob
    {
        ILogger log = LogManager.GetLogger("admin");
        public void Execute(IJobExecutionContext context)
        {
            try
            {
                log.Error(string.Format("当前时间为：{0}", DateTime.Now));
            }
            catch (Exception x) { }
        }
    }
}

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Configuration;
 4 using System.Linq;
 5 using System.Text;
 6 
 7 namespace Test
 8 {
 9     class Program
10     {
11         static void Main(string[] args)
12         {
13             SchedulerHelper.AddScheduleJob<WriteLogJob>("WriteLogJob", "WriteLogTrigger", "0/5 * * * * ?");
14 
15             SchedulerHelper.Start();
16 
17             Console.ReadLine();
18         }
19     }
20 }

// 0/5 * * * * ?            每5秒钟执行一次
// 0 0/5 * * * ?            每5分钟执行一次
// 10 0/5 * * * ?           每5分钟，在第10秒钟执行一次
// 0 30 10-13 ? * WED,FRI   每周的周三、周五，时针为10-13，分钟刻度为30的时候执行一次
// 0 0/30 8-9 5,20 * ?      每个月的第5、第20天，时针为8到9，分钟刻度为从0开始，每过30分钟执行一次