目录
定时任务应用场景:年度报表、秒杀商品上架、缓存统计报告
- package com.qing;
-
- import java.util.Timer;
- import java.util.TimerTask;
-
-
- class SpringbootQuartzApplicationTests {
-
- public static void main(String[] args) {
- Timer timer = new Timer();
- TimerTask timerTask = new TimerTask(){
-
- @Override
- public void run() {
- System.out.println("do job");
- }
- };
- //延迟5s,每隔1s执行一次任务
- timer.schedule(timerTask,5000,1000);
- }
-
-
- }

job:具体执行的工作
jobDetail:与工作相关的设定
trigger触发器: 某一个工作具体的触发规则
scheduler调度器:把jobDetail和trigger绑定在一起
scheduler调度器:把jobDetail和trigger绑定在一起 → trigger:绑定具体的工作明细 → jobDetail:绑定具体的工作 → job
步骤
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-quartz</artifactId>
- </dependency>
→ job
- package com.qing.quartz;
-
- import org.quartz.JobExecutionContext;
- import org.quartz.JobExecutionException;
- import org.springframework.scheduling.quartz.QuartzJobBean;
-
- public class Myquartz extends QuartzJobBean {
-
- //工作job
- @Override
- protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
- System.out.println("do quartz job");
- }
-
- }
→ 执行周期、jobDetail、trigger触发器、scheduler调度器
- package com.qing.config;
-
- import com.qing.quartz.Myquartz;
- import org.quartz.*;
- import org.springframework.context.annotation.Bean;
- import org.springframework.context.annotation.Configuration;
-
- @Configuration
- public class QuartzConfig {
-
- JobDetail jobDetail = null;
-
- //工作明细
- @Bean
- public JobDetail printJobDetail(){
- //绑定具体的工作
- //storeDurably 是做持久化的
- jobDetail = JobBuilder.newJob(Myquartz.class).storeDurably().build();
- return jobDetail;
- }
-
- //触发器
- @Bean
- public Trigger printTrigger(){
-
- //cronSchedule(秒 分 时 日 月 星期)
- //cronSchedule("0 0 0 1 2 ?"):0点0分0秒2月1日星期?
- //cronSchedule("0 0 0 * * ?"):任意月日 即每天
- //cronSchedule("0 * * * * ?"):每天的任意整分钟执行
- //cronSchedule("0,15,30,45 * * * * ?"):每天的0,15,30,45秒运行这个工作
- //cronSchedule("0/5 * * * * ?"):从0秒开始每5s执行一次
- ScheduleBuilder schedBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");
- //绑定对应的工作明细
- return TriggerBuilder.newTrigger().forJob(jobDetail).withSchedule(schedBuilder).build();
- }
-
- }
启动项目
