一、Quartz
Quartz是一个完全由java编写的开源作业调度框架。
job - 任务- 你要做什么事？
Trigger - 触发器- 你什么时候去做？
Scheduler - 任务调度- 你什么时候需要去做什么事？
maven中添加相关依赖：
1 <dependency>
2 <groupId>org.quartz-scheduler</groupId>
3 <artifactId>quartz</artifactId>
4 </dependency>
创建Job类
1 public class QuartzJob implements Job {
2 public void execute(JobExecutionContext arg) throws JobExecutionException {
3 System.out.println("执行定时任务");
4 }
5 }
测试quartz
1 public static void main(String[] args) thwors Exception {
2 JobDetail jobDetail = JobBuilder.newJob(QuartzJob.class).build();
3 Trigger trigger = TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"));
4 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
5 scheduler.setScheduleJob(job, trigger);
6 scheduler.start();
7 }
二、SpringBoot整合Quartz
添加maven依赖
1 <dependency>
2 <groupId>org.quartz-scheduler</groupId>
3 <artifactId>quartz</artifactId>
4 <exclusions>
5 <exclusion>
6 <groupId>org.slf4j</groupId>
7 <artifactId>slf4j-api</artifactId>
8 </exclusion>
9 </exclusions>
10 </dependency>
11 <dependency>
12 <groupId>org.springframework</groupId>
13 <artifactId>spring-context-support</artifactId>
14 </dependency>
15 <dependency>
16 <groupId>org.springframework</groupId>
17 <artifactId>spring-tx</artifactId>
18 </dependency>
启动类开启定时任务
1 @SpringBootApplication
2 @EnableScheduling
3 public class App {
4 public static void main(String[] args) {
5 SpringAppliction.run(App.class, args);
6 }
7 }
编写一个适配器任务工厂，将实例化的任务手动添加到SpringIOC容器中完成对象的注入。
1 @Component("myAdaptableJobFactory")
2 public class MyAdaptableJobFactory extends AdaptableJobFactory {
3 @Autowired
4 private AutowireCapableBeanFactory autowireCapableBeanFactory;
5 protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
6 Object object = super.createJobInstance(bundle);
7 this.autowireCapableBeanFactory.autowireBean(object);
8 return object;
9 }
10 }
编写QuartzConfig
1 @Configuration
2 public class QuartzConfig {
3 //创建Job对象
4 @Bean
5 public JobDetailFactoryBean jobDetailFactoryBean() {
6 JobDetailFactoryBean factory = new JobDetailFactoryBean();
7 factory.setJobClass(QuartzJob.class);
8 return factory;
9 }
10 //创建Trigger对象
11 @Bean
12 public CronTriggerFactoryBean cronTriggerFactoryBean(JobDetailFactoryBean jobDetialFactoryBean) {
13 CronTriggerFactoryBean factory = new CronTriggerFactoryBean();
14 factory.setJobDetail(jobDetailFactoryBean.getObject);
15 factory.setCronExpression("0/2 * * * * ?");
16 return factory;
17 }
18 //创建Scheduler对象
19 @Bean
20 public SchedulerFactoryBean schedulerFactoryBean(CronTriggerJobFactory cronTriggerJobFactory, MyAdaptableFactory myAdaptableFactory) {
21 SchedulerFactoryBean factory = new SchedulerFactoryBean();
22 factory.setTriggers(cronTriggerFactoryBean.getObject());
23 factory.setJobFactory(myAdaptableFactory);
24 return factory;
25 }
26 }