第九节：Quartz中的作业

做为使用quartz的我们，其实最关心的就job，job里面会实现我们要执行的业务代码，相对于调度器触发器来讲，job相对简单一些。

 

先睹图为快:

 

我们继承IJob接口定义的job会被封装到JobDetailImpl中，JobDetailImpl还包括其它属性,比如唯一标识job的JobKey（如上图）,可见记录job状态的JobDataMap（如上图），还有就是是否支持持久化，Ijob，等等一些其它的属性

 

至于IJobExecutionContext可以叫做job执行上下文,里面比如会有当前的触发器，当前作业，调度器这些东东。

 

当初始化IJobDetail的时候是用JobBuilder来完成的。

比如：IJobDetail myJob =JobBuilder.Create<MyJob>().WithIdentity("j1").Build();

 

前面几节大家已经会实现自己的job了，今天来实现一个能记录执行过程中的数据的job，很简单，直接看代码吧：

 

1：job代码(和旧版的写法不一样)：

[csharp] view plaincopy

1. [PersistJobDataAfterExecution]//保存执行状态  
2. [DisallowConcurrentExecution]//不允许并发执行  
3. public class MyJob : IJob  
4. {  
5.     public void Execute(IJobExecutionContext context)  
6.     {  
7.         int exeCount = context.JobDetail.JobDataMap.GetInt("exeCount");  
8.   
9.         Console.WriteLine("我执行了,时间:{0} 第{1}次执行", DateTime.Now, exeCount);  
10.   
11.         context.JobDetail.JobDataMap.Put("exeCount", ++exeCount);  
12.     }  
13. }  

 

 

2:调度代码:

 

[csharp] view plaincopy

1. static void Main(string[] args)  
2.        {  
3.            //调度器  
4.            ISchedulerFactory sf = new StdSchedulerFactory();  
5.            IScheduler sched = sf.GetScheduler();  
6.   
7.            //job详情，注意MyJob  
8.            IJobDetail myJob = JobBuilder.Create<MyJob>()  
9.               .WithIdentity("j1")  
10.               .Build();  
11.   
12.            //触发器,用的简单触发器，每隔5秒执行一次  
13.            ITrigger trigger = TriggerBuilder.Create().WithSimpleSchedule(t => t.RepeatForever().WithIntervalInSeconds(5))  
14.                .WithIdentity("t1")  
15.                .Build();  
16.   
17.            //关联job和触发器  
18.            sched.ScheduleJob(myJob, trigger);  
19.   
20.            //执行  
21.            sched.Start();  
22.   
23.            Console.Read();  
24.   
25.            //关掉  
26.            sched.Shutdown(true);  
27.        }  

 

 

3执行结果 :

 

总结：进一步了解了作业原理。

 

 

全部代码：

[csharp] view plaincopy

1. using System;  
2. using System.Collections.Generic;  
3. using System.Linq;  
4. using System.Text;  
5. using Quartz.Impl;  
6.   
7. namespace Quartz.Demo  
8. {  
9.     class Class5  
10.     {  
11.         static void Main(string[] args)  
12.         {  
13.             //调度器  
14.             ISchedulerFactory sf = new StdSchedulerFactory();  
15.             IScheduler sched = sf.GetScheduler();  
16.   
17.             //job详情，注意MyJob  
18.             IJobDetail myJob = JobBuilder.Create<MyJob>()  
19.                .WithIdentity("j1")  
20.                .Build();  
21.   
22.             //触发器,用的简单触发器，每隔5秒执行一次  
23.             ITrigger trigger = TriggerBuilder.Create().WithSimpleSchedule(t => t.RepeatForever().WithIntervalInSeconds(5))  
24.                 .WithIdentity("t1")  
25.                 .Build();  
26.   
27.             //关联job和触发器  
28.             sched.ScheduleJob(myJob, trigger);  
29.   
30.             //执行  
31.             sched.Start();  
32.   
33.             Console.Read();  
34.   
35.             //关掉  
36.             sched.Shutdown(true);  
37.         }  
38.     }  
39.   
40.     [PersistJobDataAfterExecution]//保存执行状态  
41.     [DisallowConcurrentExecution]//不允许并发执行  
42.     public class MyJob : IJob  
43.     {  
44.         public void Execute(IJobExecutionContext context)  
45.         {  
46.             int exeCount = context.JobDetail.JobDataMap.GetInt("exeCount");  
47.   
48.             Console.WriteLine("我执行了,时间:{0} 第{1}次执行", DateTime.Now, exeCount);  
49.   
50.             context.JobDetail.JobDataMap.Put("exeCount", ++exeCount);  
51.         }  
52.     }