Spring boot quartz

① 那么我们首先看需要的包，先看看pom.xml文件：

    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
    </dependency>
    <dependency><!-- 该依赖必加，里面有sping对schedule的支持 -->
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
    </dependency>

我只截取了部分，除了这些以外，如果你是spring boot 的项目一定还要有相关配置文件，别指望我会贴出来，做梦！摔！

② 先写一个监听器保证项目启动的时候会调用到，我们的定时任务，代码如下：

package task;
import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

/**

• @author Lucky

• @Description 监听器

• @Date 15:08 2018/5/23

• @Param

• @return
  **/
  @Configuration
  public class SchedulerListener implements ApplicationListener<ContextRefreshedEvent> {

  @Autowired
  public MyScheduler myScheduler;

  @Override
  public void onApplicationEvent(ContextRefreshedEvent event) {
  try {
  myScheduler.scheduleJobs();
  } catch (SchedulerException e) {
  e.printStackTrace();
  }
  }

  @Bean
  public SchedulerFactoryBean schedulerFactoryBean() {
  SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
  return schedulerFactoryBean;
  }
  }

③ 写我们自己的定时器，用来触发我们的任务：

package task;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Component;
/**

• @author Lucky

• @Description

• @Date 13:48 2018/5/16

• @Param

• @return
  **/
  @Component
  public class MyScheduler {

  @Autowired
  SchedulerFactoryBean schedulerFactoryBean;

  static Scheduler scheduler;

  public void scheduleJobs() throws SchedulerException {
  scheduler = schedulerFactoryBean.getScheduler();
  startJob1(); // 每5分钟执行一次
  startJob2(); // 每2分钟执行一次
  }

  public static void startJob1() throws SchedulerException {
  JobDetail jobDetail = JobBuilder.newJob(ScheduledJob.class).withIdentity("job1", "group1").build();
  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");
  CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
  .withSchedule(scheduleBuilder).build();
  scheduler.scheduleJob(jobDetail, cronTrigger);
  }
  public static void modifyJob1(String cron) throws SchedulerException {
  TriggerKey triggerKey = TriggerKey.triggerKey("trigger1", "group1");
  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
  CronTrigger newTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
  .withSchedule(scheduleBuilder).build();
  scheduler.rescheduleJob(triggerKey, newTrigger);
  }
  public static String getJob1Status() throws SchedulerException {
  TriggerKey triggerKey = TriggerKey.triggerKey("trigger1", "group1");
  return scheduler.getTriggerState(triggerKey).name();
  }
  public static void pauseJob1() throws SchedulerException {
  scheduler.pauseJob(JobKey.jobKey("job1", "group1"));
  }
  public static void resumeJob1() throws SchedulerException {
  scheduler.resumeJob(JobKey.jobKey("job1", "group1"));
  }

  private void startJob2() throws SchedulerException {
  JobDetail jobDetail = JobBuilder.newJob(ScheduledJob2.class).withIdentity("job2", "group1").build();
  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/2 * * * * ?");
  CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger2", "group1")
  .withSchedule(scheduleBuilder).build();
  scheduler.scheduleJob(jobDetail, cronTrigger);
  }
  public static void modifyJob2(String cron) throws SchedulerException {
  TriggerKey triggerKey = TriggerKey.triggerKey("trigger2", "group1");
  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
  CronTrigger newTrigger = TriggerBuilder.newTrigger().withIdentity("trigger2", "group1")
  .withSchedule(scheduleBuilder).build();
  scheduler.rescheduleJob(triggerKey, newTrigger);
  }
  public static String getJob2Status() throws SchedulerException {
  TriggerKey triggerKey = TriggerKey.triggerKey("trigger2", "group1");
  return scheduler.getTriggerState(triggerKey).name();
  }
  public static void pauseJob2() throws SchedulerException {
  scheduler.pauseJob(JobKey.jobKey("job2", "group1"));
  }
  public static void resumeJob2() throws SchedulerException {
  scheduler.resumeJob(JobKey.jobKey("job2", "group1"));
  }

}

④ 接下来就写我们具体的任务如下：
第一个定时任务

package task;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.util.Date;

/**

• @ClassName ScheduledJob
• @Description TODO
• @Author Lucky
• @Date 2018/5/16 13:46
• @Version 1.0
  */
  public class ScheduledJob implements Job {
  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
  System.out.println("第一个定时任务" + new Date());
  }
  }

第二个定时任务

package task;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.util.Date;

/**

• @ClassName ScheduledJob2
• @Description TODO
• @Author Lucky
• @Date 2018/5/16 13:47
• @Version 1.0
  */
  public class ScheduledJob2 implements Job {
  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
  System.out.println("第二个定时任务" + new Date());
  }
  }

启动测试Demo（启动方法main直接写在了Controller里面，配个spring boot 注解@SpringBootApplication）：

package task;

import org.quartz.SchedulerException;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

/**

• @author Lucky

• @Description 测试定时任务，启动类

• @Date 15:12 2018/5/23

• @Param

• @return
  **/
  @RestController
  @SpringBootApplication
  public class ScheduleController {

  @RequestMapping("/modify")
  public @ResponseBody String modify() throws SchedulerException {
  MyScheduler.modifyJob1("0/1 * * * * ?");
  return "1";
  }

  @RequestMapping("/status")
  public @ResponseBody String status() throws SchedulerException {
  return MyScheduler.getJob1Status();
  }

  @RequestMapping("/pause")
  public @ResponseBody String pause() throws SchedulerException {
  MyScheduler.pauseJob1();
  return "1";
  }

  @RequestMapping("/resume")
  public @ResponseBody String resume() throws SchedulerException {
  MyScheduler.resumeJob1();
  return "1";
  }

  public static void main(String[] args) {
  SpringApplication.run(ScheduleController.class, args);
  }
  }