剛剛看了下Spring Boot實(shí)現(xiàn)定時(shí)任務(wù)的文章，感覺(jué)還不錯(cuò)。Spring Boot 使用Spring自帶的Schedule來(lái)實(shí)現(xiàn)定時(shí)任務(wù)變得非常簡(jiǎn)單和方便。在這里個(gè)大家分享下。

開(kāi)啟緩存注解

@SpringBootApplication
@EnableScheduling //開(kāi)啟定時(shí)任務(wù)
public class Application {
  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}

編寫(xiě)定時(shí)任務(wù)

@Component
public class ScheduledTasks {
  private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);
  // cron接受cron表達(dá)式，根據(jù)cron表達(dá)式確定定時(shí)規(guī)則
  @Scheduled(cron="0/5 * * * * ? ")  //每5秒執(zhí)行一次 
  public void testCron() {
  DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
   logger.info(sdf.format(new Date())+"*********每5秒執(zhí)行一次");
  }
}

任務(wù)完成

啟動(dòng)項(xiàng)目，查看控制臺(tái)打印信息,發(fā)現(xiàn)定時(shí)任務(wù)已經(jīng)生效。spring boot 和Scheduled整合完畢。

存在問(wèn)題

但是后來(lái)發(fā)現(xiàn)個(gè)問(wèn)題，通過(guò)同時(shí)測(cè)試幾個(gè)任務(wù)發(fā)現(xiàn)，所有的任務(wù)都是在同一個(gè)線程池中的同一個(gè)線程來(lái)完成的。在實(shí)際開(kāi)發(fā)過(guò)程中，我們當(dāng)然不希望所有的任務(wù)都運(yùn)行在一個(gè)線程中。

@Scheduled(cron="0/1 * * * * ? ")  //每1秒執(zhí)行一次 
public void testCron1() {
  DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
  logger.info(sdf.format(new Date())+"*********每1秒執(zhí)行一次");
}
@Scheduled(cron="0/2 * * * * ? ")  //每2秒執(zhí)行一次 
public void testCron2() {
  DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
  logger.info(sdf.format(new Date())+"*********每2秒執(zhí)行一次");
}
@Scheduled(cron="0/3 * * * * ? ")  //每3秒執(zhí)行一次 
public void testCron3() {
  DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
  logger.info(sdf.format(new Date())+"*********每3秒執(zhí)行一次");
}
@Scheduled(cron="0/4 * * * * ? ")  //每4秒執(zhí)行一次 
public void testCron4() {
  DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
  logger.info(sdf.format(new Date())+"*********每4秒執(zhí)行一次");
}

解決方案

那么，怎么設(shè)計(jì)成多線程實(shí)現(xiàn)并發(fā)呢？在網(wǎng)上看到過(guò)這樣的解決方案。通過(guò)ScheduleConfig配置文件實(shí)現(xiàn)SchedulingConfigurer接口，并重寫(xiě)setSchedulerfang方法，我們嘗試著配置了一下。

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
 @Override
 public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
   taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
 }
}

整合成功

這樣就完成了多線程并發(fā)的配置？我們啟動(dòng)項(xiàng)目通過(guò)控制臺(tái)輸出信息驗(yàn)證一下結(jié)果，最后發(fā)現(xiàn)所有的任務(wù)都在同一個(gè)線程池但不同線程中完成，說(shuō)明這個(gè)方案完全可行，這樣，我們就完成了spring boot 多線程并發(fā)定時(shí)任務(wù)。

注

@Scheduled所支持的參數(shù)：

1.cron：cron表達(dá)式，指定任務(wù)在特定時(shí)間執(zhí)行； 2.fixedDelay：表示上一次任務(wù)執(zhí)行完成后多久再次執(zhí)行，參數(shù)類(lèi)型為long，單位ms； 3.fixedDelayString：與fixedDelay含義一樣，只是參數(shù)類(lèi)型變?yōu)镾tring； 4.fixedRate：表示按一定的頻率執(zhí)行任務(wù)，參數(shù)類(lèi)型為long，單位ms； 5.fixedRateString: 與fixedRate的含義一樣，只是將參數(shù)類(lèi)型變?yōu)镾tring； 6.initialDelay：表示延遲多久再第一次執(zhí)行任務(wù)，參數(shù)類(lèi)型為long，單位ms； 7.initialDelayString：與initialDelay的含義一樣，只是將參數(shù)類(lèi)型變?yōu)镾tring； 8.zone：時(shí)區(qū)，默認(rèn)為當(dāng)前時(shí)區(qū)，一般沒(méi)有用到。

Cron表達(dá)式范例：

每隔5秒執(zhí)行一次：*/5 * * * * ? 每隔1分鐘執(zhí)行一次：0 */1 * * * ? 每天23點(diǎn)執(zhí)行一次：0 0 23 * * ? 每天凌晨1點(diǎn)執(zhí)行一次：0 0 1 * * ? 每月1號(hào)凌晨1點(diǎn)執(zhí)行一次：0 0 1 1 * ? 每月最后一天23點(diǎn)執(zhí)行一次：0 0 23 L * ? 每周星期天凌晨1點(diǎn)實(shí)行一次：0 0 1 ? * L 在26分、29分、33分執(zhí)行一次：0 26,29,33 * * * ? 每天的0點(diǎn)、13點(diǎn)、18點(diǎn)、21點(diǎn)都執(zhí)行一次：0 0 0,13,18,21 * * ?

其實(shí)不會(huì)Cron表達(dá)式也不用擔(dān)心，網(wǎng)上有好多在線Cron生成器，我們完全可以通過(guò)在線生成器生成符合要求的cron，也很方便。

總結(jié)

以上所述是小編給大家介紹的spring-boot 多線程并發(fā)定時(shí)任務(wù)的解決方案 ,希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
如果你覺(jué)得本文對(duì)你有幫助，歡迎轉(zhuǎn)載，煩請(qǐng)注明出處，謝謝！

最新評(píng)論