springboot整合quarzt实现动态定时任务

eternalshallow 发布于2019-08-01 13:57 / 1451人阅读

摘要：而我这里定时任务的触发是要通过接口的方式来触发，所以只用实现以下的调度器即可。我这里简单说下任务的调度器，具体的任务类，触发器，任务什么时候执行是由它决定的。遇到的坑解决方式这个是因为不兼容的问题，所以使用是不会出现这个错误的。

实现定时任务的几种方式: 1.使用linux的crontab

优点:
    1.使用方式很简单,只要在crontab中写好
    2.随时可以修改,不需要重启服务器
缺点:
    1.分布式的系统中不好使用,只能一台台机器去修改
    2.分是最小的时间单位,秒级的不能使用

2.使用spring自带的ScheduledExecutor

优点:
    cronExpression比crontab的更强大一些支持到秒,性能更好
缺点:
    修改了cronExpression的重启服务器,否则不生效

3. 使用JDK自带的Timer

优点: 
    轻量级,执行速度快
缺点:
    分布式系统不好使用.而且不能指定时间执行,只能按某个频次来执行

4. 使用quartz

优点:
    1.可适用于分布式系统,quartz可支持集群模式
    2.修改了定时任务无须重启服务器(这只是我个人想到的一些优缺点,网友有其他看法可以留言说下)

整合步骤:

我们现在知道了quartz有这么优秀,该怎么整合到项目中呢?笔者接下来将实现一个通过http接口调用来触发动态定时任务的一个小功能.
笔者使用的环境:

jdk:1.8.0_162;
springboot:1.5.10.RELEASE

1.引入需要的jar包,在pom文件中加入quartz的jar包和spring支持quartz的jar

         
            org.quartz-scheduler
            quartz
            2.3.1
        

        
            org.springframework
            spring-context-support

2.配置调度器的bean,这里spring实现了三个工厂类,SchedulerFactoryBean,CronTriggerBean,JobDetailBean,使用注解的方式将这三个类交给spring管理.一般看网上的资料都是这三个类,都交给spring管理,可以参考这篇文章这篇文章。
而我这里定时任务的触发是要通过接口的方式来触发，所以只用实现以下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事物的包

 
            org.springframework
            spring-tx

源码地址：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/

idc机房托管专线服务实现定时任务 php实现定时任务 java实现定时任务 springboot整合webrtc

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/49057.html

springboot整合quarzt实现动态定时任务

摘要：而我这里定时任务的触发是要通过接口的方式来触发，所以只用实现以下的调度器即可。我这里简单说下任务的调度器，具体的任务类，触发器，任务什么时候执行是由它决定的。遇到的坑解决方式这个是因为不兼容的问题，所以使用是不会出现这个错误的。实现定时任务的几种方式: 1.使用linux的crontab 优点: 1.使用方式很简单,只要在crontab中写好 2.随时可以修改,不需要...

hoohack 2019-08-19 11:40 评论0 收藏0
springboot整合quarzt实现动态定时任务

摘要：而我这里定时任务的触发是要通过接口的方式来触发，所以只用实现以下的调度器即可。我这里简单说下任务的调度器，具体的任务类，触发器，任务什么时候执行是由它决定的。遇到的坑解决方式这个是因为不兼容的问题，所以使用是不会出现这个错误的。实现定时任务的几种方式: 1.使用linux的crontab 优点: 1.使用方式很简单,只要在crontab中写好 2.随时可以修改,不需要...

szysky 2019-08-08 14:01 评论0 收藏0
Springboot整合Quartz实现动态定时任务

摘要：本文使用实现对定时任务的增删改查启用停用等功能。并把定时任务持久化到数据库以及支持集群。决定什么时候来执行任务。定义的是任务数据，而真正的执行逻辑是在中。封装定时任务接口添加一个暂停恢复删除修改暂停所有恢复所有简介 Quartz是一款功能强大的任务调度器，可以实现较为复杂的调度功能，如每月一号执行、每天凌晨执行、每周五执行等等，还支持分布式调度。本文使用Springboot+Myba...

IamDLY 2019-08-19 11:16 评论0 收藏0
Springboot整合Quartz实现动态定时任务

摘要：本文使用实现对定时任务的增删改查启用停用等功能。并把定时任务持久化到数据库以及支持集群。决定什么时候来执行任务。定义的是任务数据，而真正的执行逻辑是在中。封装定时任务接口添加一个暂停恢复删除修改暂停所有恢复所有简介 Quartz是一款功能强大的任务调度器，可以实现较为复杂的调度功能，如每月一号执行、每天凌晨执行、每周五执行等等，还支持分布式调度。本文使用Springboot+Myba...

bluesky 2019-07-23 17:49 评论0 收藏0
Springboot整合Quartz实现动态定时任务

摘要：本文使用实现对定时任务的增删改查启用停用等功能。并把定时任务持久化到数据库以及支持集群。决定什么时候来执行任务。定义的是任务数据，而真正的执行逻辑是在中。封装定时任务接口添加一个暂停恢复删除修改暂停所有恢复所有简介 Quartz是一款功能强大的任务调度器，可以实现较为复杂的调度功能，如每月一号执行、每天凌晨执行、每周五执行等等，还支持分布式调度。本文使用Springboot+Myba...

baihe 2019-07-23 17:00 评论0 收藏0