轉載地址：https://www.cnblogs.com/wendj/archive/2018/09/18/9670412.html
作為一個優秀的開源調度框架，Quartz 具有以下特點：
- 強大的調度功能，例如支持豐富多樣的調度方法，可以滿足各種常規及特殊需求；
- 靈活的應用方式，例如支持任務和調度的多種組合方式，支持調度數據的多種存儲方式；
- 分布式和集群能力，Terracotta 收購后在原來功能基礎上作了進一步提升。
另外，作為 Spring 默認的調度框架，Quartz 很容易與 Spring 集成實現靈活可配置的調度功能。
quartz調度核心元素：
- Scheduler:任務調度器，是實際執行任務調度的控制器。在spring中通過SchedulerFactoryBean封裝起來。
- Trigger：觸發器，用於定義任務調度的時間規則，有SimpleTrigger,CronTrigger,DateIntervalTrigger和NthIncludedDayTrigger，其中CronTrigger用的比較多，本文主要介紹這種方式。CronTrigger在spring中封裝在CronTriggerFactoryBean中。
- Calendar:它是一些日歷特定時間點的集合。一個trigger可以包含多個Calendar，以便排除或包含某些時間點。
- JobDetail:用來描述Job實現類及其它相關的靜態信息，如Job名字、關聯監聽器等信息。在spring中有JobDetailFactoryBean和 MethodInvokingJobDetailFactoryBean兩種實現，如果任務調度只需要執行某個類的某個方法，就可以通過MethodInvokingJobDetailFactoryBean來調用。
- Job：是一個接口，只有一個方法void execute(JobExecutionContext context),開發者實現該接口定義運行任務，JobExecutionContext類提供了調度上下文的各種信息。Job運行時的信息保存在JobDataMap實例中。實現Job接口的任務，默認是無狀態的，若要將Job設置成有狀態的，在quartz中是給實現的Job添加@DisallowConcurrentExecution注解（以前是實現StatefulJob接口，現在已被Deprecated）,在與spring結合中可以在spring配置文件的job detail中配置concurrent參數。
我這里簡單記錄使用過程及代碼：
1：首先引用Quartz組件
2：using Quartz;using Quartz.Impl;
注：在本地新建一個控制台項目，將以下代碼copy過去即可用，只需要重寫Execute方法即可。Quartz3.0及以上的版本是采用的異步，3.0以下的版本沒有采用異步，使用方法是一樣的
主函數入口文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
using
BackgroundTask.job;
using
log4net;
using
Quartz;
using
Quartz.Impl;
using
System;
using
System.Collections.Generic;
using
System.Linq;
using
System.Text;
using
System.Threading.Tasks;
namespace
BackgroundTask
{
class
Program
{
private
static
readonly
ILog _log = LogManager.GetLogger(
typeof
(Program));
private
static
readonly
string
tiggerName =
"TestJobTrigger"
;
private
static
readonly
string
gropName =
"TestJobTriggerGrop"
;
private
static
readonly
string
jobName =
"TestJob"
;
//從工廠中獲取一個調度器實例化
private
static
IScheduler scheduler =
null
;
static
void
Main(
string
[] args)
{
Console.WriteLine(
"開始任務...."
);
_log.Debug(
"開始任務...."
);
Start();
}
private
static
async
void
Start()
{
//從工廠中獲取一個調度器實例化
scheduler = await StdSchedulerFactory.GetDefaultScheduler();
await scheduler.Start();
//創建一個作業
IJobDetail job1 = JobBuilder.Create<TestJob>()
.WithIdentity(jobName, gropName)
.UsingJobData(
"key"
,
"value"
)
// 傳遞參數 在Execute方法中獲取（以什么類型值傳入，取值就用相應的類型方法取值）
.Build();
// 創建觸發器
ITrigger trigger1 = TriggerBuilder.Create()
.WithIdentity(tiggerName, gropName)
.StartNow()
//現在開始
.WithSimpleSchedule(x => x
//觸發時間，10秒一次。
.WithIntervalInSeconds(10)
.RepeatForever())
//不間斷重復執行
.Build();
await scheduler.ScheduleJob(job1, trigger1);
//把作業，觸發器加入調度器。
Console.ReadKey();
// 清除任務和觸發器
ClearJobTrigger();
}
/// <summary>
/// 清除任務和觸發器
/// </summary>
private
static
void
ClearJobTrigger()
{
TriggerKey triggerKey =
new
TriggerKey(tiggerName, gropName);
JobKey jobKey =
new
JobKey(jobName, gropName);
if
(scheduler !=
null
)
{
scheduler.PauseTrigger(triggerKey);
scheduler.UnscheduleJob(triggerKey);
scheduler.DeleteJob(jobKey);
scheduler.Shutdown();
// 關閉
}
}
}
}
|
實現IJob 接口的任務文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
using
log4net;
using
Quartz;
using
System;
using
System.Collections.Generic;
using
System.Linq;
using
System.Text;
using
System.Threading.Tasks;
namespace
BackgroundTask.job
{
public
class
TestJob : IJob
{
private
readonly
ILog _log = LogManager.GetLogger(
typeof
(TestJob));
/// <summary>
/// 測試作業
/// </summary>
/// <param name="context"></param>
/// <returns></returns>
public
async Task Execute(IJobExecutionContext context)
{
|
JobDataMap dataMap = context.JobDetail.JobDataMap;
string k = dataMap.GetString("key");//獲取參數(可根據傳遞的類型使用GetInt、GetFloat、GetString.....)
|
1
2
3
4
5
6
7
8
|
_log.Debug(
"run TestJob debug"
);
_log.Error(
"run TestJob error"
);
_log.Info(
"run TestJob info"
);
// 在這里處理你的任務
}
}
}<br><br>
|