原文出處： oKong

前言

上兩章節(jié)咨堤，我們簡(jiǎn)單的講解了關(guān)于異步調(diào)用和異步請(qǐng)求相關(guān)知識(shí)點(diǎn)。這一章節(jié)先紫，我們來(lái)講講開(kāi)發(fā)過(guò)程也是經(jīng)常會(huì)碰見(jiàn)的定時(shí)任務(wù)。比如每天定時(shí)清理無(wú)效數(shù)據(jù)、定時(shí)發(fā)送短信、定時(shí)發(fā)送郵件淮菠、支付系統(tǒng)中的定時(shí)對(duì)賬等等，往往都會(huì)定義一些定時(shí)器荤堪，進(jìn)行此業(yè)務(wù)的開(kāi)發(fā)合陵。所以，本章節(jié)介紹下在SpringBoot中定時(shí)任務(wù)如何使用及一點(diǎn)分布式定時(shí)服務(wù)的思考總結(jié)澄阳。

一點(diǎn)知識(shí)

在JAVA開(kāi)發(fā)領(lǐng)域拥知，目前可以通過(guò)以下幾種方式進(jìn)行定時(shí)任務(wù):

• Timer：jdk中自帶的一個(gè)定時(shí)調(diào)度類(lèi)，可以簡(jiǎn)單的實(shí)現(xiàn)按某一頻度進(jìn)行任務(wù)執(zhí)行碎赢。提供的功能比較單一低剔，無(wú)法實(shí)現(xiàn)復(fù)雜的調(diào)度任務(wù)。
• ScheduledExecutorService：也是jdk自帶的一個(gè)基于線程池設(shè)計(jì)的定時(shí)任務(wù)類(lèi)肮塞。其每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的一個(gè)線程執(zhí)行襟齿，所以其任務(wù)是并發(fā)執(zhí)行的，互不影響枕赵。
• Spring Task：Spring提供的一個(gè)任務(wù)調(diào)度工具猜欺，支持注解和配置文件形式，支持Cron表達(dá)式拷窜，使用簡(jiǎn)單但功能強(qiáng)大开皿。
• Quartz：一款功能強(qiáng)大的任務(wù)調(diào)度器，可以實(shí)現(xiàn)較為復(fù)雜的調(diào)度功能篮昧，如每月一號(hào)執(zhí)行副瀑、每天凌晨執(zhí)行、每周五執(zhí)行等等恋谭，還支持分布式調(diào)度，就是配置稍顯復(fù)雜挽鞠。

題外話：對(duì)于Quartz疚颊，早前用過(guò)1.6版本的，更新到2.x及以上版本后基本沒(méi)怎么接觸了信认，原來(lái)還有倒騰過(guò)結(jié)合Kettle做了一些動(dòng)態(tài)的定時(shí)抽取數(shù)據(jù)啥的還編寫(xiě)過(guò)一個(gè)Cron表達(dá)式編輯器材义，現(xiàn)在基本忘記了。嫁赏。等有機(jī)會(huì)其掂，再次深入學(xué)習(xí)后再來(lái)單獨(dú)分享一些關(guān)于的Quartz心得吧。

基于JDK方式實(shí)現(xiàn)簡(jiǎn)單定時(shí)

剛剛有介紹過(guò)潦蝇，基于JDK方式一共有兩種：Timer和ScheduledExecutorService款熬。接下來(lái)深寥，就簡(jiǎn)單講解下這兩種方式。

Timer

Timer是jdk提供的java.util.Timer類(lèi)贤牛。

簡(jiǎn)單示例：

@GetMapping("/timer")
public String doTimer() {
    Timer timer = new Timer();
    timer.schedule(new TimerTask() {
         
        @Override
        public void run() {
            log.info("Timer定時(shí)任務(wù)啟動(dòng)：" + new Date());
             
        }
    }, 1000,1000);//延遲1秒啟動(dòng)惋鹅，每1秒執(zhí)行一次
    return "timer";

啟動(dòng)后，訪問(wèn)即可看見(jiàn)控制臺(tái)周期性輸出信息了：

2018-08-18 21:30:35.171  INFO 13352 --- [        Timer-0] c.l.l.s.c.controller.TaskController      : Timer定時(shí)任務(wù)啟動(dòng)：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定時(shí)任務(wù)啟動(dòng)：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定時(shí)任務(wù)啟動(dòng)：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定時(shí)任務(wù)啟動(dòng)：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定時(shí)任務(wù)啟動(dòng)：Sat Aug 18 21:30:39 CST 2018
......

相關(guān)API簡(jiǎn)單說(shuō)明：

1殉簸、在特定時(shí)間執(zhí)行任務(wù)闰集，只執(zhí)行一次

public void schedule(TimerTask task,Date time)

2、在特定時(shí)間之后執(zhí)行任務(wù)般卑，只執(zhí)行一次

public void schedule(TimerTask task,long delay)

3武鲁、指定第一次執(zhí)行的時(shí)間，然后按照間隔時(shí)間蝠检，重復(fù)執(zhí)行

public void schedule(TimerTask task,Date firstTime,long period)

4沐鼠、在特定延遲之后第一次執(zhí)行，然后按照間隔時(shí)間蝇率，重復(fù)執(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：重復(fù)執(zhí)行的時(shí)間間隔

取消任務(wù)使用：timer.cancel()方法即可注銷(xiāo)任務(wù)监氢。

此類(lèi)相對(duì)用的較少了，簡(jiǎn)單了解下藤违。

ScheduledExecutorService

ScheduledExecutorService可以說(shuō)是Timer的替代類(lèi)浪腐，因?yàn)?code>Timer不支持多線程，任務(wù)是串行的顿乒，而且也不捕獲異常议街，假設(shè)某個(gè)任務(wù)異常了，整個(gè)Timer就無(wú)法運(yùn)行了璧榄。

簡(jiǎn)單示例：

@GetMapping("/executor")
public String ScheduledExecutorService() {
    //
    ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
    service.scheduleAtFixedRate(new Runnable() {
         
        @Override
        public void run() {
            log.info("ScheduledExecutorService定時(shí)任務(wù)執(zhí)行：" + new Date());                
        }
    }, 1, 1, TimeUnit.SECONDS);//首次延遲1秒特漩，之后每1秒執(zhí)行一次
    log.info("ScheduledExecutorService定時(shí)任務(wù)啟動(dòng)：" + new Date());    
    return "ScheduledExecutorService!";        
}

啟動(dòng)后，可看見(jiàn)控制臺(tái)按設(shè)定的頻率輸出：

2018-08-18 22:03:24.840  INFO 6752 --- [nio-8080-exec-1] c.l.l.s.c.controller.TaskController      : ScheduledExecutorService定時(shí)任務(wù)啟動(dòng)：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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(zhí)行：Sat Aug 18 22:03:29 CST 2018

可同時(shí)設(shè)置多個(gè)任務(wù)骨杂，只需再次設(shè)置scheduleAtFixedRate即可涂身。

常用方法說(shuō)明：

• ScheduleAtFixedRate：

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit);

參數(shù)說(shuō)明：

1. command：執(zhí)行線程
2. initialDelay：初始化延時(shí)
3. period：兩次開(kāi)始執(zhí)行最小間隔時(shí)間
4. unit：計(jì)時(shí)單位

• ScheduleWithFixedDelay：

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit);

參數(shù)說(shuō)明：

1. command：執(zhí)行線程
2. initialDelay：初始化延時(shí)
3. delay：前一次執(zhí)行結(jié)束到下一次執(zhí)行開(kāi)始的間隔時(shí)間（間隔執(zhí)行延遲時(shí)間）
4. unit：計(jì)時(shí)單位

其他的方法大家可自行谷歌下。

基于SpingTask實(shí)現(xiàn)定時(shí)任務(wù)

使用SpringTask在SpringBoot是很簡(jiǎn)單的搓蚪，使用@Scheduled注解即可輕松搞定蛤售。

0.啟動(dòng)類(lèi)，加入@EnableScheduling讓注解@Scheduled生效。

@SpringBootApplication
@EnableScheduling
@Slf4j
public class Chapter22Application {
 
    public static void main(String[] args) {
        SpringApplication.run(Chapter22Application.class, args);
        log.info("Chapter22啟動(dòng)!");
    }
}

1.編寫(xiě)一個(gè)調(diào)度類(lèi)悴能，系統(tǒng)啟動(dòng)后自動(dòng)掃描揣钦，自動(dòng)執(zhí)行。

@Component
@Slf4j
public class ScheduledTask {
 
    /**
     * 自動(dòng)掃描搜骡，啟動(dòng)時(shí)間點(diǎn)之后5秒執(zhí)行一次
     */
    @Scheduled(fixedRate=5000)
    public void getCurrentDate() {
        log.info("Scheduled定時(shí)任務(wù)執(zhí)行：" + new Date());
    }
}

2.啟動(dòng)后拂盯，控制臺(tái)可就看見(jiàn)每5秒一次輸出了：

2018-08-18 22:23:09.735  INFO 13812 --- [pool-1-thread-1] c.l.l.s.c.controller.ScheduledTask       : Scheduled定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(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定時(shí)任務(wù)執(zhí)行：Sat Aug 18 22:23:29 CST 2018
......

使用都是簡(jiǎn)單的，現(xiàn)在我們來(lái)看看注解@Scheduled的參數(shù)意思：

1. fixedRate：定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)
2. fixedDelay：定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)记靡，與上面不同的是谈竿，改屬性可以配合initialDelay， 定義該任務(wù)延遲執(zhí)行時(shí)間摸吠。
3. cron：通過(guò)表達(dá)式來(lái)配置任務(wù)執(zhí)行時(shí)間

Cron表達(dá)式詳解

一個(gè)cron表達(dá)式有至少6個(gè)（也可能7個(gè)）有空格分隔的時(shí)間元素空凸。

依次順序如下表所示：

簡(jiǎn)單舉例：

• 0/1 * * * * ?：每秒執(zhí)行一次
• 0 0 2 1 * ? ： 表示在每月的1日的凌晨2點(diǎn)調(diào)整任務(wù)
• 0 0 10,14,16 ? ：每天上午10點(diǎn)寸痢，下午2點(diǎn)呀洲，4點(diǎn)
• 0 0 12 * * ? ： 每天中午12點(diǎn)觸發(fā)
• 0 15 10 ? * MON-FRI ： 周一至周五的上午10:15觸發(fā)

更多表達(dá)式，可訪問(wèn)：http://cron.qqe2.com/ 進(jìn)行在線表達(dá)式編寫(xiě)啼止。簡(jiǎn)單明了道逗。

在線表達(dá)式編輯器

自定義線程池

從控制臺(tái)輸出可以看見(jiàn)，多任務(wù)使用的是同一個(gè)線程献烦∽仪希可結(jié)合上章節(jié)的異步調(diào)用來(lái)實(shí)現(xiàn)不同任務(wù)使用不同的線程進(jìn)行任務(wù)執(zhí)行。

0.編寫(xiě)配置類(lèi),同時(shí)啟用@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-");
        // 線程池對(duì)拒絕任務(wù)（無(wú)線程可用）的處理策略巩那，目前只支持AbortPolicy吏夯、CallerRunsPolicy；默認(rèn)為后者
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //調(diào)度器shutdown被調(diào)用時(shí)等待當(dāng)前被調(diào)度的任務(wù)完成
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        //等待時(shí)長(zhǎng)
        taskExecutor.setAwaitTerminationSeconds(60);
        taskExecutor.initialize();
        return taskExecutor;
    }
}

1.調(diào)度類(lèi)上加入@Async即横。

@Component
@Slf4j
public class ScheduledTask {
 
    /**
     * 自動(dòng)掃描噪生，啟動(dòng)時(shí)間點(diǎn)之后5秒執(zhí)行一次
     */
    @Async("scheduledPoolTaskExecutor")
    @Scheduled(fixedRate=5000)
    public void getCurrentDate() {
        log.info("Scheduled定時(shí)任務(wù)執(zhí)行：" + new Date());
    }
}

再次啟動(dòng)程序，可看見(jiàn)控制臺(tái)輸出东囚，任務(wù)已經(jīng)是不同線程下執(zhí)行了：

2018-08-18 22:47:13.313  INFO 14212 --- [ong-Scheduled-1] c.l.l.s.c.controller.ScheduledTask       : Scheduled定時(shí)任務(wù)執(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啟動(dòng)!
2018-08-18 22:47:18.308  INFO 14212 --- [ong-Scheduled-2] c.l.l.s.c.controller.ScheduledTask       : Scheduled定時(shí)任務(wù)執(zhí)行：Sat Aug 18 22:47:18 CST 2018

動(dòng)態(tài)添加定時(shí)任務(wù)

使用注解的方式跺嗽，無(wú)法實(shí)現(xiàn)動(dòng)態(tài)的修改或者添加新的定時(shí)任務(wù)的，這個(gè)使用就需要使用編程的方式進(jìn)行任務(wù)的更新操作了页藻〗凹蓿可直接使用ThreadPoolTaskScheduler或者SchedulingConfigurer接口進(jìn)行自定義定時(shí)任務(wù)創(chuàng)建。

ThreadPoolTaskScheduler

ThreadPoolTaskScheduler 這個(gè)類(lèi)是在 org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler 這個(gè)包中惕橙。

ThreadPoolTaskScheduler 是 spring taskSchedule 接口的實(shí)現(xiàn)，可以用來(lái)做定時(shí)任務(wù)使用钉跷。

ThreadPoolTaskScheduler 四個(gè)版本定時(shí)任務(wù)方法：

• schedule(Runnable task, Date stateTime)：在指定時(shí)間執(zhí)行一次定時(shí)任務(wù)

• schedule(Runnable task, Trigger trigger)：動(dòng)態(tài)創(chuàng)建指定表達(dá)式cron的定時(shí)任務(wù)弥鹦，threadPoolTaskScheduler.schedule(() -> {}, triggerContext -> newCronTrigger("").nextExecutionTime(triggerContext));

• scheduleAtFixedRate：指定間隔時(shí)間執(zhí)行一次任務(wù)，間隔時(shí)間為前一次執(zhí)行開(kāi)始到下次任務(wù)開(kāi)始時(shí)間

• scheduleWithFixedDelay：指定間隔時(shí)間執(zhí)行一次任務(wù)，間隔時(shí)間為前一次任務(wù)完成到下一次開(kāi)始時(shí)間

• 1彬坏、創(chuàng)建一個(gè)ThreadPoolTaskScheduler類(lèi)

@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)用時(shí)等待當(dāng)前被調(diào)度的任務(wù)完成
    executor.setWaitForTasksToCompleteOnShutdown(true);
    //等待時(shí)長(zhǎng)
    executor.setAwaitTerminationSeconds(60);
    return executor;
}

• 2朦促、編寫(xiě)一個(gè)控制類(lèi)，動(dòng)態(tài)設(shè)置定時(shí)任務(wù)：

@Autowired
TaskScheduler taskScheduler;
 
@GetMapping("/poolTask")
public String threadPoolTaskScheduler() {
 
    taskScheduler.schedule(new Runnable() {
         
        @Override
        public void run() {
            log.info("ThreadPoolTaskScheduler定時(shí)任務(wù)：" + new Date());
        }
    }, new CronTrigger("0/3 * * * * ?"));//每3秒執(zhí)行一次
    return "ThreadPoolTaskScheduler!";
}

• 3栓始、編寫(xiě)一個(gè)控制類(lèi)务冕，延時(shí)執(zhí)行任務(wù)：

@Autowired
TaskScheduler taskScheduler;
 
@GetMapping("/poolTask")
public String threadPoolTaskScheduler() {
    
    //延時(shí)一秒執(zhí)行
    Date executionTime = Date.from(LocalDateTime.now().plusSeconds(1).atZone(ZoneId.systemDefault()).toInstant());
    taskScheduler.schedule(() -> {
        
        log.info("ThreadPoolTaskScheduler定時(shí)任務(wù)：" + new Date());
        
    }, executionTime);//延時(shí)一秒執(zhí)行
    
    return "ThreadPoolTaskScheduler!";
}   

• 4、啟動(dòng)后幻赚，訪問(wèn)接口禀忆，即可看見(jiàn)控制臺(tái)每3秒輸出一次：

2018-08-18 23:20:39.002  INFO 9120 --- [Kong-Executor-1] c.l.l.s.c.controller.TaskController      : ThreadPoolTaskScheduler定時(shí)任務(wù)：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定時(shí)任務(wù)：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定時(shí)任務(wù)：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定時(shí)任務(wù)：Sat Aug 18 23:20:48 CST 2018

SchedulingConfigurer

此類(lèi)十個(gè)接口，直接實(shí)現(xiàn)其configurerTasks方法即可落恼。

0.編寫(xiě)配置類(lèi)：

@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定時(shí)任務(wù)：" + 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)用時(shí)等待當(dāng)前被調(diào)度的任務(wù)完成
        executor.setWaitForTasksToCompleteOnShutdown(true);
        //等待時(shí)長(zhǎng)
        executor.setAwaitTerminationSeconds(60);
        return executor;
    }
 
}

1.啟動(dòng)后箩退，控制臺(tái)也可以看見(jiàn)每3秒輸出一次：

2018-08-18 23:24:39.001  INFO 868 --- [Kong-Executor-1] c.l.l.s.chapter22.config.ScheduleConfig  : SchedulingConfigurer定時(shí)任務(wù)：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定時(shí)任務(wù)：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定時(shí)任務(wù)：Sat Aug 18 23:24:45 CST 2018

基于Quartz實(shí)現(xiàn)定時(shí)調(diào)度

由于本章節(jié)是基于SpringBoot 1.x版本的，所以沒(méi)有基于Quartz的starter配置佳谦，這里直接引入了Quartz相關(guān)依賴(lài)包來(lái)集成戴涝。

題外話：原本使用SpringMvc時(shí)，一般上都是通過(guò)xml文件钻蔑，配置其org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean類(lèi)進(jìn)行具體執(zhí)行任務(wù)的配置啥刻，指定執(zhí)行的對(duì)象和方法。然后通過(guò)設(shè)置CronTriggerFactoryBean或者SimpleTriggerFactoryBean設(shè)置定時(shí)器咪笑，最后通過(guò)org.springframework.scheduling.quartz.SchedulerFactoryBean加入調(diào)度的trigger可帽。所以，我們就使用javaConfig方式進(jìn)行簡(jiǎn)單集成下蒲肋。

0.加入pom依賴(lài)

<!-- 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>
<!-- 因?yàn)镾chedulerFactoryBean中依賴(lài)了org.springframework.transaction.PlatformTransactionManager,所以需依賴(lài)tx相關(guān)包蘑拯，其實(shí)還是quartz有個(gè)分布式功能，是使用數(shù)據(jù)庫(kù)完成的兜粘。 -->
    <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
</dependency>

1.編寫(xiě)配置類(lèi)申窘。

@Configuration
@Slf4j
public class QuartzConfig {
     
    /**
     * 通過(guò)工廠類(lèi)，創(chuàng)建job實(shí)例
     * @return
     */
    @Bean
    public MethodInvokingJobDetailFactoryBean customJobDetailFactoryBean() {
         
        MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
        //設(shè)置執(zhí)行任務(wù)的bean
        jobDetail.setTargetBeanName("quartzTask");
        //設(shè)置具體執(zhí)行的方法
        jobDetail.setTargetMethod("quartzTask");
        //同步執(zhí)行孔轴，上一任務(wù)未執(zhí)行完剃法，下一任務(wù)等待
        //true 任務(wù)并發(fā)執(zhí)行
        //false 下一個(gè)任務(wù)必須等待上一任務(wù)完成
        jobDetail.setConcurrent(false);
        return jobDetail; 
    }
     
    /**
     * 通過(guò)工廠類(lèi)創(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)度工廠類(lèi),自動(dòng)注入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()]));
//        }
        //這里注意 對(duì)應(yīng)的trigger 不能為null 不然會(huì)異常的
        bean.setTriggers(triggers);
        return bean;
    } 
     
    @Component("quartzTask")
    public class QuartzTask {
       
        public void quartzTask() {
            log.info("Quartz定時(shí)任務(wù)：" + new Date());
        }
    }
}

2.啟動(dòng)后，可以看見(jiàn)控制臺(tái)以每3秒執(zhí)行一次輸出：

2018-08-18 23:42:03.019  INFO 772 --- [ryBean_Worker-2] c.l.l.s.chapter22.config.QuartzConfig    : Quartz定時(shí)任務(wù)：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定時(shí)任務(wù)：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定時(shí)任務(wù)：Sun Aug 18 23:42:09 CST 2018

關(guān)于Quartz的詳細(xì)用法路鹰，再次不表了贷洲。好久沒(méi)有使用過(guò)了。有機(jī)會(huì)再來(lái)詳細(xì)闡述吧晋柱。

分布式調(diào)度服務(wù)淺談

在單機(jī)模式下优构，定時(shí)任務(wù)是沒(méi)什么問(wèn)題的。但當(dāng)我們部署了多臺(tái)服務(wù)雁竞，同時(shí)又每臺(tái)服務(wù)又有定時(shí)任務(wù)時(shí)钦椭，若不進(jìn)行合理的控制在同一時(shí)間拧额，只有一個(gè)定時(shí)任務(wù)啟動(dòng)執(zhí)行，這時(shí)彪腔，定時(shí)執(zhí)行的結(jié)果就可能存在混亂和錯(cuò)誤了侥锦。

這里簡(jiǎn)單的說(shuō)說(shuō)相關(guān)的解決方案吧，一家之言德挣，希望大家能提出自己的見(jiàn)解恭垦，共同進(jìn)步！

• 剝離所有定時(shí)任務(wù)到一個(gè)工程：此方案是最簡(jiǎn)單的格嗅，在定時(shí)任務(wù)相對(duì)較小番挺，并發(fā)任務(wù)不多時(shí)，可以使用此方案吗浩。簡(jiǎn)單也容易維護(hù)建芙。當(dāng)定時(shí)任務(wù)牽扯的業(yè)務(wù)越來(lái)越多，越來(lái)越雜時(shí)懂扼，維護(hù)量就成本增加了禁荸，工程會(huì)越來(lái)越臃腫，此方案就不實(shí)用了阀湿。
• 利用Quartz集群方案：本身Quartz是支持通過(guò)數(shù)據(jù)庫(kù)實(shí)現(xiàn)集群的赶熟，以下是其集群架構(gòu)圖：

集群架構(gòu)圖

其實(shí)現(xiàn)原理也相對(duì)簡(jiǎn)單：通過(guò)數(shù)據(jù)庫(kù)實(shí)現(xiàn)任務(wù)的持久化，保存定時(shí)任務(wù)的相關(guān)配置信息陷嘴，以保證下次系統(tǒng)啟動(dòng)時(shí)映砖，定時(shí)任務(wù)能自動(dòng)啟動(dòng)。同時(shí)灾挨，通過(guò)數(shù)據(jù)庫(kù)行鎖(for update)機(jī)制邑退，控制一個(gè)任務(wù)只能被一個(gè)實(shí)例運(yùn)行，只有獲取鎖的實(shí)例才能運(yùn)行任務(wù)劳澄，其他的只能等待地技，直到鎖被釋放。這種方式有些弊端秒拔，就是依賴(lài)了數(shù)據(jù)庫(kù)莫矗，同時(shí)也需要保證各服務(wù)器之間的時(shí)間需要同步，不然也是會(huì)混亂的砂缩。

現(xiàn)在Quartz也有基于Redis的集群方案作谚，有興趣的可以搜索下。

• 分布式鎖：可通過(guò)使用Redis或者ZooKeeper實(shí)現(xiàn)一個(gè)分布式鎖的機(jī)制庵芭，使得只有獲取到鎖的實(shí)例方能運(yùn)行定時(shí)任務(wù)妹懒，避免任務(wù)重復(fù)執(zhí)行∷海可查看下開(kāi)源的基于Redis實(shí)現(xiàn)的分布式鎖項(xiàng)目：redisson眨唬。github地址：https://github.com/redisson/redisson有興趣的同學(xué)可以了解下滔悉。
• 統(tǒng)一調(diào)度中心：

可構(gòu)建一個(gè)純粹的定時(shí)服務(wù)，只有定時(shí)器相關(guān)配置单绑，比如定時(shí)時(shí)間，定時(shí)調(diào)度的api接口或者http服務(wù)曹宴，甚至是統(tǒng)一注冊(cè)中心下的服務(wù)類(lèi)搂橙，如dubbo服務(wù)等。而具體的任務(wù)執(zhí)行操作都在各自業(yè)務(wù)方系統(tǒng)中笛坦，調(diào)度中心只負(fù)責(zé)接口的調(diào)用区转，具體實(shí)現(xiàn)還是在業(yè)務(wù)方。這種方案相對(duì)來(lái)說(shuō)比較通用版扩，實(shí)現(xiàn)起來(lái)也簡(jiǎn)單废离。就是需要業(yè)務(wù)方進(jìn)行約定編程，或者對(duì)外提供一個(gè)api接口礁芦。

當(dāng)然蜻韭，為了實(shí)現(xiàn)定時(shí)任務(wù)的自動(dòng)發(fā)現(xiàn)和注冊(cè)功能，還是需要規(guī)范一套規(guī)則來(lái)實(shí)現(xiàn)自動(dòng)注冊(cè)功能柿扣。簡(jiǎn)單來(lái)說(shuō)肖方，以Dubbo服務(wù)為例，可以定義一個(gè)定時(shí)任務(wù)接口類(lèi)未状，調(diào)度中心只需要獲取所有實(shí)現(xiàn)此接口的服務(wù)俯画，同時(shí)通過(guò)服務(wù)的相關(guān)配置(調(diào)度時(shí)間、失敗策略等)進(jìn)行相關(guān)定時(shí)操作司草〖璐梗或者編寫(xiě)一個(gè)服務(wù)注冊(cè)與發(fā)現(xiàn)的客戶端，通過(guò)Spring獲取到實(shí)現(xiàn)此接口的所有實(shí)現(xiàn)類(lèi)埋虹，上送到調(diào)度中心猜憎。

而且，統(tǒng)一調(diào)度中心吨岭，還可以對(duì)所有的定時(shí)任務(wù)的調(diào)度情況進(jìn)行有效監(jiān)控拉宗，日志記錄等，也可以約定接口辣辫，讓定時(shí)任務(wù)回傳定時(shí)結(jié)果旦事，做到全局把控的目的。

以上就是對(duì)分布式調(diào)度的一點(diǎn)理解急灭，有錯(cuò)誤的地方還望指正姐浮，有更好的方案也希望能分享下。

參考資料

1. https://www.cnblogs.com/yank/p/3955322.html
2. https://blog.csdn.net/tsyj810883979/article/details/8481621
3. https://www.cnblogs.com/javahr/p/8318728.html
4. http://www.quartz-scheduler.org/documentation/quartz-2.1.x/quick-start.html
5. https://spring.io/guides/gs/scheduling-tasks/
6. http://www.importnew.com/29864.html

總結(jié)

本章節(jié)主要是講解了通過(guò)不同的方式實(shí)現(xiàn)定時(shí)任務(wù)葬馋。對(duì)于定時(shí)任務(wù)而言卖鲤，本身是門(mén)大學(xué)問(wèn)肾扰，一倆篇文章是講不完的。像SpringTask和Quartz都是很強(qiáng)大的調(diào)度器蛋逾，兩者很相似集晚，像如何實(shí)現(xiàn)任務(wù)的動(dòng)態(tài)修改調(diào)度周期，動(dòng)態(tài)停止相關(guān)任務(wù)区匣，調(diào)度任務(wù)的監(jiān)控偷拔，這些本文章都沒(méi)有涉及。還希望有相關(guān)需求的同學(xué)自行搜索相關(guān)資料了亏钩。

最后

目前互聯(lián)網(wǎng)上很多大佬都有SpringBoot系列教程莲绰，如有雷同，請(qǐng)多多包涵了姑丑。本文是作者在電腦前一字一句敲的蛤签，每一步都是自己實(shí)踐的。若文中有所錯(cuò)誤之處栅哀，還望提出震肮，謝謝。

參考：
https://blog.csdn.net/qq_18948359/article/details/125499389