quartz定时任务框架运行过程：定时任务框架Quartz
quartz定时任务框架运行过程：定时任务框架QuartzWeek（1） Seconds Minutes Hours Day Month Week Year （2）Seconds Minutes Hours Day Monthpackage com.htb.beidawebscheduledreview.demo01; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.Date; /** @Description: @Author 16221 * @Date 2020/6/20 **/ @Component public class Demo01 { @Scheduled(cron = "0/2 * * * * ?"
一、spring boot 3.0 自带的 定时任务
Scheduled 定时任务器
demo示例
1) 加上Scheduled 注解，写上 cron 表达式
package com.htb.beidawebscheduledreview.demo01;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component;
import java.util.Date;
/**
@Description:
@Author 16221
* @Date 2020/6/20
**/ @Component
public class Demo01 {
@Scheduled(cron = "0/2 * * * * ?") public void scheduled(){
System.out.println("定时任务执行 " new Date());
}
}
- 主类上面添加 @EnableScheduling 注解
package com.htb.beidawebscheduledreview;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.scheduling.annotation.EnableScheduling;
@EnableScheduling @SpringBootApplication
public class BeidawebScheduledReviewApplication {
public static void main(String[] args) { SpringApplication.run(BeidawebScheduledReviewApplication.class args);
}
}
- 效果
- 分析
每两秒执行一次 上面的scheduled（） 方法 原因是因为 cron 表达式 上面的 cron 表达式：cron = "0/2
* * * * ?" 表示 每隔两秒执行一次
Cron 表达式是一个字符串，分为 6 或 7 个域，每一个域代表一个含义 Cron 有如下两种语法格式：
（1） Seconds Minutes Hours Day Month Week Year （2）Seconds Minutes Hours Day Month
Week
所以第一个位置是 秒 例子: @Scheduled(cron = "0 0 1 1 1 ?")//每年一月的一号的 1:00:00 执行一次
@Scheduled(cron = "0 0 1 1 1 6 ?") //一月和六月的一号的 1:00:00 执行一次 @Scheduled(cron = "0 0
1 1 1 4 7 10 ?") //每个季度的第一个月的一号的 1:00:00 执行一次 @Scheduled(cron = "0 0 1 1 * ?")//
每月一号 1:00:00 执行一次 @Scheduled(cron="0 0 1 * * *") //每天凌晨 1 点执行一次
二、结合 Quartz 定时任务框架
1）Quartz 的使用思路
- job - 任务 -> 做什么事？ 2）Trigger - 触发器 -> 什么时候去做？ 3）Scheduler - 任务调度 -> 什么时候需要去做什么事？
- 添加依赖
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
<exclusions>
<exclusion>
<artifactId>slf4j-api</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
<!-- Sprng tx 坐标 事务-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
</dependency>
3) 配置类
创建三个bean
package com.htb.beidawebscheduledreview.demo02.config;
import com.htb.beidawebscheduledreview.demo02.job.MyAdaptableJobFactory; import com.htb.beidawebscheduledreview.demo02.job.QuartzJob;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.CronTriggerFactoryBean; import org.springframework.scheduling.quartz.JobDetailFactoryBean; import org.springframework.scheduling.quartz.SchedulerFactoryBean;
/**
@Description:
@Author 16221
* @Date 2020/6/20
**/ @Configuration
public class QuartzConfig {
@Bean
public JobDetailFactoryBean jobDetailFactoryBean(){
JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
factoryBean.setJobClass(QuartzJob.class); return factoryBean;
}
@Bean
public CronTriggerFactoryBean cronTriggerFactoryBean(JobDetailFactoryBean jobDetailFactoryBean){
CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
cronTriggerFactoryBean.setJobDetail(jobDetailFactoryBean.getObject());
cronTriggerFactoryBean.setCronExpression("0/3 * * * * ?"); return cronTriggerFactoryBean;
}
@Bean
public SchedulerFactoryBean schedulerFactoryBean(CronTriggerFactoryBean cronTriggerFactoryBean
MyAdaptableJobFactory
myAdaptableJobFactory){
SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
factoryBean.setTriggers(cronTriggerFactoryBean.getObject()); factoryBean.setJobFactory(myAdaptableJobFactory);
return factoryBean;
}
}QuartzJob
package com.htb.beidawebscheduledreview.demo02.job;
import com.htb.beidawebscheduledreview.demo02.service.UserService; import org.quartz.Job;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException;
import javax.annotation.Resource;
/**
@Description:
@Author 16221
* @Date 2020/6/20
**/
public class QuartzJob implements Job { @Resource
private UserService userService;
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
userService.add();
}
}
- UserService
@Service
public class UserService {
public void add(){
System.out.println("user add...添加新用户 " new Date());
}
}
- 代理类，注入JobFactory
@EnableScheduling @SpringBootApplication
public class BeidawebScheduledReviewApplication {
public static void main(String[] args) { SpringApplication.run(BeidawebScheduledReviewApplication.class args);
}
}
- 启动类上加注解
@EnableScheduling @SpringBootApplication
public class BeidawebScheduledReviewApplication {
public static void main(String[] args) { SpringApplication.run(BeidawebScheduledReviewApplication.class args);
}
}
- 测试
启动主类，可以看到每两秒执行一次
三、以上的讲解都是单个的任务
开启多任务，只要配置多个 JobDetail 和 Trigger 即可
