<packages><package id="Common.Logging" version="3.0.0" targetFramework="net452" /><package id="Common.Logging.Core" version="3.0.0" targetFramework="net452" /><package id="Quartz" version="2.3.3" targetFramework="net452" />
</packages>

public class HelloJob : IJob{public void Execute(IJobExecutionContext context){Console.WriteLine("Hello " + DateTime.Now.ToString());}}

static void Main(string[] args){ISchedulerFactory schedFact = new StdSchedulerFactory();IScheduler sched = schedFact.GetScheduler();sched.Start();IJobDetail job = JobBuilder.Create<HelloJob>().WithIdentity("myJob", "group1").Build();ITrigger trigger = TriggerBuilder.Create().WithIdentity("myTrigger", "group1").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(3).RepeatForever()).Build();sched.ScheduleJob(job, trigger);}

static void Main(string[] args){ISchedulerFactory schedFact = new StdSchedulerFactory();IScheduler sched = schedFact.GetScheduler();sched.Start();IJobDetail job = JobBuilder.Create<DumbJob>().WithIdentity("myJob", "group1") .UsingJobData("jobSays", "Hello World!").UsingJobData("myFloatValue", 3.141f).Build();ITrigger trigger = TriggerBuilder.Create().WithIdentity("myTrigger", "group1").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(3).RepeatForever()).Build();sched.ScheduleJob(job, trigger);}

public class DumbJob : IJob{public void Execute(IJobExecutionContext context){JobKey key = context.JobDetail.Key;JobDataMap dataMap = context.JobDetail.JobDataMap;string jobSays = dataMap.GetString("jobSays");float myFloatValue = dataMap.GetFloat("myFloatValue");Console.Error.WriteLine("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);}}

JobKey key = context.JobDetail.Key;//JobDataMap dataMap = context.JobDetail.JobDataMap;JobDataMap dataMap = context.MergedJobDataMap; 

public class DumbJob : IJob{public string JobSays { private get; set; }public float MyFloatValue { private get; set; }public void Execute(IJobExecutionContext context){JobKey key = context.JobDetail.Key;JobDataMap dataMap = context.MergedJobDataMap;Console.Error.WriteLine("Instance " + key + " of DumbJob says: " + JobSays + ", and val is: " + MyFloatValue);}}

public class HelloJob : IJob{public void Execute(IJobExecutionContext context){Console.WriteLine("Hello " + DateTime.Now.ToString());Thread.Sleep(5 * 1000);}}

[DisallowConcurrentExecution]public class HelloJob : IJob{public void Execute(IJobExecutionContext context){Console.WriteLine("Hello " + DateTime.Now.ToString());Thread.Sleep(5 * 1000);}}

// trigger builder creates simple trigger by default, actually an ITrigger is returned
ISimpleTrigger trigger = (ISimpleTrigger) TriggerBuilder.Create() .WithIdentity("trigger1", "group1") .StartAt(myStartTime) // some Date .ForJob("job1", "group1") // identify job with name, group strings .Build(); 

trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .StartAt(myTimeToStartFiring) // if a start time is not given (if this line were omitted), "now" is implied .WithSimpleSchedule(x => x .WithIntervalInSeconds(10) .WithRepeatCount(10)) // note that 10 repeats will give a total of 11 firings .ForJob(myJob) // identify job with handle to its JobDetail itself .Build(); 

trigger = (ISimpleTrigger) TriggerBuilder.Create() .WithIdentity("trigger5", "group1") .StartAt(DateBuilder.FutureDate(5, IntervalUnit.Minute)) // use DateBuilder to create a date in the future .ForJob(myJobKey) // identify job with its JobKey .Build(); 

trigger = TriggerBuilder.Create() .WithIdentity("trigger7", "group1") .WithSimpleSchedule(x => x .WithIntervalInMinutes(5) .RepeatForever()) .EndAt(DateBuilder.DateOf(22, 0, 0)) .Build(); 

trigger = TriggerBuilder.Create() .WithIdentity("trigger8") // because group is not specified, "trigger8" will be in the default group .StartAt(DateBuilder.EvenHourDate(null)) // get the next even-hour (minutes and seconds zero ("00:00")) .WithSimpleSchedule(x => x .WithIntervalInHours(2) .RepeatForever()) // note that in this example, 'forJob(..)' is not called // - which is valid if the trigger is passed to the scheduler along with the job .Build(); scheduler.scheduleJob(trigger, job);

"0 0/5 * * * ?"

"10 0/5 * * * ?"

"0 30 10-13 ? * WED,FRI"

"0 0/30 8-9 5,20 * ?"

Build a trigger that will fire every other minute, between 8am and 5pm, every day:

trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .WithCronSchedule("0 0/2 8-17 * * ?") .ForJob("myJob", "group1") .Build(); 

Build a trigger that will fire daily at 10:42 am:

// we use CronScheduleBuilder's static helper methods here
trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .WithSchedule(CronScheduleBuilder.DailyAtHourAndMinute(10, 42)) .ForJob(myJobKey) .Build(); 

or -

trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .WithCronSchedule("0 42 10 * * ?") .ForJob("myJob", "group1") .Build(); 

Build a trigger that will fire on Wednesdays at 10:42 am, in a TimeZone other than the system's default:

trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .WithSchedule(CronScheduleBuilder .WeeklyOnDayAndHourAndMinute(DayOfWeek.Wednesday, 10, 42) .InTimeZone(TimeZoneInfo.FindSystemTimeZoneById("Central America Standard Time"))) .ForJob(myJobKey) .Build(); 

or -

trigger = TriggerBuilder.Create() .WithIdentity("trigger3", "group1") .WithCronSchedule("0 42 10 ? * WED", x => x .InTimeZone(TimeZoneInfo.FindSystemTimeZoneById("Central America Standard Time"))) .ForJob(myJobKey) .Build();

TriggerListeners and JobListeners

Adding a JobListener that is interested in a particular job:

scheduler.ListenerManager.AddJobListener(myJobListener, KeyMatcher<JobKey>.KeyEquals(new JobKey("myJobName", "myJobGroup"))); 

Adding a JobListener that is interested in all jobs of a particular group:

scheduler.ListenerManager.AddJobListener(myJobListener, GroupMatcher<JobKey>.GroupEquals("myJobGroup")); 

Adding a JobListener that is interested in all jobs of two particular groups:

scheduler.ListenerManager.AddJobListener(myJobListener, OrMatcher<JobKey>.Or(GroupMatcher<JobKey>.GroupEquals("myJobGroup"), GroupMatcher<JobKey>.GroupEquals("yourGroup"))); 

Adding a JobListener that is interested in all jobs:

scheduler.ListenerManager.AddJobListener(myJobListener, GroupMatcher<JobKey>.AnyGroup());

SchedulerListeners

Adding a SchedulerListener:

scheduler.ListenerManager.AddSchedulerListener(mySchedListener); 

Removing a SchedulerListener:

scheduler.ListenerManager.RemoveSchedulerListener(mySchedListener);

JobStores

Quartz 默认是存在内存的，也就是如下配置：

quartz.jobStore.type = Quartz.Simpl.RAMJobStore, Quartz

还可以存在数据库中，可以从https://github.com/quartznet/quartznet database目录中找到建库脚本

可以看到创建了11张表，都是以qrtz_ 开头的，这个可以在配置里更改

quartz.jobStore.tablePrefix = QRTZ_

配置使用数据库：

quartz.jobStore.type = Quartz.Impl.AdoJobStore.JobStoreTX, Quartz

配置数据库代理：

quartz.jobStore.driverDelegateType = Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz

这里类型有：

MySQLDelegate 

SqlServerDelegate 

OracleDelegate 

SQLiteDelegate

配置使用哪个数据库：

quartz.jobStore.dataSource = myDS

配置连接属性：

 quartz.dataSource.myDS.connectionString = Server=localhost;Database=quartz;Uid=quartznet;Pwd=quartznetquartz.dataSource.myDS.provider = MySql-695

配置所有的JobDataMap 都是string类型：

quartz.jobStore.useProperties = true

配置集群：

quartz.jobStore.clustered=true

配置线程池：

quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal

配置读取配置：

quartz.plugin.jobInitializer.type=Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin
quartz.plugin.jobInitializer.fileNames=~/quartz_jobs.xml
quartz.plugin.jobInitializer.failOnFileNotFound=true

配置实例名：

quartz.scheduler.instanceName = QuartzTest

如果不配置的话默认是QuartzScheduler，如下图所示：

只保留简单的HelloJob，运行，查看数据库，可以看到这几张表里有数据：


更改重复次数为10次，先运行3次：


可以看到最后字段是3次，重新运行程序：

ISchedulerFactory schedFact = new StdSchedulerFactory();IScheduler sched = schedFact.GetScheduler();sched.Start();

注意这里不要再加任务了。

可以看到剩余次数Repeat_Count是7次了，当这7次运行完后这几个表就清空了。

使用配置文件配置任务

在项目根目录下创建quartz_jobs.xml并设置始终复制

 View Code

运行程序，发现数据库里有了记录，可是却没有运行任务。关了再次运行才开始跑任务，而如果这里的配置是true的话，再次运行也只是写库，不运行任务：

<processing-directives><overwrite-existing-data>true</overwrite-existing-data></processing-directives>

这里关键就在<start-time>节点，把两个时间节点注释后可以正常运行：

 View Code

下面是其他园友总结的：

Quartz.NET 入门

Quartz.NET 2.0 学习笔记(3) ：通过配置文件实现任务调度

job 任务，这个节点是用来定义每个具体的任务的，多个任务请创建多个job节点即可

• name(必填) 任务名称，同一个group中多个job的name不能相同，若未设置group则所有未设置group的job为同一个分组，如:<name>sampleJob</name>
• group(选填) 任务所属分组，用于标识任务所属分组，如:<group>sampleGroup</group>
• description(选填) 任务描述，用于描述任务具体内容，如:<description>Sample job for Quartz Server</description>
• job-type(必填) 任务类型，任务的具体类型及所属程序集，格式：实现了IJob接口的包含完整命名空间的类名,程序集名称，如:<job-type>Quartz.Server.SampleJob, Quartz.Server</job-type>
• durable(选填) 具体作用不知，官方示例中默认为true，如:<durable>true</durable>
• recover(选填) 具体作用不知，官方示例中默认为false，如:<recover>false</recover>

trigger 任务触发器，用于定义使用何种方式出发任务(job)，同一个job可以定义多个trigger ，多个trigger 各自独立的执行调度，每个trigger 中必须且只能定义一种触发器类型(calendar-interval、simple、cron)

calendar-interval 一种触发器类型，使用较少，此处略过

simple 简单任务的触发器，可以调度用于重复执行的任务

• name(必填) 触发器名称，同一个分组中的名称必须不同
• group(选填) 触发器组
• description(选填) 触发器描述
• job-name(必填) 要调度的任务名称，该job-name必须和对应job节点中的name完全相同
• job-group(选填) 调度任务(job)所属分组，该值必须和job中的group完全相同
• start-time(选填) 任务开始执行时间utc时间，北京时间需要+08:00，如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京时间2012年4月1日上午8:00开始执行，注意服务启动或重启时都会检测此属性，若没有设置此属性或者start-time设置的时间比当前时间较早，则服务启动后会立即执行一次调度，若设置的时间比当前时间晚，服务会等到设置时间相同后才会第一次执行任务，一般若无特殊需要请不要设置此属性
• repeat-count(必填)  任务执行次数，如:<repeat-count>-1</repeat-count>表示无限次执行，<repeat-count>10</repeat-count>表示执行10次
• repeat-interval(必填) 任务触发间隔(毫秒)，如:<repeat-interval>10000</repeat-interval> 每10秒执行一次

cron复杂任务触发器--使用cron表达式定制任务调度（强烈推荐)

• name(必填) 触发器名称，同一个分组中的名称必须不同
• group(选填) 触发器组
• description(选填) 触发器描述
• job-name(必填) 要调度的任务名称，该job-name必须和对应job节点中的name完全相同
• job-group(选填) 调度任务(job)所属分组，该值必须和job中的group完全相同
• start-time(选填) 任务开始执行时间utc时间，北京时间需要+08:00，如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京时间2012年4月1日上午8:00开始执行，注意服务启动或重启时都会检测此属性，若没有设置此属性，服务会根据cron-expression的设置执行任务调度；若start-time设置的时间比当前时间较早，则服务启动后会忽略掉cron-expression设置，立即执行一次调度，之后再根据cron-expression执行任务调度；若设置的时间比当前时间晚，则服务会在到达设置时间相同后才会应用cron-expression，根据规则执行任务调度，一般若无特殊需要请不要设置此属性
• cron-expression(必填) cron表达式，如:<cron-expression>0/10 * * * * ?</cron-expression>每10秒执行一次

TriggerListeners and JobListeners

可以使用监听器来监视任务和触发器的执行状态：

public class MyJobListener : IJobListener{public string Name{get{return "myJobListener";}}public void JobExecutionVetoed(IJobExecutionContext context){}public void JobToBeExecuted(IJobExecutionContext context){Console.WriteLine("Job{0}开始执行。", context.JobDetail.Key);}public void JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException){if(jobException==null){Console.WriteLine("Job{0}执行完成。", context.JobDetail.Key);}else{Console.WriteLine("Job{0}执行失败：{1}", context.JobDetail.Key, jobException.Message);}}}

IScheduler sched = StdSchedulerFactory.GetDefaultScheduler();MyJobListener myJobListener = new MyJobListener();sched.ListenerManager.AddJobListener(myJobListener, GroupMatcher<JobKey>.GroupEquals("Test"));sched.Start();

The ITriggerListener Interface

public interface ITriggerListener
{string Name { get; } void TriggerFired(ITrigger trigger, IJobExecutionContext context); bool VetoJobExecution(ITrigger trigger, IJobExecutionContext context); void TriggerMisfired(ITrigger trigger); void TriggerComplete(ITrigger trigger, IJobExecutionContext context, int triggerInstructionCode); } 

Job-related events include: a notification that the job is about to be executed, and a notification when the job has completed execution.

The IJobListener Interface

public interface IJobListener
{string Name { get; } void JobToBeExecuted(IJobExecutionContext context); void JobExecutionVetoed(IJobExecutionContext context); void JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException); } 

Adding a JobListener that is interested in a particular job:

scheduler.ListenerManager.AddJobListener(myJobListener, KeyMatcher<JobKey>.KeyEquals(new JobKey("myJobName", "myJobGroup"))); 

Adding a JobListener that is interested in all jobs of a particular group:

scheduler.ListenerManager.AddJobListener(myJobListener, GroupMatcher<JobKey>.GroupEquals("myJobGroup")); 

Adding a JobListener that is interested in all jobs of two particular groups:

scheduler.ListenerManager.AddJobListener(myJobListener, OrMatcher<JobKey>.Or(GroupMatcher<JobKey>.GroupEquals("myJobGroup"), GroupMatcher<JobKey>.GroupEquals("yourGroup"))); 

Adding a JobListener that is interested in all jobs:

scheduler.ListenerManager.AddJobListener(myJobListener, GroupMatcher<JobKey>.AnyGroup());