工程程式碼示例   : Spring Boot整合持久化Quartz定時任務管理和介面展示

工程地址  : https://github.com/tjfy1992/SpringBootQuartz

執行方法
Spring Boot工程已經集成了伺服器。右鍵點選DemoApplication.java -> Run As -> Java Application即可執行工程。預設埠為8080，啟動後在瀏覽器位址列輸入http://localhost:8080/JobManager.html就可以看到效果。

SpringBoot併發執行定時任務

開啟快取註解

@SpringBootApplication

@EnableScheduling //開啟定時任務

public class Application {

           public static void main(String[] args) {

                     SpringApplication.run(Application.class, args);

           }

}

存在問題

發現個問題，通過同時測試幾個任務發現，所有的任務都是在同一個執行緒池中的同一個執行緒來完成的。在實際開發過程中，我們當然不希望所有的任務都執行在一個執行緒中。

@Scheduled(cron="0/1 * * * * ? ") //每1秒執行一次

public void testCron1() {

          DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

          logger.info(sdf.format(new Date())+"*********每1秒執行一次");

}

@Scheduled(cron="0/2 * * * * ? ") //每2秒執行一次

public void testCron2() {

          DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

          logger.info(sdf.format(new Date())+"*********每2秒執行一次");

}

@Scheduled(cron="0/3 * * * * ? ") //每3秒執行一次

public void testCron3() {

          DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

          logger.info(sdf.format(new Date())+"*********每3秒執行一次");

}

@Scheduled(cron="0/4 * * * * ? ") //每4秒執行一次

public void testCron4() {

          DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

          logger.info(sdf.format(new Date())+"*********每4秒執行一次");

}

解決方案

那麼，怎麼設計成多執行緒實現併發呢？在網上看到過這樣的解決方案。通過ScheduleConfig配置檔案實現SchedulingConfigurer介面，並重寫setSchedulerfang方法，我們嘗試著配置了一下。

@Configuration

public class ScheduleConfig implements SchedulingConfigurer {

          @Override

          public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

                      taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));

          }

}

整合成功

這樣就完成了多執行緒併發的配置？我們啟動專案通過控制檯輸出資訊驗證一下結果，最後發現所有的任務都在同一個執行緒池但不同執行緒中完成，說明這個方案完全可行，這樣，我們就完成了spring boot 多執行緒併發定時任務。

注

@Scheduled所支援的引數：

1.cron：cron表示式，指定任務在特定時間執行；
2.fixedDelay：表示上一次任務執行完成後多久再次執行，引數型別為long，單位ms；
3.fixedDelayString：與fixedDelay含義一樣，只是引數型別變為String；
4.fixedRate：表示按一定的頻率執行任務，引數型別為long，單位ms；
5.fixedRateString: 與fixedRate的含義一樣，只是將引數型別變為String；
6.initialDelay：表示延遲多久再第一次執行任務，引數型別為long，單位ms；
7.initialDelayString：與initialDelay的含義一樣，只是將引數型別變為String；
8.zone：時區，預設為當前時區，一般沒有用到。

Cron表示式範例：

每隔5秒執行一次：*/5 * * * * ?
每隔1分鐘執行一次：0 */1 * * * ?
每天23點執行一次：0 0 23 * * ?
每天凌晨1點執行一次：0 0 1 * * ?
每月1號凌晨1點執行一次：0 0 1 1 * ?
每月最後一天23點執行一次：0 0 23 L * ?
每週星期天凌晨1點實行一次：0 0 1 ? * L
在26分、29分、33分執行一次：0 26,29,33 * * * ?
每天的0點、13點、18點、21點都執行一次：0 0 0,13,18,21 * * ?

其實不會Cron表示式也不用擔心，網上有好多線上Cron生成器，我們完全可以通過線上生成器生成符合要求的cron，也很方便。