Springboot集成定时调度

 1 package com.demo.cron;
 2 
 3 import java.text.SimpleDateFormat;
 4 import java.util.Date;
 5 
 6 import org.springframework.scheduling.annotation.Scheduled;
 7 import org.springframework.stereotype.Component;
 8 
 9 /**
10  * 
11  * @author
12  *
13  */
14 @Component
15 public class CronSchedulerTask {
16 
17     /**
18      * 定义一个要执行的任务
19      */
20     @Scheduled(fixedRate = 2000) // 采用间隔调度，每隔2秒执行一次
21     public void runJobA() {
22         System.err.println("【*** runJobA ***】 " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()));
23     }
24 
25     /**
26      * 定义一个要执行的任务
27      */
28     @Scheduled(cron = "* * * * * ?") // 采用间隔调度，每隔1秒执行一次
29     public void runJobB() {
30         System.err.println("【*** runJobB ***】 " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()));
31     }
32 
33 }

 1 package com.demo.config;
 2 
 3 import java.util.concurrent.Executors;
 4 
 5 import org.springframework.context.annotation.Configuration;
 6 import org.springframework.scheduling.annotation.SchedulingConfigurer;
 7 import org.springframework.scheduling.config.ScheduledTaskRegistrar;
 8 
 9 /**
10  * 定时调度的配置类一定要实现指定的父接口
11  * 
12  * @author
13  *
14  */
15 @Configuration
16 public class SchedulerConfig implements SchedulingConfigurer {
17 
18     /**
19      * 开启线程调度池
20      */
21     @Override
22     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
23         // 10个线程池
24         taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
25     }
26 
27 }

 1 package com.demo;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 6 import org.springframework.scheduling.annotation.EnableScheduling;
 7 import org.springframework.transaction.annotation.EnableTransactionManagement;
 8 
 9 @SpringBootApplication // 启动Springboot程序，而后自带子包扫描
10 @EnableScheduling // 启动调度
11 public class DemoApplication {
12 
13     public static void main(String[] args) {
14         // 启动Springboot程序
15         SpringApplication.run(DemoApplication.class, args);
16     }
17 
18 }