SpringBoot中如何使用Quartz Schedule

不念不忘少年蓝@ 2021-06-12 14:36 461阅读 0赞

1.首先需要引入Quartz的依赖。

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-quartz</artifactId>
    </dependency>

2.创建Job类并继承QuartzJobBean，重写executeInternal()方法，该方法用来执行具体的Job任务。

public class WeatherDataSyncJob extends QuartzJobBean {
    
        private final static Logger logger=LoggerFactory.getLogger(WeatherDataSyncJob.class);
    
        @Autowired
        private CityDataService cityDataService;
        @Autowired
        private WeatherDataService weatherDataService;
    
        @Override
        protected void executeInternal(JobExecutionContext jobExecutionContext) {//执行的动作
            logger.info("Weather data Sync Job start");
            //获取城市ID列表
            List<City> cityList=null;
            try {
                cityList=cityDataService.listCity();
            } catch (Exception e) {
                logger.error("Exception", e);
            }
    
            //遍历城市ID获取天气
            for(City city:cityList){
                String cityId=city.getCityId();
                logger.info("Weather Data sync job ,cityId:{}",cityId);
                weatherDataService.syncDataByCityId(cityId);
            }
            logger.info("Weather data Sync Job end");
        }
    }

3.创建Quartz的配置类，在配置类中创建JobDetail对象，然后创建Trigger对象来执行JobDetail中的Job，并且可通过SimpleScheduleBuilder对象来配置定时任务的一些参数。  
在下述配置中，Job被设置为每隔半个小时执行一次，每执行一次就会调用一次executeInternal()方法。

@Configuration
    public class QuartzConfiguration {
    
        private static final int TIME=1800;//更新频率
    
        //创建JobDetail
        @Bean
        public JobDetail weatherDataSyncJobDetail(){
            return JobBuilder.newJob(WeatherDataSyncJob.class)
                    .withIdentity("weatherDataSyncJob")//定义JobDetail的名称
                    .storeDurably().build();
        }
        //创建trigger，执行JobDetail
        @Bean
        public Trigger weatherDataSyncTrigger(){
            //每隔1800秒重复执行
            SimpleScheduleBuilder schedBuilder=SimpleScheduleBuilder.simpleSchedule()
                    .withIntervalInSeconds(TIME).repeatForever();
    
            return TriggerBuilder.newTrigger().forJob(weatherDataSyncJobDetail())
                    .withIdentity("weatherDataSyncTrigger")//定义trigger的名称
                    .withSchedule(schedBuilder).build();
        }
    }