实战代码（一）：SpringBoot集成Quartz

一、简单介绍

Quartz 是一个完全由 Java 编写的开源作业调度框架,可以由少量的代码实现较为复杂的功能。

Springboot内置的task虽然也可以实现定时任务，但是它默认单线程，虽然可以通过配置实现多线程，但是功能略显单薄。

Quartz有着强大的任务管理功能，可以在运行时进行任务的开启、关闭、修改任务执行时间等。

二、开发

2.1 依赖引入

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2.2 配置文件

spring:
  main:
    banner-mode: off
  quartz:
    job-store-type: memory
    scheduler-name: smile-scheduler
    properties:
      org:
        quartz:
          jobStore:
          threadPool:
            # 线程个数
            threadCount: 10

注：如需将job信息持久化到db，可参考官方文档进行配置

2.3 实现Job

/**
 * 定时任务demo
 * - @DisallowConcurrentExecution 当前任务未执行完前不会执行新的任务
 * @author smile
 */
@Slf4j
@DisallowConcurrentExecution
public class QuartzDemoJob extends QuartzJobBean {

    @Override
    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        // todo something 
        log.info("！！！开始执行--测试定时任务");
    }
}

2.4 工具类

/**
 * quartz任务管理
 * - Group统一使用quartz默认的组
 * @author smile
 */
@Component
public class QuartzUtils {

   @Autowired
   private Scheduler scheduler;

   /**
    * 添加任务--SimpleScheduler
    * @param jobClass jobClass
    * @param taskName jobName、triggerName使用同一个name
    * @param intervalTime 间隔时间, 单位：秒
    */
   public void addSingleJob(Class<? extends Job> jobClass, String taskName, int intervalTime) throws SchedulerException {
      JobDetail jobDetail = JobBuilder.newJob(jobClass)
            .withIdentity(taskName).build();
      SimpleScheduleBuilder simpleScheduler = SimpleScheduleBuilder.simpleSchedule()
            .withMisfireHandlingInstructionNextWithRemainingCount();
      Trigger trigger = TriggerBuilder.newTrigger()
              .startAt(new Date(System.currentTimeMillis() + 1000 * 10))
              .withIdentity(taskName)
              .withSchedule(
                  simpleScheduler.withIntervalInSeconds(intervalTime).repeatForever())
              .build();
      scheduler.scheduleJob(jobDetail, trigger);
   }


   /**
    * 添加任务--cron
    * @param jobClass jobClass
    * @param taskName jobName、triggerName使用同一个name
    * @param cron cron定时任务规则
    */
   public void addCronJob(Class<? extends Job> jobClass, String taskName, String cron) throws SchedulerException {
      JobDetail jobDetail = JobBuilder.newJob(jobClass)
            .withIdentity(taskName).build();
      CronScheduleBuilder cronScheduler = CronScheduleBuilder.cronSchedule(cron).withMisfireHandlingInstructionDoNothing();
      Trigger trigger = TriggerBuilder.newTrigger().startNow().withIdentity(taskName)
            .withSchedule(cronScheduler)
            .build();
      scheduler.scheduleJob(jobDetail, trigger);
   }


   /**
    * 修改cron规则
    */
   public void modifyCron(String taskName, String cron) throws SchedulerException {
      TriggerKey triggerKey = TriggerKey.triggerKey(taskName);
      CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
      String oldTime = trigger.getCronExpression();
      if(!oldTime.equalsIgnoreCase(cron)){
         CronScheduleBuilder cronBuilder = CronScheduleBuilder.cronSchedule(cron);
         TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
         triggerBuilder.withIdentity(taskName).startNow().withSchedule(cronBuilder);
         trigger = (CronTrigger) triggerBuilder.build();
         scheduler.rescheduleJob(triggerKey, trigger);
      }
   }


   /**
    * 删除任务
    */
   public void delJob(String taskName) throws SchedulerException {
      TriggerKey triggerKey = TriggerKey.triggerKey(taskName);
      JobKey jobKey = JobKey.jobKey(taskName);
      scheduler.pauseTrigger(triggerKey);
      scheduler.unscheduleJob(triggerKey);
      scheduler.deleteJob(jobKey);
   }
}

2.5 初始化定时任务

/**
 * 初始化定时任务
 * @author smile
 */
@Component
public class QuartzJobInit implements CommandLineRunner {

    @Autowired
    private QuartzUtils quartzUtils;


    @Override
    public void run(String... args) throws Exception {
        // 每十秒执行一次
        quartzUtils.addSingleJob(QuartzDemoJob.class, "demo-job", 10);
    }
}

2.6 源码地址

https://github.com/lysmile/spring-boot-demo/tree/master/spring-boot-quartz-demo

附：Crontab实例

# 每分钟的第0秒执行
0 */1 * * * ?
# 每隔5秒执行一次
*/5 * * * * ?
# 每天23:00:00执行
0 0 23 * * ?
# 每天凌晨1点执行
0 0 1 * * ?
# 每月1号凌晨0点执行
0 0 0 1 * ?
# 每月最后一天23点执行一次
0 0 23 L * ?
# 每周的星期天凌晨0点实行一次
0 0 0 ? * 1
# 每个小时的10分、20分、30分分别执行一次
0 10,20,30 * * * ?
# 每天的0点、1点、2点分别执行
0 0 0,1,2 * * ?