剛剛看了下Spring Boot實現(xiàn)定時任務(wù)的文章,感覺還不錯奉瘤。Spring Boot 使用Spring自帶的Schedule來實現(xiàn)定時任務(wù)變得非常簡單和方便。在這里個大家分享下吕朵。
開啟緩存注解
@SpringBootApplication
@EnableScheduling //開啟定時任務(wù)
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
編寫定時任務(wù)
@Component
public class ScheduledTasks {
private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);
// cron接受cron表達(dá)式嗅榕,根據(jù)cron表達(dá)式確定定時規(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ù)完成
啟動項目,查看控制臺打印信息,發(fā)現(xiàn)定時任務(wù)已經(jīng)生效火焰。spring boot 和Scheduled整合完畢劲装。
存在問題
但是后來發(fā)現(xiàn)個問題,通過同時測試幾個任務(wù)發(fā)現(xiàn)荐健,所有的任務(wù)都是在同一個線程池中的同一個線程來完成的酱畅。在實際開發(fā)過程中,我們當(dāng)然不希望所有的任務(wù)都運行在一個線程中江场。
@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è)計成多線程實現(xiàn)并發(fā)呢?在網(wǎng)上看到過這樣的解決方案址否。通過ScheduleConfig配置文件實現(xiàn)SchedulingConfigurer接口餐蔬,并重寫setSchedulerfang方法,我們嘗試著配置了一下佑附。
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
}
}
整合成功
這樣就完成了多線程并發(fā)的配置樊诺?我們啟動項目通過控制臺輸出信息驗證一下結(jié)果,最后發(fā)現(xiàn)所有的任務(wù)都在同一個線程池但不同線程中完成音同,說明這個方案完全可行词爬,這樣,我們就完成了spring boot 多線程并發(fā)定時任務(wù)权均。
注
@Scheduled所支持的參數(shù):
1.cron:cron表達(dá)式顿膨,指定任務(wù)在特定時間執(zhí)行;
2.fixedDelay:表示上一次任務(wù)執(zhí)行完成后多久再次執(zhí)行叽赊,參數(shù)類型為long恋沃,單位ms;
3.fixedDelayString:與fixedDelay含義一樣必指,只是參數(shù)類型變?yōu)镾tring囊咏;
4.fixedRate:表示按一定的頻率執(zhí)行任務(wù),參數(shù)類型為long塔橡,單位ms梅割;
5.fixedRateString: 與fixedRate的含義一樣,只是將參數(shù)類型變?yōu)镾tring葛家;
6.initialDelay:表示延遲多久再第一次執(zhí)行任務(wù)炮捧,參數(shù)類型為long,單位ms惦银;
7.initialDelayString:與initialDelay的含義一樣,只是將參數(shù)類型變?yōu)镾tring;
8.zone:時區(qū)扯俱,默認(rèn)為當(dāng)前時區(qū)书蚪,一般沒有用到。
Cron表達(dá)式范例:
每隔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表達(dá)式也不用擔(dān)心,網(wǎng)上有好多在線Cron生成器让簿,我們完全可以通過在線生成器生成符合要求的cron敬察,也很方便。