内容简介:你好! 这是你第一次使用我们现在知道了quartz有这么优秀,该怎么整合到项目中呢?笔者接下来将实现一个通过http接口调用来触发动态定时任务的一个小功能.笔者使用的环境:
实现定时任务的几种方式:
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...
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- springboot整合Quartz实现动态配置定时任务
- 一行代码整合 Quartz 实现定时任务动态增删改
- SpringBoot整合MybatisPlus的简单教程(简单整合)
- springmvc教程--整合mybatis开发(spring+springMVC+mybatis整合开发)
- springboot整合springsecurity从Hello World到源码解析(五):springsecurity+jwt整合restful服务
- SpringBoot与异步任务、定时任务、邮件任务
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。