Quartz.NET开源作业调度框架系列(三):IJobExecutionContext参数传递

1 using System;
2 using System.Threading;
3
4 using Common.Logging;
5 using Quartz;
6 using Quartz.Impl;
7 using Quartz.Job;
8 using Quartz.Impl.Calendar;
9 using Quartz.Impl.Matchers;
10 namespace QuartzDemo
11 {
12
13 public class JobWithParametersExample
14 {
15 public string Name
16 {
17 get { return GetType().Name; }
18 }
19 private IScheduler sched &＃61; null;
20 public JobWithParametersExample(IScheduler _sched)
21 {
22 sched &＃61; _sched;
23 }
24 public virtual void Run()
25 {
26
27 //2S后执行
28 DateTimeOffset startTime &＃61; DateBuilder.NextGivenSecondDate(null, 2);
29 IJobDetail job1 &＃61; JobBuilder.Create()
30 .WithIdentity("job1", "group1")
31 .Build();
32
33 ISimpleTrigger trigger1 &＃61; (ISimpleTrigger)TriggerBuilder.Create()
34 .WithIdentity("trigger1", "group1")
35 .StartAt(startTime)
36 .WithSimpleSchedule(x &＃61;> x.WithIntervalInSeconds(5).WithRepeatCount(100))
37 .Build();
38
39 // 设置初始参数
40 job1.JobDataMap.Put(JobWithParameters.tSQL, "SELECT * FROM [ACT_ID_USER]");
41 job1.JobDataMap.Put(JobWithParameters.ExecutionCount, 1);
42
43 // 设置监听器
44 JobListener listener &＃61; new JobListener();
45 IMatcher matcher &＃61; KeyMatcher.KeyEquals(job1.Key);
46 sched.ListenerManager.AddJobListener(listener, matcher);
47
48 // 绑定trigger和job
49 sched.ScheduleJob(job1, trigger1);
50 //启动
51 sched.Start();
52
53 }
54 }
55 }

1 using System;
2 using Common.Logging;
3 using Quartz;
4 using Quartz.Impl;
5 using Quartz.Job;
6 using System.Windows.Forms;
7 namespace QuartzDemo
8 {
9
10 [PersistJobDataAfterExecution]
11 [DisallowConcurrentExecution]
12 public class JobWithParameters : IJob
13 {
14
15 // 定义参数常量
16 public const string tSQL &＃61; "tSQL";
17 public const string ExecutionCount &＃61; "count";
18 public const string RowCount &＃61; "rowCount";
19 public const string tableAlert &＃61; "tAlert";
20 // Quartz 每次执行时都会重新实例化一个类, 因此Job类中的非静态变量不能存储状态信息
21 private int counter &＃61; 1;//都为1
22 //private static int counter &＃61; 1;//可以保存状态
23 public virtual void Execute(IJobExecutionContext context)
24 {
25
26 JobKey jobKey &＃61; context.JobDetail.Key;
27 // 获取传递过来的参数
28 JobDataMap data &＃61; context.JobDetail.JobDataMap;
29 string SQL &＃61; data.GetString(tSQL);
30 int count &＃61; data.GetInt(ExecutionCount);
31
32 if (isOpen("FrmConsole"))
33 {
34 try
35 {
36 //获取当前Form1实例
37 __instance &＃61; (FrmConsole)Application.OpenForms["FrmConsole"];
38 //获取当前执行的线程ID
39 __instance.SetInfo(jobKey &＃43; "Thread ID " &＃43; System.Threading.Thread.CurrentThread.ManagedThreadId.ToString());
40 //数据库操作
41 System.Data.DataTable tAlert &＃61; SqlHelper.getDateTable(SQL, null);
42 //回写条数
43 data.Put(RowCount, tAlert.Rows.Count);
44 //通过方法更新消息
45 __instance.SetInfo(string.Format("{0} exec {1} &＃61; {2} get {3} rows\r\n execution count (from job map) is {4}\r\n execution count (from job member variable) is {5}",
46 jobKey,
47 tSQL,
48 SQL,
49 tAlert.Rows.Count,
50 count, counter));
51 //怎么取出Datatable ? json to datatable
52 //data.Put(tableAlert, tAlert);
53 }
54 catch (Exception ex)
55 {
56 Console.WriteLine(ex.Message);
57 }
58 }
59 // 修改执行计数并回写到job data map中
60 count&＃43;&＃43;;
61 data.Put(ExecutionCount, count);
62 // 修改本地变量,如果是非静态变量,不能存储状态
63 counter&＃43;&＃43;;
64 }
65
66 private static FrmConsole __instance &＃61; null;
67
68 ///

1 using System;
2 using Common.Logging;
3 using Quartz;
4 using Quartz.Impl;
5 using Quartz.Job;
6 namespace QuartzDemo
7 {
8 public class JobListener : IJobListener
9 {
10
11 public virtual string Name
12 {
13 get { return "JobListener"; }
14 }
15
16 public virtual void JobToBeExecuted(IJobExecutionContext inContext)
17 {
18 //执行前执行
19 Console.WriteLine("JobToBeExecuted");
20 }
21
22 public virtual void JobExecutionVetoed(IJobExecutionContext inContext)
23 {
24 //否决时执行
25 Console.WriteLine("JobExecutionVetoed");
26 }
27
28 public virtual void JobWasExecuted(IJobExecutionContext inContext, JobExecutionException inException)
29 {
30 JobKey jobKey &＃61; inContext.JobDetail.Key;
31 // 获取传递过来的参数
32 JobDataMap data &＃61; inContext.JobDetail.JobDataMap;
33 //获取回传的数据库表条目数
34 int rowCount &＃61; data.GetInt(JobWithParameters.RowCount);
35
36 try
37 {
38 if (rowCount > 9)
39 {
40 inContext.Scheduler.PauseAll();
41 System.Windows.Forms.MessageBox.Show("预警已超9条");
42 inContext.Scheduler.ResumeAll();
43
44 }
45 Console.WriteLine(rowCount.ToString());
46 }
47 catch (SchedulerException e)
48 {
49
50 Console.Error.WriteLine(e.StackTrace);
51 }
52 }
53
54 }
55 }