一、 介绍

Quartz是一个开源的定时任务调度框架，这里就不详细介绍了，我们直入主题
Quartz主要由三部分组成

1. 任务：JobDetail
2. 触发器：Trigger，（分两类：SimpleTrigger和常用的CronTrigger）
3. 调度器：Scheduler

主要流程：比较简单： 先有JobDetail 装载定时任务类（需要实现Job接口），然后设置触发规则（如：cron表达式）来告知任务该按照什么样的规则执行，最后将两者放到调度器中，由调度器统一执行调度， 调度器主要是负责，任务的启动、暂停、恢复、修改、删除、添加等操作。

二、 代码

定时任务类：

import org.quartz.*;import java.time.LocalDateTime;

/** * @author guochunyun * @date 2019-12-18 下午 7:53 */public class HelloJop implements Job {    @Override    public void execute(JobExecutionContext context) throws JobExecutionException {        JobKey key = context.getJobDetail().getKey();        TriggerKey trkey = context.getTrigger().getKey();        System.out.println("jobDetail: " +  key.getName() + " : " + key.getGroup() + " trigger: " + trkey.getName() + " :　" + trkey.getGroup());

        //获取jobDetail配置中自定义信息        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();        //获取Trigger配置中自定义信息        JobDataMap trDataMap = context.getTrigger().getJobDataMap();        System.out.println("jobDetail: " + jobDataMap.get("message") + " " + jobDataMap.get("floatJobValue") + "trigger: " + trDataMap.get("message") + " " + trDataMap.get("doubleTriggerValue"));

        System.out.println("============>  hello world!  " + LocalDateTime.now());    }}

配置类：

mport org.quartz.*;import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

/** * @author guochunyun * @date 2019-12-18 下午 7:55 */public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException {        //创建一个jobDetail实例，将该实例与HelloJob 绑定        JobDetail jobDetail = JobBuilder.newJob(HelloJop.class)                .withIdentity("myJob", "group")                //以下两个配置可以将自定义的map 传递到任务当中                .usingJobData("message", "hello myJob")                .usingJobData("floatJobValue", 3.14)                .build();

        //创建一个CronTrigger实例， 每隔五秒重复执行一次        CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("myTrigger", "group")                //以下两个配置可以将自定义的map 传递到任务当中                .usingJobData("message", "hello myTrigger")                .usingJobData("doubleTriggerValue", 3.1415926D)                .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))                .build();

        //创建Scheduler实例，        SchedulerFactory sfact = new StdSchedulerFactory();        Scheduler scheduler = sfact.getScheduler();

        //启动定时任务        scheduler.start();        scheduler.scheduleJob(jobDetail, trigger);

        //创建jobKey        JobKey jobKey = new JobKey("myJob", "group");        //创建TriggerKey        TriggerKey triggerKey = new TriggerKey("myTrigger", "group");

        try {            //todo  特别注意此暂停只是调用暂停方法之后，任务不在执行， 等到执行恢复函数的时候 暂停时间内的任务会一次性全执行            //15秒后暂停定时任务            Thread.sleep(15000);            scheduler.pauseJob(jobKey);            System.out.println("===================");

            //再等待15秒后开启定时任务            Thread.sleep(15000);            scheduler.resumeJob(jobKey);            System.out.println("==================");

            //修改定时任务            CronTrigger trigger1 = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("myTrigger", "group")                    .usingJobData("message", "hello myTrigger")                    .usingJobData("doubleTriggerValue", 3.1415926D)                    .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"))                    .build();            Date date = scheduler.rescheduleJob(triggerKey, trigger1);            System.out.println("-----------------" + date);

        } catch (InterruptedException e) {            e.printStackTrace();        }    }}

三、 我的组件

封装成springboot组件， 直接使用@QuartzJob注解并实现Job接口即可
组件地址