单体应用spring Task和分布式调度
Spring Task
1.通过 Spring Task，您可以方便地在 Java 应用程序中实现定时任务，比如每天凌晨进行数据同步、每小时执行一次清理操作等。
2.1
启动类添加@EnableScheduling注解(默认情况下，系统会自动启动一个线程)
2.2
在需要定时执行的方法上添加@Scheduled注解即可。定时执行的方法不能有参数，并且一般没有返回值，即使有返回值也没什么用。注意定时任务所在的类要作为 Spring Bean，在类上添加@Component注解即可。也就是说定时方法所在的类，你要放到IOC容器里面
@Component
@Slf4j //用来查看日志,日志上面精确显示到秒.这需要在properties中加logging....
@EnableAsync //开启多个线程
public class ScheduledTask {int i =1;@Scheduled(fixedRate = 3000)public void task1(){log.debug("task1->{},{}",i++,Thread.currentThread().getId());}@Scheduled(cron = "*/5 * * * * ?")@Async("asyncScheduledPool") //配置类中线程类的类名public void task2(){log.debug("task2->{},{}",Thread.currentThread().getId());}
}
2.3多线程（异步）定时任务
@Component
public class ExecutorConfig {//定义核心线程数public static final int CORE_POOL_SIZE = 5;//定义最大线程数public static final int MAX_POOL_SIZE = 10;//定义线程活跃时间public static final int KEEP_ALIVE_TIME = 2000;//定义线程队列public static final int BLOCKING_QUEUE_SIZE = 100;
// @Bean("asyncScheduledPool")public Executor asyncScheduledPool(){//自定义线程池ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();threadPoolTaskExecutor.setCorePoolSize(CORE_POOL_SIZE);threadPoolTaskExecutor.setMaxPoolSize(MAX_POOL_SIZE);threadPoolTaskExecutor.setKeepAliveSeconds(KEEP_ALIVE_TIME);threadPoolTaskExecutor.setQueueCapacity(BLOCKING_QUEUE_SIZE);threadPoolTaskExecutor.setThreadNamePrefix("async-scheduled-pool-");//设置拒绝策略threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());return threadPoolTaskExecutor;}}
logging.root.level=error
logging.level.com.example=debug
开启异步支持
这个Enable...其实写在哪个类中都行
Api说明
fixedDelay ：上次结束到下次开始执行时间间隔：
@Scheduled(fixedDelay = 4000)
fixedRate：上一次开始执行时间和下次开始时间间隔10s。如：
@Scheduled(fixedRate = 10000)
initialDelay：第一次延迟多长时间后再执行。
@Scheduled(initialDelay=1000, fixedRate=5000) //第一次延迟1秒后执行，之后按fixedRate的规则每5秒执行一次
cron（掌握）
@Scheduled(cron = "*/5 * * * * ?")
在线Cron表达式生成器