SpringBoot 定时任务的使用

public static void main(String[] args) {
    SpringApplication.run(Chapter22Application.class, args);
    log.info("Chapter22启动!");
}

}
1.编写一个调度类，系统启动后自动扫描，自动执行。

/**
 * 自动扫描，启动时间点之后5秒执行一次
 */
@Scheduled(fixedRate=5000)
public void getCurrentDate() {
    log.info("Scheduled定时任务执行：" + new Date());
}

}
2.启动后，控制台可就看见每5秒一次输出了：

2018-08-18 22:23:09.735 INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:23:09 CST 2018
2018-08-18 22:23:14.734 INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:23:14 CST 2018
2018-08-18 22:23:19.735 INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:23:19 CST 2018
2018-08-18 22:23:24.735 INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:23:24 CST 2018
2018-08-18 22:23:29.735 INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:23:29 CST 2018
......
使用都是简单的，现在我们来看看注解@Scheduled的参数意思：

fixedRate：定义一个按一定频率执行的定时任务
fixedDelay：定义一个按一定频率执行的定时任务，与上面不同的是，改属性可以配合initialDelay， 定义该任务延迟执行时间。
cron：通过表达式来配置任务执行时间
Cron表达式详解
一个cron表达式有至少6个（也可能7个）有空格分隔的时间元素。

依次顺序如下表所示：

字段 允许值 允许的特殊字符
秒 0~59 , – /
分 0~59 , – /
小时 0~23 , – /
日期 1-31 , – ? / L W C
月份 1~12或者JAN~DEC , – /
星期 1~7或者SUN~SAT , – ? / L C #
年（可选） 留空，1970~2099 , – * /
简单举例：

0/1 ?：每秒执行一次
0 0 2 1 ? ： 表示在每月的1日的凌晨2点调整任务
0 0 10,14,16 ? ：每天上午10点，下午2点，4点
0 0 12 ? ： 每天中午12点触发
0 15 10 ? MON-FRI ： 周一至周五的上午10:15触发

在线表达式编辑器

自定义线程池
从控制台输出可以看见，多任务使用的是同一个线程。可结合上章节的异步调用来实现不同任务使用不同的线程进行任务执行。

0.编写配置类,同时启用@Async注解：

• 配置线程池
• @return
  */
  @Bean(name = "scheduledPoolTaskExecutor")
  public ThreadPoolTaskExecutor getAsyncThreadPoolTaskExecutor() {
  ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
  taskExecutor.setCorePoolSize(20);
  taskExecutor.setMaxPoolSize(200);
  taskExecutor.setQueueCapacity(25);
  taskExecutor.setKeepAliveSeconds(200);
  taskExecutor.setThreadNamePrefix("oKong-Scheduled-");
  // 线程池对拒绝任务（无线程可用）的处理策略，目前只支持AbortPolicy、CallerRunsPolicy；默认为后者
  taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
  //调度器shutdown被调用时等待当前被调度的任务完成
  taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
  //等待时长
  taskExecutor.setAwaitTerminationSeconds(60);
  taskExecutor.initialize();
  return taskExecutor;
  }
  }
  1.调度类上加入@Async。

/**
 * 自动扫描，启动时间点之后5秒执行一次
 */
@Async("scheduledPoolTaskExecutor")
@Scheduled(fixedRate=5000)
public void getCurrentDate() {
    log.info("Scheduled定时任务执行：" + new Date());
}

}
再次启动程序，可看见控制台输出，任务已经是不同线程下执行了：

2018-08-18 22:47:13.313 INFO 14212 --- [ong-Scheduled-1] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:47:13 CST 2018
2018-08-18 22:47:13.343 INFO 14212 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8080 (http)
2018-08-18 22:47:13.348 INFO 14212 --- [ main] c.l.l.s.chapter22.Chapter22Application : Started Chapter22Application in 2.057 seconds (JVM running for 2.855)
2018-08-18 22:47:13.348 INFO 14212 --- [ main] c.l.l.s.chapter22.Chapter22Application : Chapter22启动!
2018-08-18 22:47:18.308 INFO 14212 --- [ong-Scheduled-2] c.l.l.s.c.controller.ScheduledTask : Scheduled定时任务执行：Sat Aug 18 22:47:18 CST 2018
动态添加定时任务
使用注解的方式，无法实现动态的修改或者添加新的定时任务的，这个使用就需要使用编程的方式进行任务的更新操作了。可直接使用ThreadPoolTaskScheduler或者SchedulingConfigurer接口进行自定义定时任务创建。

ThreadPoolTaskScheduler
ThreadPoolTaskScheduler是SpringTask的核心实现类，该类提供了大量的重载方法进行任务调度。这里简单示例下，具体的大家自行搜索下，用的少不太了解呀。

0.创建一个ThreadPoolTaskScheduler类。

@Bean("taskExecutor")
public TaskScheduler taskExecutor() {
ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
executor.setPoolSize(20);
executor.setThreadNamePrefix("oKong-taskExecutor-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
//调度器shutdown被调用时等待当前被调度的任务完成
executor.setWaitForTasksToCompleteOnShutdown(true);
//等待时长
executor.setAwaitTerminationSeconds(60);
return executor;
}
1.编写一个控制类，动态设置定时任务：

@Autowired
TaskScheduler taskScheduler;

@GetMapping("/poolTask")
public String threadPoolTaskScheduler() {

taskScheduler.schedule(new Runnable() {

    @Override
    public void run() {
        log.info("ThreadPoolTaskScheduler定时任务：" + new Date());
    }
}, new CronTrigger("0/3 * * * * ?"));//每3秒执行一次
return "ThreadPoolTaskScheduler!";

}
2.启动后，访问接口，即可看见控制台每3秒输出一次：

2018-08-18 23:20:39.002 INFO 9120 --- [Kong-Executor-1] c.l.l.s.c.controller.TaskController : ThreadPoolTaskScheduler定时任务：Sat Aug 18 23:20:39 CST 2018
2018-08-18 23:20:42.000 INFO 9120 --- [Kong-Executor-1] c.l.l.s.c.controller.TaskController : ThreadPoolTaskScheduler定时任务：Sat Aug 18 23:20:42 CST 2018
2018-08-18 23:20:45.002 INFO 9120 --- [Kong-Executor-2] c.l.l.s.c.controller.TaskController : ThreadPoolTaskScheduler定时任务：Sat Aug 18 23:20:45 CST 2018
2018-08-18 23:20:48.001 INFO 9120 --- [Kong-Executor-1] c.l.l.s.c.controller.TaskController : ThreadPoolTaskScheduler定时任务：Sat Aug 18 23:20:48 CST 2018
SchedulingConfigurer
此类十个接口，直接实现其configurerTasks方法即可。

0.编写配置类：

@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    taskRegistrar.setTaskScheduler(taskExecutor());
    taskRegistrar.getScheduler().schedule(new Runnable() {

        @Override
        public void run() {
            log.info("SchedulingConfigurer定时任务：" + new Date());
        }
    }, new CronTrigger("0/3 * * * * ?"));//每3秒执行一次
}

@Bean("taskExecutor")
public TaskScheduler taskExecutor() {
    ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
    executor.setPoolSize(20);
    executor.setThreadNamePrefix("oKong-Executor-");
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    //调度器shutdown被调用时等待当前被调度的任务完成
    executor.setWaitForTasksToCompleteOnShutdown(true);
    //等待时长
    executor.setAwaitTerminationSeconds(60);
    return executor;
}

}
1.启动后，控制台也可以看见每3秒输出一次：

2018-08-18 23:24:39.001 INFO 868 --- [Kong-Executor-1] c.l.l.s.chapter22.config.ScheduleConfig : SchedulingConfigurer定时任务：Sat Aug 18 23:24:39 CST 2018
2018-08-18 23:24:42.001 INFO 868 --- [Kong-Executor-1] c.l.l.s.chapter22.config.ScheduleConfig : SchedulingConfigurer定时任务：Sat Aug 18 23:24:42 CST 2018
2018-08-18 23:24:45.000 INFO 868 --- [Kong-Executor-2] c.l.l.s.chapter22.config.ScheduleConfig : SchedulingConfigurer定时任务：Sat Aug 18 23:24:45 CST 2018
基于Quartz实现定时调度
由于本章节是基于SpringBoot 1.x版本的，所以没有基于Quartz的starter配置，这里直接引入了Quartz相关依赖包来集成。

题外话：原本使用SpringMvc时，一般上都是通过xml文件，配置其org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean类进行具体执行任务的配置，指定执行的对象和方法。然后通过设置CronTriggerFactoryBean或者SimpleTriggerFactoryBean设置定时器，最后通过org.springframework.scheduling.quartz.SchedulerFactoryBean加入调度的trigger。所以，我们就使用javaConfig方式进行简单集成下。

0.加入pom依赖