引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
import com.example.quartz.bean.QuartzBean;
import lombok.Data;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author HQLD
* @description
* @date 2021-01-29 14:30
*/
@Service
public class QuartzService {
/**
* 注入任务调度
*/
@Autowired
private Scheduler scheduler;
/**
* 创建定时任务 定时任务创建之后默认启动状态
*
* @param quartzBean 定时任务信息类
*/
public void createScheduleJob(QuartzBean quartzBean) {
try {
//获取到定时任务的执行类 必须是类的绝对路径名称
//定时任务类需要是job类的具体实现 QuartzJobBean是job的抽象类。
Class<? extends Job> jobClass = (Class<? extends Job>) Class.forName(quartzBean.getJobClass());
// 构建定时任务信息
JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(quartzBean.getJobName()).build();
// 设置定时任务执行方式
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression());
// 构建触发器trigger
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(quartzBean.getJobName()).withSchedule(scheduleBuilder).build();
scheduler.scheduleJob(jobDetail, trigger);
} catch (ClassNotFoundException e) {
System.out.println("定时任务类路径出错:请输入类的绝对路径");
} catch (SchedulerException e) {
System.out.println("创建定时任务出错:" + e.getMessage());
}
}
/**
* 根据任务名称暂停定时任务
*
* @param jobName 定时任务名称
*/
public void pauseScheduleJob(String jobName) {
JobKey jobKey = JobKey.jobKey(jobName);
try {
scheduler.pauseJob(jobKey);
} catch (SchedulerException e) {
System.out.println("暂停定时任务出错:" + e.getMessage());
}
}
/**
* 根据任务名称恢复定时任务
*
* @param jobName 定时任务名称
*/
public void resumeScheduleJob(String jobName) {
JobKey jobKey = JobKey.jobKey(jobName);
try {
scheduler.resumeJob(jobKey);
} catch (SchedulerException e) {
System.out.println("启动定时任务出错:" + e.getMessage());
}
}
/**
* 根据任务名称立即运行一次定时任务
*
* @param jobName 定时任务名称
*/
public void runOnce(String jobName) {
JobKey jobKey = JobKey.jobKey(jobName);
try {
scheduler.triggerJob(jobKey);
} catch (SchedulerException e) {
System.out.println("运行定时任务出错:" + e.getMessage());
}
}
/**
* 更新定时任务
*
* @param quartzBean 定时任务信息类
*/
public void updateScheduleJob(QuartzBean quartzBean) {
try {
//获取到对应任务的触发器
TriggerKey triggerKey = TriggerKey.triggerKey(quartzBean.getJobName());
//设置定时任务执行方式
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression());
//重新构建任务的触发器trigger
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
//重置对应的job
scheduler.rescheduleJob(triggerKey, trigger);
} catch (SchedulerException e) {
System.out.println("更新定时任务出错:" + e.getMessage());
}
}
/**
* 根据定时任务名称从调度器当中删除定时任务
*
* @param jobName 定时任务名称
*/
public void deleteScheduleJob(String jobName) {
JobKey jobKey = JobKey.jobKey(jobName);
try {
scheduler.deleteJob(jobKey);
} catch (SchedulerException e) {
System.out.println("删除定时任务出错:" + e.getMessage());
}
}
@Data
public class QuartzBean {
/**
* 任务id
*/
private String id;
/**
* 任务名称
*/
private String jobName;
/**
* 任务执行类
*/
private String jobClass;
/**
* 任务状态 启动还是暂停
*/
private Integer status;
/**
* 任务运行时间表达式
*/
private String cronExpression;
//省略getter setter
}
}
使用例子
@Autowired
QuartzService quartzService;
@RequestMapping("/createJob")
public String createJob(QuartzBean quartzBean) {
try {
//进行测试所以写死
quartzBean.setJobClass("com.example.quartz.bean.MyTask1");
quartzBean.setJobName("test1");
quartzBean.setCronExpression("*10/ * * * * ?");
quartzService.createScheduleJob(quartzBean);
} catch (Exception e) {
return "创建失败";
}
return "创建成功";
}
package com.example.quartz.bean;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;
import java.util.Date;
public class MyTask1 extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
//TODO 这里写定时任务的执行逻辑
System.out.println("动态的定时任务执行时间:"+new Date().toLocaleString());
}
}
网友评论