springboot整合quartz

package com.quartzs.demo.util; import com.quartzs.demo.service.HelloJob; import lombok.extern.log4j.Log4j2; import org.quartz.*; import org.quartz.impl.matchers.GroupMatcher; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.*; /** * task任务创建个工具类 * * @author author * 2020-02-11 16:04 */ @Component @Log4j2 public class QuartzJobManager { private static QuartzJobManager jobUtil; @Autowired private Scheduler scheduler; public QuartzJobManager() { log.info("QuartzJobManager init"); jobUtil = this; } public static QuartzJobManager getInstance() { log.info("return JobUtil"); return QuartzJobManager.jobUtil; } /** * 创建任务 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @param cronExpression cron表达式 * @throws Exception */ public void addJob(String jobName, String jobGroupName, String cronExpression) throws Exception { //启动调度器 scheduler.start(); //构建job信息 HelloJob：执行定时任务的具体代码 JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity(jobName, jobGroupName).build(); //表达式调度构造起,任务执行时间 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression); //根据任务执行时间的cron表达式构建trigger触发器 CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName).withSchedule(scheduleBuilder).build(); scheduler.scheduleJob(jobDetail, trigger); } /** * 创建job，可传参,可以新加一个定时任务实现类的参数，本例写死 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @param cronExpression cron表达式 * @param argMap map形式参数 * @throws Exception */ public void addJob(String jobName, String jobGroupName, String cronExpression, Map<String, Object> argMap) throws Exception { // 启动调度器 scheduler.start(); //构建job信息 JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity(jobName, jobGroupName).build(); //传入参数 jobDetail.getJobDataMap().putAll(argMap); //表达式调度构建器(即任务执行的时间) CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression); //按新的cronExpression表达式构建一个新的trigger CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName) .withSchedule(scheduleBuilder).build(); //获得JobDataMap，写入数据 //trigger.getJobDataMap().putAll(argMap); scheduler.scheduleJob(jobDetail, trigger); } /** * 暂停job * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @throws SchedulerException */ public void pauseJob(String jobName, String jobGroupName) throws SchedulerException { scheduler.pauseJob(JobKey.jobKey(jobName, jobGroupName)); } /** * 恢复job * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @throws SchedulerException */ public void resumeJob(String jobName, String jobGroupName) throws SchedulerException { scheduler.resumeJob(JobKey.jobKey(jobName, jobGroupName)); } /** * job 更新,只更新频率 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @param cronExpression cron表达式 * @throws Exception */ public void updateJob(String jobName, String jobGroupName, String cronExpression) throws Exception { TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName); // 表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); // 按新的cronExpression表达式重新构建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build(); // 按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey, trigger); } /** * job 更新,更新频率和参数 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @param cronExpression cron表达式 * @param argMap 参数 * @throws Exception */ public void updateJob(String jobName, String jobGroupName, String cronExpression, Map<String, Object> argMap) throws Exception { TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName); // 表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); // 按新的cronExpression表达式重新构建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build(); //修改map trigger.getJobDataMap().putAll(argMap); // 按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey, trigger); } /** * job 更新,只更新更新参数 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @param argMap 参数 * @throws Exception */ public void updateJob(String jobName, String jobGroupName, Map<String, Object> argMap) throws Exception { TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); //修改map trigger.getJobDataMap().putAll(argMap); // 按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey, trigger); } /** * job 删除 * * @param jobName 任务名称 * @param jobGroupName 任务所在组名称 * @throws Exception */ public void deleteJob(String jobName, String jobGroupName) throws Exception { scheduler.pauseTrigger(TriggerKey.triggerKey(jobName, jobGroupName)); scheduler.unscheduleJob(TriggerKey.triggerKey(jobName, jobGroupName)); scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName)); } /** * 启动所有定时任务 */ public void startAllJobs() { try { scheduler.start(); } catch (Exception e) { throw new RuntimeException(e); } } /** * 关闭所有定时任务 */ public void shutdownAllJobs() { try { if (!scheduler.isShutdown()) { scheduler.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * 获取所有任务列表 * * @return * @throws SchedulerException */ public List<Map<String, Object>> getAllJob() throws SchedulerException { GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup(); Set<JobKey> jobKeys = scheduler.getJobKeys(matcher); List<Map<String, Object>> jobList = new ArrayList<>(); for (JobKey jobKey : jobKeys) { List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey); for (Trigger trigger : triggers) { Map<String, Object> job = new HashMap<>();