/**
 * 自动扫描，启动时间点之后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 , – * /
简单举例：

/**
 * 自动扫描，启动时间点之后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依赖

<!-- quartz -->
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.2.3</version>
</dependency>
<!-- spring集成quartz -->
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context-support</artifactId>
</dependency>
<!-- 因为SchedulerFactoryBean中依赖了org.springframework.transaction.PlatformTransactionManager,所以需依赖tx相关包，其实还是quartz有个分布式功能，是使用数据库完成的。 -->
    <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
</dependency>

/**
 * 通过工厂类，创建job实例
 * @return
 */
@Bean
public MethodInvokingJobDetailFactoryBean customJobDetailFactoryBean() {

    MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
    //设置执行任务的bean
    jobDetail.setTargetBeanName("quartzTask");
    //设置具体执行的方法
    jobDetail.setTargetMethod("quartzTask");
    //同步执行，上一任务未执行完，下一任务等待
    //true 任务并发执行
    //false 下一个任务必须等待上一任务完成
    jobDetail.setConcurrent(false);
    return jobDetail;
}

/**
 * 通过工厂类创建Trigger
 * @param jobDetailFactoryBean
 * @return
 * @throws ParseException
 */
@Bean(name = "cronTriggerBean")
public Trigger cronTriggerBean(MethodInvokingJobDetailFactoryBean jobDetailFactoryBean) throws ParseException {
    CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
    cronTriggerFactoryBean.setJobDetail(jobDetailFactoryBean.getObject());
    cronTriggerFactoryBean.setCronExpression("0/3 * * * * ?");//每3秒执行一次
    cronTriggerFactoryBean.setName("customCronTrigger");
    cronTriggerFactoryBean.afterPropertiesSet();
    return cronTriggerFactoryBean.getObject();

}

/**
 * 调度工厂类,自动注入Trigger
 * @return
 */
@Bean
public SchedulerFactoryBean schedulerFactoryBean(Trigger... triggers) {
    SchedulerFactoryBean bean = new SchedulerFactoryBean();

    //也可以直接注入 ApplicationContext,利于 getBeansOfType获取trigger

// Map<String,Trigger> triggerMap = appContext.getBeansOfType(Trigger.class);
// if(triggerMap != null) {
// List<Trigger> triggers = new ArrayList<>(triggerMap.size());
// //
// triggerMap.forEach((key,trigger)->{
// triggers.add(trigger);
// });
// bean.setTriggers(triggers.toArray(new Trigger[triggers.size()]));
// }
//这里注意 对应的trigger 不能为null 不然会异常的
bean.setTriggers(triggers);
return bean;
}

@Component("quartzTask")
public class QuartzTask {

    public void quartzTask() {
        log.info("Quartz定时任务：" + new Date());
    }
}

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

2018-08-18 23:42:03.019  INFO 772 --- [ryBean_Worker-2] c.l.l.s.chapter22.config.QuartzConfig    : Quartz定时任务：Sun Aug 18 23:42:03 CST 2018
2018-08-18 23:42:06.002  INFO 772 --- [ryBean_Worker-3] c.l.l.s.chapter22.config.QuartzConfig    : Quartz定时任务：Sun Aug 18 23:42:06 CST 2018
2018-08-18 23:42:09.002  INFO 772 --- [ryBean_Worker-4] c.l.l.s.chapter22.config.QuartzConfig    : Quartz定时任务：Sun Aug 18 23:42:09 CST 2018

关于Quartz的详细用法，再次不表了。好久没有使用过了。有机会再来详细阐述吧。

分布式调度服务浅谈
在单机模式下，定时任务是没什么问题的。但当我们部署了多台服务，同时又每台服务又有定时任务时，若不进行合理的控制在同一时间，只有一个定时任务启动执行，这时，定时执行的结果就可能存在混乱和错误了。

这里简单的说说相关的解决方案吧，一家之言，希望大家能提出自己的见解，共同进步！

其实现原理也相对简单：通过数据库实现任务的持久化，保存定时任务的相关配置信息，以保证下次系统启动时，定时任务能自动启动。同时，通过数据库行锁(for update)机制，控制一个任务只能被一个实例运行，只有获取锁的实例才能运行任务，其他的只能等待，直到锁被释放。这种方式有些弊端，就是依赖了数据库，同时也需要保证各服务器之间的时间需要同步，不然也是会混乱的。

现在Quartz也有基于Redis的集群方案，有兴趣的可以搜索下。

分布式锁：可通过使用Redis或者ZooKeeper实现一个分布式锁的机制，使得只有获取到锁的实例方能运行定时任务，避免任务重复执行。可查看下开源的基于Redis实现的分布式锁项目：redisson。
统一调度中心：
可构建一个纯粹的定时服务，只有定时器相关配置，比如定时时间，定时调度的api接口或者http服务，甚至是统一注册中心下的服务类，如dubbo服务等。而具体的任务执行操作都在各自业务方系统中，调度中心只负责接口的调用，具体实现还是在业务方。这种方案相对来说比较通用，实现起来也简单。就是需要业务方进行约定编程，或者对外提供一个api接口。

当然，为了实现定时任务的自动发现和注册功能，还是需要规范一套规则来实现自动注册功能。简单来说，以Dubbo服务为例，可以定义一个定时任务接口类，调度中心只需要获取所有实现此接口的服务，同时通过服务的相关配置(调度时间、失败策略等)进行相关定时操作。或者编写一个服务注册与发现的客户端，通过Spring获取到实现此接口的所有实现类，上送到调度中心。

而且，统一调度中心，还可以对所有的定时任务的调度情况进行有效监控，日志记录等，也可以约定接口，让定时任务回传定时结果，做到全局把控的目的。

以上就是对分布式调度的一点理解，有错误的地方还望指正，有更好的方案也希望能分享下。

总结

本章节主要是讲解了通过不同的方式实现定时任务。对于定时任务而言，本身是门大学问，一俩篇文章是讲不完的。像SpringTask和Quartz都是很强大的调度器，两者很相似，像如何实现任务的动态修改调度周期，动态停止相关任务，调度任务的监控，这些本文章都没有涉及。
最后
目前互联网上很多大佬都有SpringBoot系列教程，如有雷同，请多多包涵了。若文中有所错误之处，还望提出，谢谢。

原文地址：http://blog.51cto.com/13932491/2176753