原文地址:http://www.cnblogs.com/yaopengfei/p/8526358.html
一. 五大构件
引言: Quartz.Net的五大构件
1. 调度器:Scheduler
2. 作业任务:Job
3. 触发器: Trigger
4. 线程池: SimpleThreadPool
5. 作业持久化:JobStore
二. Scheduler详解
1. 创建Scheduler的两种方式
(1). 直接通过StdSchedulerFactory类的GetDefaultScheduler方法创建
(2). 先创建StdSchedulerFactory,然后通过GetScheduler方法创建. 该方式可以在实体化StdSchedulerFactory的时候配置一些额外的信息,比如:配置SimpleThreadPool的个数、RemoteScheduler的远程控制、数据库的持久化等。(都在后续章节介绍)
2. Scheduler的简单封装
这里提供两种思路,一种是单例的模式封装,另一种是利用线程槽的模式封装
(1). 单例模式:是指无论多少个用户访问,都只有一个实例,在web端上常用 (详见:MySchedulerFactory类)
(2). 线程槽模式:是指单个用户的单次链接,在未断开连接之前,只有一个实例,下次重新连接,实例将重新创建(详见:MySchedulerFactory2类)
代码分享:
1 /// <summary> 2 /// 将Sheduler封装成单例模式,解决多线程多用户不唯一的问题 3 /// </summary> 4 public class MySchedulerFactory 5 { 6 /// <summary> 7 /// 静态变量:由CLR保证,在程序第一次使用该类之前被调用,而且只调用一次 8 /// </summary> 9 private static IScheduler _Scheduler = StdSchedulerFactory.GetDefaultScheduler(); 10 public static IScheduler CreateScheduler() 11 { 12 return _Scheduler; 13 } 14 } 15 /// <summary> 16 /// 通过线程槽进行一个优化 17 /// </summary> 18 public class MySchedulerFactory2 19 { 20 public static IScheduler CreateScheduler() 21 { 22 IScheduler scheduler = CallContext.GetData(typeof(MySchedulerFactory2).Name) as IScheduler; 23 if (scheduler == null) 24 { 25 scheduler = StdSchedulerFactory.GetDefaultScheduler(); 26 CallContext.SetData(typeof(MySchedulerFactory2).Name, scheduler); 27 } 28 return scheduler; 29 } 30 }
3. Scheduler的基本方法:
(1). 开启:Start
(2). 关闭:ShutDown
(3). 暂停job或Trigger:PauseAll、PauseJob、PauseJobs、PauseTrigger、PauseTriggers
(4). 恢复job或Trigger:ResumeAll、ResumeJob、ResumeJobs、ResumeTrigger、ResumeTriggers
(5). 将job和trigger加入Scheduler中:ScheduleJob
(6). 添加Job:AddJob
PS:更多方法以及如何封装使用,将在后面的框架章节介绍
分享一段完成的代码:
1 public static void SchedulerShow() 2 { 3 //1.创建Scheduler有两种方式 4 //方式一:直接通过StdSchedulerFactory类的GetDefaultScheduler方法创建 5 IScheduler scheduler = StdSchedulerFactory.GetDefaultScheduler(); 6 //方式二:先创建StdSchedulerFactory,然后通过GetScheduler方法创建 7 var factory = new StdSchedulerFactory(); 8 IScheduler scheduler2 = factory.GetScheduler(); 9 10 //2.创建一个具体的作业即job (具体的job需要单独在一个文件中执行) 11 var job = JobBuilder.Create<HelloJob>().Build(); 12 13 //3.创建并配置一个触发器即trigger 1s执行一次 14 var trigger = TriggerBuilder.Create().WithSimpleSchedule(x => x.WithIntervalInSeconds(1) 15 .RepeatForever()).Build(); 16 //4.将job和trigger加入到作业调度池中 17 scheduler.ScheduleJob(job, trigger); 18 19 //5.开启调度 20 scheduler.Start(); 21 }