Spring boot quartz

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

    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
    </dependency>
    <dependency><!-- 該依賴必加，里面有sping對(duì)schedule的支持 -->
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
    </dependency>

我只截取了部分，除了這些以外，如果你是spring boot 的項(xiàng)目一定還要有相關(guān)配置文件，別指望我會(huì)貼出來，做夢(mèng)！摔！

② 先寫一個(gè)監(jiān)聽器保證項(xiàng)目啟動(dòng)的時(shí)候會(huì)調(diào)用到，我們的定時(shí)任務(wù)，代碼如下：

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 監(jiān)聽器

  • @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;
    }
    }

③ 寫我們自己的定時(shí)器，用來觸發(fā)我們的任務(wù)：

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分鐘執(zhí)行一次
    startJob2(); // 每2分鐘執(zhí)行一次
    }

    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"));
    }

}

④ 接下來就寫我們具體的任務(wù)如下：
第一個(gè)定時(shí)任務(wù)

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("第一個(gè)定時(shí)任務(wù)" + new Date());
    }
    }

第二個(gè)定時(shí)任務(wù)

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("第二個(gè)定時(shí)任務(wù)" + new Date());
    }
    }

啟動(dòng)測(cè)試Demo（啟動(dòng)方法main直接寫在了Controller里面，配個(gè)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 測(cè)試定時(shí)任務(wù)，啟動(dòng)類

  • @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);
    }
    }

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容