2024年3月24日发(作者：)
uartz来实现这个功能；
一、 说明
三、 配置及使用
；
，不然会出错。至于原因，则是spring对于quartz的支持实现，framewo
ger变成了接口，从而造成无法用spring的方式配置quartz的触发器（trigger）。
系列中igger是个类，而在quartz2.x系列中ig
iggerBean继承了igger，在quartz1.x
；
q
二、 添加quartz包
最终实现的功能：
我使用的quartz版本是2.2.1 。
compile "-scheduler:quartz:2.2.1"
我使用Gradle构建项目，加包时只需下面一行即可：
1. 配置任务调度器 （对应的文件名为）
1） 项目启动时，可执行的定时任务启动，按时执行相应的逻辑
2） 可添加新任务，删除任务，更新任务，暂停任务，恢复任务
由于最近工作要实现定时任务的执行，而且要求定时周期是不固定的，所以就用到了
spring3.1以下的版本必须使用quartz1.x系列，3.1以上的版本才支持quartz 2.x
1
2
1
2
3
4
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
3. 加载可执行任务的类
2. 服务器启动时加载，在文件里配置
4 default-lazy-init="false">
5
6
8
9
10
11
12
13
14
15
public class LoadTask {
public void initTask() throws Exception {
Scheduler scheduler = eduler();
// 可执行的任务列表
Collection
for (Task task : taskList) {
// 任务名称和任务组设置规则：
// 名称：task_1 ..
// 组 ：group_1 ..
TriggerKey triggerKey = rKey(
"task_" + (), "group_" + ());
CronTrigger trigger = (CronTrigger) scheduler
.getTrigger(triggerKey);
// 不存在，创建一个
if (null == trigger) {
JobDetail jobDetail = JobBuilder
.newJob()
.withIdentity("task_" + (),
"group_" + ()).build();
1
2
3
4
5
6
7
8
9
10
11
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
4. 调度任务的入口
public class QuartzTaskFactory implements Job {
@Override
public void execute(JobExecutionContext context)
throws JobExecutionException {
// TODO Auto-generated method stub
try {
n("任务运行...");
Task task = (Task) gedJobDataMap().get(
"scheduleJob");
n("任务名称: [" + kName() + "]");
DataMap().put("scheduleJob", task);
// 表达式调度构建器
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(getCronExpression());
// 按新的表达式构建一个新的trigger
trigger = TriggerBuilder
.newTrigger()
.withIdentity("task_" + (),
"group_" + ())
.withSchedule(scheduleBuilder).build();
leJob(jobDetail, trigger);
} else {
// trigger已存在，则更新相应的定时设置
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder
.cronSchedule(nExpression());
// 按新的cronExpression表达式重新构建trigger
trigger = ggerBuilder().withIdentity(triggerKey)
.withSchedule(scheduleBuilder).build();
// 按新的trigger重新设置job执行
duleJob(triggerKey, trigger);
}
}
}
@Autowired
private SchedulerFactoryBean schedulerFactoryBean;
@Autowired
private TaskService taskService;
}
12
13
14
15
16
17
7. 删除任务
6. 恢复任务
5. 暂停任务
8. 立即运行任务
9. 更新任务（时间表达式）
//在这里执行你的任务...
} catch (Exception e) {
tackTrace();
}
}
}
1Scheduler scheduler = eduler();
2
1Scheduler scheduler = eduler();
2JobKey jobKey = (Name(), Group());
rJob(jobKey);
1Scheduler scheduler = eduler();
2JobKey jobKey = (Name(), Group());
Job(jobKey);
1Scheduler scheduler = eduler();
2JobKey jobKey = (Name(), Group());
Job(jobKey);
1Scheduler scheduler = eduler();
2JobKey jobKey = (Name(), Group());
ob(jobKey);
四、时间表达式说明
3TriggerKey triggerKey = rKey(Name(),
Group());
5
6
//获取trigger，即在spring配置文件中定义的 bean id="myTrigger"
7CronTrigger trigger = (CronTrigger) gger(triggerKey);
8
9
//表达式调度构建器
10CronScheduleBuilder scheduleBuilder = hedule(scheduleJob
nExpression());
12
13
//按新的cronExpression表达式重新构建trigger
14trigger = ggerBuilder().withIdentity(triggerKey)
hedule(scheduleBuilder).build();
16
17
//按新的trigger重新设置job执行
duleJob(triggerKey, trigger);
发布评论