在spring boot项目中,通过@enablescheduling可启用spring自带的定时任务支持,在通过@scheduled注解定义定时任务,但是通过注解只能编写固定时间的定时任务,无法动态调整定时间隔,可通过实现schedulingconfigurer接口实现动态定时任务注册。
对比quartz的优缺点
优点:配置非常简单
缺点:
- 不支持分布式部署
- 不支持动态配置定时任务
- 不支持持久化
其实这几个缺点归根结底都是因为不支持持久化,所以如果项目需要持久化定时任务,还是要选择quartz比较好。
参考代码:
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
|
package org.cent.demo.scanner.schedule; import lombok.allargsconstructor; import lombok.data; import lombok.extern.slf4j.slf4j; import org.springframework.context.annotation.configuration; import org.springframework.scheduling.trigger; import org.springframework.scheduling.annotation.enablescheduling; import org.springframework.scheduling.annotation.schedulingconfigurer; import org.springframework.scheduling.config.scheduledtaskregistrar; import org.springframework.scheduling.support.crontrigger; import java.util.arrays; import java.util.list; /** * @author: cent * @email: 292462859@qq.com * @date: 2019/1/16. * @description: */ @configuration @enablescheduling @slf4j public class dynamicschedule implements schedulingconfigurer { /** * 测试数据,实际可从数据库获取 */ private list<task> tasks = arrays.aslist( new task( 1 , "任务1" , "*/30 * * * * *" ), new task( 2 , "任务2" , "*/30 * * * * *" ), new task( 3 , "任务3" , "*/30 * * * * *" ), new task( 4 , "任务4" , "*/30 * * * * *" ), new task( 5 , "任务5" , "*/30 * * * * *" ), new task( 6 , "任务6" , "*/30 * * * * *" ), new task( 7 , "任务7" , "*/30 * * * * *" ), new task( 8 , "任务8" , "*/30 * * * * *" ), new task( 9 , "任务9" , "*/30 * * * * *" ), new task( 10 , "任务10" , "*/30 * * * * *" ) ); @override public void configuretasks(scheduledtaskregistrar scheduledtaskregistrar) { tasks.foreach(task -> { //任务执行线程 runnable runnable = () -> log.info( "execute task {}" , task.getid()); //任务触发器 trigger trigger = triggercontext -> { //获取定时触发器,这里可以每次从数据库获取最新记录,更新触发器,实现定时间隔的动态调整 crontrigger crontrigger = new crontrigger(task.getcron()); return crontrigger.nextexecutiontime(triggercontext); }; //注册任务 scheduledtaskregistrar.addtriggertask(runnable, trigger); }); } @data @allargsconstructor static class task { /** * 主键id */ private int id; /** * 任务名称 */ private string name; /** * cron表达式 */ private string cron; } } |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://www.jianshu.com/p/546631cc2b8f