详解SpringBoot Schedule配置
1.定时任务实现方式
定时任务实现方式:
- Java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务。使用这种方式可以让你的程序按照某一个频度执行,但不能在指定时间运行。一般用的较少,这篇文章将不做详细介绍。
- 使用Quartz,这是一个功能比较强大的的调度器,可以让你的程序在指定时间执行,也可以按照某一个频度执行,配置起来稍显复杂,有空介绍。
- SpringBoot自带的Scheduled,可以将它看成一个轻量级的Quartz,而且使用起来比Quartz简单许多,本文主要介绍。
定时任务执行方式:
- 单线程(串行)
- 多线程(并行)
2.创建定时任务
packagecom.autonavi.task.test; importorg.slf4j.Logger; importorg.slf4j.LoggerFactory; importorg.springframework.scheduling.annotation.Scheduled; importorg.springframework.stereotype.Component; importcom.autonavi.task.ScheduledTasks; @Component publicclassScheduledTest{ privatestaticfinalLoggerlogger=LoggerFactory.getLogger(ScheduledTasks.class); @Scheduled(cron="00/2***?") publicvoidexecuteFileDownLoadTask(){ //间隔2分钟,执行任务 Threadcurrent=Thread.currentThread(); System.out.println("定时任务1:"+current.getId()); logger.info("ScheduledTest.executeFileDownLoadTask定时任务1:"+current.getId()+",name:"+current.getName()); } }
@Scheduled注解用于标注这个方法是一个定时任务的方法,有多种配置可选。cron支持cron表达式,指定任务在特定时间执行;fixedRate以特定频率执行任务;fixedRateString以string的形式配置执行频率。
3.启动定时任务
@SpringBootApplication @EnableScheduling publicclassApp{ privatestaticfinalLoggerlogger=LoggerFactory.getLogger(App.class); publicstaticvoidmain(String[]args){ SpringApplication.run(App.class,args); logger.info("start"); } }
其中@EnableScheduling注解的作用是发现注解@Scheduled的任务并后台执行。
Springboot本身默认的执行方式是串行执行,也就是说无论有多少task,都是一个线程串行执行,并行需手动配置
4.并行任务
继承SchedulingConfigurer类并重写其方法即可,如下:
@Configuration @EnableScheduling publicclassScheduleConfigimplementsSchedulingConfigurer{ @Override publicvoidconfigureTasks(ScheduledTaskRegistrartaskRegistrar){ taskRegistrar.setScheduler(taskExecutor()); } @Bean(destroyMethod="shutdown") publicExecutortaskExecutor(){ returnExecutors.newScheduledThreadPool(100); } }
再次执行之前的那个Demo,会欣然发现已经是并行执行了!
5.异步并行任务
importorg.springframework.scheduling.TaskScheduler; importorg.springframework.scheduling.annotation.AsyncConfigurer; importorg.springframework.scheduling.annotation.EnableAsync; importorg.springframework.scheduling.annotation.EnableScheduling; importorg.springframework.scheduling.annotation.SchedulingConfigurer; importorg.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; importorg.springframework.scheduling.config.ScheduledTaskRegistrar; @Configuration @EnableScheduling @EnableAsync( mode=AdviceMode.PROXY,proxyTargetClass=false, order=Ordered.HIGHEST_PRECEDENCE ) @ComponentScan( basePackages="hello" ) publicclassRootContextConfigurationimplements AsyncConfigurer,SchedulingConfigurer{ @Bean publicThreadPoolTaskSchedulertaskScheduler() { ThreadPoolTaskSchedulerscheduler=newThreadPoolTaskScheduler(); scheduler.setPoolSize(20); scheduler.setThreadNamePrefix("task-"); scheduler.setAwaitTerminationSeconds(60); scheduler.setWaitForTasksToCompleteOnShutdown(true); returnscheduler; } @Override publicExecutorgetAsyncExecutor() { Executorexecutor=this.taskScheduler(); returnexecutor; } @Override publicvoidconfigureTasks(ScheduledTaskRegistrarregistrar) { TaskSchedulerscheduler=this.taskScheduler(); registrar.setTaskScheduler(scheduler); } }
在启动的main方法加入额外配置:
@SpringBootApplication publicclassApplication{ publicstaticvoidmain(String[]args)throwsException{ AnnotationConfigApplicationContextrootContext= newAnnotationConfigApplicationContext(); rootContext.register(RootContextConfiguration.class); rootContext.refresh(); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。