springboot整合quarzt实现动态定时任务
实现定时任务的几种方式:
1.使用linux的crontab
优点:
1.使用方式很简单,只要在crontab中写好
2.随时可以修改,不需要重启服务器
缺点:
1.分布式的系统中不好使用,只能一台台机器去修改
2.分是最小的时间单位,秒级的不能使用
2.使用spring自带的ScheduledExecutor
优点:
cronExpression比crontab的更强大一些支持到秒,性能更好
缺点:
修改了cronExpression的重启服务器,否则不生效
3. 使用JDK自带的Timer
优点: 轻量级,执行速度快 缺点:分布式系统不好使用.而且不能指定时间执行,只能按某个频次来执行
4.使用quarzt
优点: 1.可适用于分布式系统,quartz可支持集群模式 2.修改了定时任务无须重启服务器 (这只是我个人想到的一些优缺点,网友有其他看法可以留言说下)
你好！ 这是你第一次使用 Markdown编辑器 所展示的欢迎页。如果你想学习如何使用Markdown编辑器, 可以仔细阅读这篇文章，了解一下Markdown的基本语法知识。
整合步骤:
我们现在知道了quartz有这么优秀,该怎么整合到项目中呢?笔者接下来将实现一个通过http接口调用来触发动态定时任务的一个小功能.
笔者使用的环境:
jdk:1.8.0_162;
springboot:1.5.10.RELEASE
1.引入需要的jar包,在pom文件中加入quartz的jar包和spring支持quartz的jar
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.1</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
2.配置调度器的bean,这里spring实现了三个工厂类,SchedulerFactoryBean,CronTriggerBean,JobDetailBean,使用注解的方式将这三个类交给spring管理.一般看网上的资料都是这三个类,都交给spring管理,可以参考这篇文章[这篇文章]。( https://blog.csdn.net/liuchua... 。而我这里定时任务的触发是要通过接口的方式来触发，所以只用实现以下SchedulerFactoryBean的调度器即可。如果读者不是很明白这几个类是干嘛的，可以看下 quartz使用 的文章。我这里简单说下：
scheduler：任务的调度器，job：具体的任务类，trigger：触发器，任务什么时候执行是由它决定的。就是说时间人物做什么，scheduler就是主语的人物，trigger是时间，job是做什么事。
@Configuration
public class SchedulerConfig {
/**
* attention:
* Details：定义quartz调度工厂
*/
@Bean(name = "scheduler")
public SchedulerFactoryBean schedulerFactory() {
SchedulerFactoryBean bean = new SchedulerFactoryBean();
// 用于quartz集群,QuartzScheduler 启动时更新己存在的Job
bean.setOverwriteExistingJobs(true);
// 延时启动，应用启动1秒后
bean.setStartupDelay(1);
return bean;
}
}
3.具体任务类job,必须实现quartz的job类，这个也可以去实现spring的QuartJobBean（spring对job类的实现）是一样的，或者还有一种方式就是MethodInvokingJobDetailFactoryBean，这个类里面可以设置什么类的什么方法来执行这个任务，会更灵活一些：
@Slf4j
public class ScheduleTaskJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
log.info("任务执行了......");
}
}
4.http的接口来触发该调度程序：
@Slf4j
@RestController
public class Controller {
@Resource(name = "scheduler")
private Scheduler scheduler;
@PostMapping(value = "/api/executeTask")
public String executeTask(TaskVO taskVO) {
// job类
JobDetail jobDetail = JobBuilder.newJob(ScheduleTaskJob.class)
.withIdentity(taskVO.getJobName(), taskVO.getJobGroupName())
.build();
// 触发器类
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity(taskVO.getTriggerName(), taskVO.getTriggerGroupName())
.startNow()
.withSchedule(cronSchedule(taskVO.getCronExpression()))
.build();
try {
// 执行任务
scheduler.scheduleJob(jobDetail, trigger);
} catch (SchedulerException e) {
log.error("任务执行异常", e);
}
return "success";
}
}
5.http接口传入的值对象，其实就是用来指定job和triger的name和groupName，__name相同的话会失败,必须是唯一的__，
6.执行程序看看效果：
我传入的参数：
jobName:job1
jobGroupName:jobGroup1
triggerName:trigger1
triggerGroupName:triggerGroup1
cronExpression:0/1 ?
jobName:job2
jobGroupName:jobGroup1
triggerName:trigger2
triggerGroupName:triggerGroup1
cronExpression:0/1 ?
图中红色方框上部是只有一个定时任务，每一秒执行一次，下部因为又加入了一个新的任务所以回答引出两个任务的执行结果。
遇到的坑：
1.java.lang.NoSuchMethodError: org.springframework.boot.SpringApplication.run(Ljava/lang/Object;[Ljava/lang/String;)Lorg/springframework/context/ConfigurableApplicationContext;
解决方式：这个是因为springboot2不兼容的问题，所以使用springboot1.5是不会出现这个错误的。
2.Caused by: java.lang.ClassNotFoundException: org.springframework.transaction.PlatformTransactionManager
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_162] at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_162] at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) ~[na:1.8.0_162] at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_162] 39 common frames omitted 启动的时候如果报这个错的话，要引入一个spring-tx事物的包
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
</dependency>
源码地址： github源码地址 ，朋友们觉得写得还行的帮忙star个，follower下，23333，感谢~
参考资料：
[1] https://blog.csdn.net/liuchua...
[2] https://www.w3cschool.cn/quar...
[3] https://www.ibm.com/developer...
[4] http://www.quartz-scheduler.org/
正文到此结束
- 本文标签： java https UI CTO entity Job bean 回答 spring git 配置 时间 src JobDetail Action 分布式系统 linux pom map GitHub build Quartz 人物 springboot IBM 集群 SDN Developer 文章 调度器 分布式 tab cat API 参数 朋友们 Jobs id 源码 find 管理 REST http CronTrigger IO ssl tar NSA value W3C JobExecutionException executor 服务器 IDE App ask trigger ORM Markdown
- 版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
- 本文海报： 生成海报一 生成海报二
热门推荐
相关文章
Loading...
![[HBLOG]公众号](http://www.liuhaihua.cn/img/qrcode_gzh.jpg)
