一點知識
在JAVA開發(fā)領(lǐng)域硫椰，目前可以通過以下幾種方式進行定時任務:
Timer：jdk中自帶的一個定時調(diào)度類制跟，可以簡單的實現(xiàn)按某一頻度進行任務執(zhí)行铜邮。提供的功能比較單一仪召，無法實現(xiàn)復雜的調(diào)度任務。
ScheduledExecutorService：也是jdk自帶的一個基于線程池設計的定時任務類。其每個調(diào)度任務都會分配到線程池中的一個線程執(zhí)行，所以其任務是并發(fā)執(zhí)行的攒霹，互不影響奔缠。
Spring Task：Spring提供的一個任務調(diào)度工具，支持注解和配置文件形式，支持Cron表達式，使用簡單但功能強大。
Quartz：一款功能強大的任務調(diào)度器萤晴，可以實現(xiàn)較為復雜的調(diào)度功能，如每月一號執(zhí)行胁后、每天凌晨執(zhí)行店读、每周五執(zhí)行等等，還支持分布式調(diào)度攀芯，就是配置稍顯復雜屯断。
題外話：對于Quartz，早前用過1.6版本的，更新到2.x及以上版本后基本沒怎么接觸了殖演，原來還有倒騰過結(jié)合Kettle做了一些動態(tài)的定時抽取數(shù)據(jù)啥的還編寫過一個Cron表達式編輯器氧秘，現(xiàn)在基本忘記了。趴久。等有機會丸相，再次深入學習后再來單獨分享一些關(guān)于的Quartz心得吧。
基于JDK方式實現(xiàn)簡單定時
剛剛有介紹過彼棍，基于JDK方式一共有兩種：Timer和ScheduledExecutorService灭忠。接下來，就簡單講解下這兩種方式座硕。
Timer
Timer是jdk提供的java.util.Timer類弛作。
簡單示例：
@GetMapping("/timer")
public String doTimer() {
? ? Timer timer = new Timer();
? ? timer.schedule(new TimerTask() {
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? log.info("Timer定時任務啟動：" + new Date());
? ? ? ? }
? ? }, 1000,1000);//延遲1秒啟動，每1秒執(zhí)行一次
? ? return "timer";
啟動后华匾，訪問即可看見控制臺周期性輸出信息了：
2018-08-18 21:30:35.171? INFO 13352 --- [? ? ? ? Timer-0] c.l.l.s.c.controller.TaskController? ? ? : Timer定時任務啟動：Sat Aug 18 21:30:35 CST 2018
2018-08-18 21:30:36.173? INFO 13352 --- [? ? ? ? Timer-0] c.l.l.s.c.controller.TaskController? ? ? : Timer定時任務啟動：Sat Aug 18 21:30:36 CST 2018
2018-08-18 21:30:37.173? INFO 13352 --- [? ? ? ? Timer-0] c.l.l.s.c.controller.TaskController? ? ? : Timer定時任務啟動：Sat Aug 18 21:30:37 CST 2018
2018-08-18 21:30:38.173? INFO 13352 --- [? ? ? ? Timer-0] c.l.l.s.c.controller.TaskController? ? ? : Timer定時任務啟動：Sat Aug 18 21:30:38 CST 2018
2018-08-18 21:30:39.174? INFO 13352 --- [? ? ? ? Timer-0] c.l.l.s.c.controller.TaskController? ? ? : Timer定時任務啟動：Sat Aug 18 21:30:39 CST 2018
......
相關(guān)API簡單說明：
1映琳、在特定時間執(zhí)行任務，只執(zhí)行一次
public void schedule(TimerTask task,Date time)
2蜘拉、在特定時間之后執(zhí)行任務萨西，只執(zhí)行一次
public void schedule(TimerTask task,long delay)
3、指定第一次執(zhí)行的時間诸尽，然后按照間隔時間原杂，重復執(zhí)行
public void schedule(TimerTask task,Date firstTime,long period)
4、在特定延遲之后第一次執(zhí)行您机，然后按照間隔時間，重復執(zhí)行
public void schedule(TimerTask task,long delay,long period)
5年局、第一次執(zhí)行之后际看，特定頻率執(zhí)行，與3同
public void scheduleAtFixedRate(TimerTask task,Date firstTime,long period)
6矢否、在delay毫秒之后第一次執(zhí)行仲闽，后按照特定頻率執(zhí)行
public void scheduleAtFixedRate(TimerTask task,long delay,long period)
參數(shù)：
delay： 延遲執(zhí)行的毫秒數(shù)，即在delay毫秒之后第一次執(zhí)行
period：重復執(zhí)行的時間間隔
取消任務使用：timer.cancel()方法即可注銷任務僵朗。
此類相對用的較少了赖欣，簡單了解下。
ScheduledExecutorService
ScheduledExecutorService可以說是Timer的替代類验庙，因為Timer不支持多線程顶吮，任務是串行的，而且也不捕獲異常粪薛，假設某個任務異常了悴了，整個Timer就無法運行了。
簡單示例：
@GetMapping("/executor")
public String ScheduledExecutorService() {
? ? //
? ? ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
? ? service.scheduleAtFixedRate(new Runnable() {
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? log.info("ScheduledExecutorService定時任務執(zhí)行：" + new Date());? ? ? ? ? ? ? ?
? ? ? ? }
? ? }, 1, 1, TimeUnit.SECONDS);//首次延遲1秒，之后每1秒執(zhí)行一次
? ? log.info("ScheduledExecutorService定時任務啟動：" + new Date());? ?
? ? return "ScheduledExecutorService!";? ? ? ?
}
啟動后湃交，可看見控制臺按設定的頻率輸出：
2018-08-18 22:03:24.840? INFO 6752 --- [nio-8080-exec-1] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務啟動：Sat Aug 18 22:03:24 CST 2018
2018-08-18 22:03:25.841? INFO 6752 --- [pool-1-thread-1] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務執(zhí)行：Sat Aug 18 22:03:25 CST 2018
2018-08-18 22:03:26.842? INFO 6752 --- [pool-1-thread-1] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務執(zhí)行：Sat Aug 18 22:03:26 CST 2018
2018-08-18 22:03:27.841? INFO 6752 --- [pool-1-thread-2] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務執(zhí)行：Sat Aug 18 22:03:27 CST 2018
2018-08-18 22:03:28.840? INFO 6752 --- [pool-1-thread-1] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務執(zhí)行：Sat Aug 18 22:03:28 CST 2018
2018-08-18 22:03:29.840? INFO 6752 --- [pool-1-thread-3] c.l.l.s.c.controller.TaskController? ? ? : ScheduledExecutorService定時任務執(zhí)行：Sat Aug 18 22:03:29 CST 2018
可同時設置多個任務熟空，只需再次設置scheduleAtFixedRate即可。
常用方法說明：
ScheduleAtFixedRate：
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit);
參數(shù)說明：
command：執(zhí)行線程
initialDelay：初始化延時
period：兩次開始執(zhí)行最小間隔時間
unit：計時單位
ScheduleWithFixedDelay：
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit);
參數(shù)說明：
command：執(zhí)行線程
initialDelay：初始化延時
delay：前一次執(zhí)行結(jié)束到下一次執(zhí)行開始的間隔時間（間隔執(zhí)行延遲時間）
unit：計時單位
其他的方法大家可自行谷歌下搞莺。
基于SpingTask實現(xiàn)定時任務
使用SpringTask在SpringBoot是很簡單的息罗，使用@Scheduled注解即可輕松搞定。
0.啟動類才沧，加入@EnableScheduling讓注解@Scheduled生效迈喉。
@SpringBootApplication
@EnableScheduling
@Slf4j
public class Chapter22Application {
? ? public static void main(String[] args) {
? ? ? ? SpringApplication.run(Chapter22Application.class, args);
? ? ? ? log.info("Chapter22啟動!");
? ? }
}
1.編寫一個調(diào)度類，系統(tǒng)啟動后自動掃描糜工，自動執(zhí)行弊添。
@Component
@Slf4j
public class ScheduledTask {
? ? /**
? ? * 自動掃描，啟動時間點之后5秒執(zhí)行一次
? ? */
? ? @Scheduled(fixedRate=5000)
? ? public void getCurrentDate() {
? ? ? ? log.info("Scheduled定時任務執(zhí)行：" + 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定時任務執(zhí)行：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定時任務執(zhí)行：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定時任務執(zhí)行：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定時任務執(zhí)行：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定時任務執(zhí)行：Sat Aug 18 22:23:29 CST 2018
......
使用都是簡單的油坝，現(xiàn)在我們來看看注解@Scheduled的參數(shù)意思：
fixedRate：定義一個按一定頻率執(zhí)行的定時任務
fixedDelay：定義一個按一定頻率執(zhí)行的定時任務，與上面不同的是刨裆，改屬性可以配合initialDelay澈圈， 定義該任務延遲執(zhí)行時間。
cron：通過表達式來配置任務執(zhí)行時間
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 * * * * ?：每秒執(zhí)行一次
0 0 2 1 * ? ： 表示在每月的1日的凌晨2點調(diào)整任務
0 0 10,14,16 ? ：每天上午10點，下午2點努潘，4點
0 0 12 * * ? ： 每天中午12點觸發(fā)
0 15 10 ? * MON-FRI ： 周一至周五的上午10:15觸發(fā)
自定義線程池
從控制臺輸出可以看見诽偷，多任務使用的是同一個線程》枥ぃ可結(jié)合上章節(jié)的異步調(diào)用來實現(xiàn)不同任務使用不同的線程進行任務執(zhí)行报慕。
0.編寫配置類,同時啟用@Async注解：
@Configuration
@EnableAsync
public class Config {
? ? /**
? ? * 配置線程池
? ? * @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());
? ? ? ? //調(diào)度器shutdown被調(diào)用時等待當前被調(diào)度的任務完成
? ? ? ? taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
? ? ? ? //等待時長
? ? ? ? taskExecutor.setAwaitTerminationSeconds(60);
? ? ? ? taskExecutor.initialize();
? ? ? ? return taskExecutor;
? ? }
}
1.調(diào)度類上加入@Async。
@Component
@Slf4j
public class ScheduledTask {
? ? /**
? ? * 自動掃描菌瘫，啟動時間點之后5秒執(zhí)行一次
? ? */
? ? @Async("scheduledPoolTaskExecutor")
? ? @Scheduled(fixedRate=5000)
? ? public void getCurrentDate() {
? ? ? ? log.info("Scheduled定時任務執(zhí)行：" + new Date());
? ? }
}
再次啟動程序蜗顽，可看見控制臺輸出，任務已經(jīng)是不同線程下執(zhí)行了：
2018-08-18 22:47:13.313? INFO 14212 --- [ong-Scheduled-1] c.l.l.s.c.controller.ScheduledTask? ? ? : Scheduled定時任務執(zhí)行：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定時任務執(zhí)行：Sat Aug 18 22:47:18 CST 2018
動態(tài)添加定時任務
使用注解的方式雨让，無法實現(xiàn)動態(tài)的修改或者添加新的定時任務的雇盖，這個使用就需要使用編程的方式進行任務的更新操作了」迹可直接使用ThreadPoolTaskScheduler或者SchedulingConfigurer接口進行自定義定時任務創(chuàng)建刊懈。
ThreadPoolTaskScheduler
ThreadPoolTaskScheduler是SpringTask的核心實現(xiàn)類这弧，該類提供了大量的重載方法進行任務調(diào)度。這里簡單示例下虚汛，具體的大家自行搜索下匾浪，用的少不太了解呀。
0.創(chuàng)建一個ThreadPoolTaskScheduler類卷哩。
@Bean("taskExecutor")
public TaskScheduler taskExecutor() {
? ? ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
? ? executor.setPoolSize(20);
? ? executor.setThreadNamePrefix("oKong-taskExecutor-");
? ? executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
? ? //調(diào)度器shutdown被調(diào)用時等待當前被調(diào)度的任務完成
? ? executor.setWaitForTasksToCompleteOnShutdown(true);
? ? //等待時長
? ? executor.setAwaitTerminationSeconds(60);
? ? return executor;
}
1.編寫一個控制類蛋辈，動態(tài)設置定時任務：
@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秒執(zhí)行一次
? ? 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
此類十個接口冷溶，直接實現(xiàn)其configurerTasks方法即可。
0.編寫配置類：
@Configuration
@Slf4j
public class ScheduleConfig implements SchedulingConfigurer {
? ? @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秒執(zhí)行一次
? ? }
? ? @Bean("taskExecutor")
? ? public TaskScheduler taskExecutor() {
? ? ? ? ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
? ? ? ? executor.setPoolSize(20);
? ? ? ? executor.setThreadNamePrefix("oKong-Executor-");
? ? ? ? executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
? ? ? ? //調(diào)度器shutdown被調(diào)用時等待當前被調(diào)度的任務完成
? ? ? ? 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實現(xiàn)定時調(diào)度
由于本章節(jié)是基于SpringBoot 1.x版本的逞频，所以沒有基于Quartz的starter配置，這里直接引入了Quartz相關(guān)依賴包來集成栋齿。
題外話：原本使用SpringMvc時苗胀，一般上都是通過xml文件，配置其org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean類進行具體執(zhí)行任務的配置瓦堵，指定執(zhí)行的對象和方法基协。然后通過設置CronTriggerFactoryBean或者SimpleTriggerFactoryBean設置定時器，最后通過org.springframework.scheduling.quartz.SchedulerFactoryBean加入調(diào)度的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相關(guān)包惋鸥，其實還是quartz有個分布式功能杂穷，是使用數(shù)據(jù)庫完成的。 -->
? ? <dependency>
? ? <groupId>org.springframework</groupId>
? ? <artifactId>spring-tx</artifactId>
</dependency>
1.編寫配置類卦绣。
@Configuration
@Slf4j
public class QuartzConfig {
? ? /**
? ? * 通過工廠類亭畜，創(chuàng)建job實例
? ? * @return
? ? */
? ? @Bean
? ? public MethodInvokingJobDetailFactoryBean customJobDetailFactoryBean() {
? ? ? ? MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
? ? ? ? //設置執(zhí)行任務的bean
? ? ? ? jobDetail.setTargetBeanName("quartzTask");
? ? ? ? //設置具體執(zhí)行的方法
? ? ? ? jobDetail.setTargetMethod("quartzTask");
? ? ? ? //同步執(zhí)行，上一任務未執(zhí)行完迎卤，下一任務等待
? ? ? ? //true 任務并發(fā)執(zhí)行
? ? ? ? //false 下一個任務必須等待上一任務完成
? ? ? ? jobDetail.setConcurrent(false);
? ? ? ? return jobDetail;
? ? }
? ? /**
? ? * 通過工廠類創(chuàng)建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秒執(zhí)行一次
? ? ? ? cronTriggerFactoryBean.setName("customCronTrigger");
? ? ? ? cronTriggerFactoryBean.afterPropertiesSet();
? ? ? ? return cronTriggerFactoryBean.getObject();
? ? }
? ? /**
? ? * 調(diào)度工廠類,自動注入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秒執(zhí)行一次輸出：
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
關(guān)于Quartz的詳細用法玷坠，再次不表了蜗搔。好久沒有使用過了。有機會再來詳細闡述吧八堡。
分布式調(diào)度服務淺談
在單機模式下樟凄，定時任務是沒什么問題的。但當我們部署了多臺服務兄渺，同時又每臺服務又有定時任務時缝龄，若不進行合理的控制在同一時間，只有一個定時任務啟動執(zhí)行，這時叔壤，定時執(zhí)行的結(jié)果就可能存在混亂和錯誤了瞎饲。
這里簡單的說說相關(guān)的解決方案吧，一家之言炼绘，希望大家能提出自己的見解嗅战，共同進步！
剝離所有定時任務到一個工程：此方案是最簡單的俺亮，在定時任務相對較小驮捍，并發(fā)任務不多時，可以使用此方案脚曾。簡單也容易維護东且。當定時任務牽扯的業(yè)務越來越多，越來越雜時本讥，維護量就成本增加了珊泳，工程會越來越臃腫，此方案就不實用了囤踩。
利用Quartz集群方案：本身Quartz是支持通過數(shù)據(jù)庫實現(xiàn)集群的旨椒，以下是其集群架構(gòu)圖：
集群架構(gòu)圖
其實現(xiàn)原理也相對簡單：通過數(shù)據(jù)庫實現(xiàn)任務的持久化，保存定時任務的相關(guān)配置信息堵漱，以保證下次系統(tǒng)啟動時综慎，定時任務能自動啟動。同時勤庐，通過數(shù)據(jù)庫行鎖(for update)機制示惊，控制一個任務只能被一個實例運行，只有獲取鎖的實例才能運行任務愉镰，其他的只能等待米罚，直到鎖被釋放。這種方式有些弊端丈探，就是依賴了數(shù)據(jù)庫录择，同時也需要保證各服務器之間的時間需要同步，不然也是會混亂的碗降。
現(xiàn)在Quartz也有基于Redis的集群方案隘竭，有興趣的可以搜索下。
分布式鎖：可通過使用Redis或者ZooKeeper實現(xiàn)一個分布式鎖的機制讼渊，使得只有獲取到鎖的實例方能運行定時任務动看，避免任務重復執(zhí)行∽茫可查看下開源的基于Redis實現(xiàn)的分布式鎖項目：redisson菱皆。
統(tǒng)一調(diào)度中心：
可構(gòu)建一個純粹的定時服務须误，只有定時器相關(guān)配置，比如定時時間仇轻，定時調(diào)度的api接口或者http服務京痢，甚至是統(tǒng)一注冊中心下的服務類，如dubbo服務等拯田。而具體的任務執(zhí)行操作都在各自業(yè)務方系統(tǒng)中历造，調(diào)度中心只負責接口的調(diào)用，具體實現(xiàn)還是在業(yè)務方船庇。這種方案相對來說比較通用吭产，實現(xiàn)起來也簡單。就是需要業(yè)務方進行約定編程鸭轮，或者對外提供一個api接口臣淤。
當然，為了實現(xiàn)定時任務的自動發(fā)現(xiàn)和注冊功能窃爷，還是需要規(guī)范一套規(guī)則來實現(xiàn)自動注冊功能邑蒋。簡單來說，以Dubbo服務為例按厘，可以定義一個定時任務接口類医吊，調(diào)度中心只需要獲取所有實現(xiàn)此接口的服務，同時通過服務的相關(guān)配置(調(diào)度時間逮京、失敗策略等)進行相關(guān)定時操作卿堂。或者編寫一個服務注冊與發(fā)現(xiàn)的客戶端懒棉，通過Spring獲取到實現(xiàn)此接口的所有實現(xiàn)類草描，上送到調(diào)度中心。
而且策严，統(tǒng)一調(diào)度中心穗慕，還可以對所有的定時任務的調(diào)度情況進行有效監(jiān)控，日志記錄等妻导，也可以約定接口逛绵，讓定時任務回傳定時結(jié)果，做到全局把控的目的倔韭。
以上就是對分布式調(diào)度的一點理解暑脆，有錯誤的地方還望指正，有更好的方案也希望能分享下狐肢。
總結(jié)
本章節(jié)主要是講解了通過不同的方式實現(xiàn)定時任務。對于定時任務而言沥曹，本身是門大學問份名，一倆篇文章是講不完的碟联。像SpringTask和Quartz都是很強大的調(diào)度器，兩者很相似僵腺，像如何實現(xiàn)任務的動態(tài)修改調(diào)度周期鲤孵，動態(tài)停止相關(guān)任務，調(diào)度任務的監(jiān)控辰如，這些本文章都沒有涉及普监。還希望有相關(guān)需求的同學自行搜索相關(guān)資料了。
最后
目前互聯(lián)網(wǎng)上很多大佬都有SpringBoot系列教程琉兜，如有雷同凯正，請多多包涵了。本文是作者在電腦前一字一句敲的豌蟋，每一步都是自己實踐的廊散。若文中有所錯誤之處，還望提出梧疲，謝謝允睹。
