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

3次阅读

共计 3824 个字符,预计需要花费 10 分钟才能阅读完成。

实现定时任务的几种方式:

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/

正文完
 0