剛剛看了下Spring Boot實現(xiàn)定時任務的文章,感覺還不錯。Spring Boot 使用Spring自帶的Schedule來實現(xiàn)定時任務變得非常簡單和方便。在這里個大家分享下。
在曲陽等地區(qū),都構建了全面的區(qū)域性戰(zhàn)略布局,加強發(fā)展的系統(tǒng)性、市場前瞻性、產品創(chuàng)新能力,以專注、極致的服務理念,為客戶提供網站建設、網站設計 網站設計制作按需開發(fā)網站,公司網站建設,企業(yè)網站建設,成都品牌網站建設,成都全網營銷,成都外貿網站制作,曲陽網站建設費用合理。
開啟緩存注解
@SpringBootApplication @EnableScheduling //開啟定時任務 public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
編寫定時任務
@Component public class ScheduledTasks { private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class); // cron接受cron表達式,根據(jù)cron表達式確定定時規(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í)行一次"); } }
任務完成
啟動項目,查看控制臺打印信息,發(fā)現(xiàn)定時任務已經生效。spring boot 和Scheduled整合完畢。
存在問題
但是后來發(fā)現(xiàn)個問題,通過同時測試幾個任務發(fā)現(xiàn),所有的任務都是在同一個線程池中的同一個線程來完成的。在實際開發(fā)過程中,我們當然不希望所有的任務都運行在一個線程中。
@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í)行一次"); }
解決方案
那么,怎么設計成多線程實現(xiàn)并發(fā)呢?在網上看到過這樣的解決方案。通過ScheduleConfig配置文件實現(xiàn)SchedulingConfigurer接口,并重寫setSchedulerfang方法,我們嘗試著配置了一下。
@Configuration public class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5)); } }
整合成功
這樣就完成了多線程并發(fā)的配置?我們啟動項目通過控制臺輸出信息驗證一下結果,最后發(fā)現(xiàn)所有的任務都在同一個線程池但不同線程中完成,說明這個方案完全可行,這樣,我們就完成了spring boot 多線程并發(fā)定時任務。
注
@Scheduled所支持的參數(shù):
1.cron:cron表達式,指定任務在特定時間執(zhí)行; 2.fixedDelay:表示上一次任務執(zhí)行完成后多久再次執(zhí)行,參數(shù)類型為long,單位ms; 3.fixedDelayString:與fixedDelay含義一樣,只是參數(shù)類型變?yōu)镾tring; 4.fixedRate:表示按一定的頻率執(zhí)行任務,參數(shù)類型為long,單位ms; 5.fixedRateString: 與fixedRate的含義一樣,只是將參數(shù)類型變?yōu)镾tring; 6.initialDelay:表示延遲多久再第一次執(zhí)行任務,參數(shù)類型為long,單位ms; 7.initialDelayString:與initialDelay的含義一樣,只是將參數(shù)類型變?yōu)镾tring; 8.zone:時區(qū),默認為當前時區(qū),一般沒有用到。
Cron表達式范例:
每隔5秒執(zhí)行一次:*/5 * * * * ? 每隔1分鐘執(zhí)行一次:0 */1 * * * ? 每天23點執(zhí)行一次:0 0 23 * * ? 每天凌晨1點執(zhí)行一次:0 0 1 * * ? 每月1號凌晨1點執(zhí)行一次:0 0 1 1 * ? 每月最后一天23點執(zhí)行一次:0 0 23 L * ? 每周星期天凌晨1點實行一次:0 0 1 ? * L 在26分、29分、33分執(zhí)行一次:0 26,29,33 * * * ? 每天的0點、13點、18點、21點都執(zhí)行一次:0 0 0,13,18,21 * * ?
其實不會Cron表達式也不用擔心,網上有好多在線Cron生成器,我們完全可以通過在線生成器生成符合要求的cron,也很方便。
總結
以上所述是小編給大家介紹的spring-boot 多線程并發(fā)定時任務的解決方案 ,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對創(chuàng)新互聯(lián)網站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!