14 changed files with 726 additions and 28 deletions
@ -1,9 +1,24 @@ |
|||
package com.ccsens.scheduler; |
|||
|
|||
import org.mybatis.spring.annotation.MapperScan; |
|||
import org.springframework.boot.SpringApplication; |
|||
import org.springframework.boot.autoconfigure.SpringBootApplication; |
|||
import org.springframework.boot.web.servlet.ServletComponentScan; |
|||
import org.springframework.scheduling.annotation.EnableAsync; |
|||
import org.springframework.scheduling.annotation.EnableScheduling; |
|||
|
|||
/** |
|||
* @description: |
|||
* @author: whj |
|||
* @time: 2021/2/20 17:39 |
|||
*/ |
|||
@EnableScheduling |
|||
@MapperScan(basePackages = {"com.ccsens.scheduler.persist.*"}) |
|||
@ServletComponentScan |
|||
@EnableAsync |
|||
@SpringBootApplication(scanBasePackages = "com.ccsens.scheduler") |
|||
public class SchedulerApplication { |
|||
public static void main(String[] args) { |
|||
SpringApplication.run(SchedulerApplication.class, args); |
|||
} |
|||
} |
|||
|
|||
@ -0,0 +1,31 @@ |
|||
package com.ccsens.scheduler.api; |
|||
|
|||
|
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiImplicitParams; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RequestMethod; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
import javax.servlet.http.HttpServletRequest; |
|||
import com.ccsens.scheduler.util.JsonResponse; |
|||
|
|||
@Api(tags = "DEBUG" , description = "DebugController | ") |
|||
@RestController |
|||
@RequestMapping("/debug") |
|||
@Slf4j |
|||
public class DebugController { |
|||
|
|||
@ApiOperation(value = "/测试",notes = "") |
|||
@ApiImplicitParams({ |
|||
}) |
|||
@RequestMapping(value="",method = RequestMethod.GET,produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse debug(HttpServletRequest request) throws Exception { |
|||
|
|||
return JsonResponse.newInstance().ok("测试"); |
|||
} |
|||
|
|||
|
|||
} |
|||
@ -0,0 +1,71 @@ |
|||
package com.ccsens.scheduler.api; |
|||
|
|||
import com.ccsens.scheduler.bean.dto.QuartzJobModule; |
|||
import com.ccsens.scheduler.util.JsonResponse; |
|||
import com.ccsens.scheduler.util.QuartzJobUtil; |
|||
import io.swagger.annotations.ApiImplicitParams; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import io.swagger.annotations.ApiParam; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.validation.annotation.Validated; |
|||
import org.springframework.web.bind.annotation.*; |
|||
|
|||
import javax.annotation.Resource; |
|||
|
|||
/** |
|||
* @description: |
|||
* @author: whj |
|||
* @time: 2021/6/30 16:26 |
|||
*/ |
|||
@Slf4j |
|||
@RestController |
|||
@RequestMapping("/job") |
|||
public class JobController { |
|||
|
|||
@Resource |
|||
private QuartzJobUtil quartzJobUtil; |
|||
|
|||
@ApiOperation(value = "/添加任务",notes = "") |
|||
@ApiImplicitParams({ |
|||
}) |
|||
@RequestMapping(value="add",method = RequestMethod.POST,produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse add(@ApiParam @Validated @RequestBody QuartzJobModule job) { |
|||
quartzJobUtil.addJob(job); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
|
|||
@ApiOperation(value = "/修改任务时间",notes = "") |
|||
@ApiImplicitParams({ |
|||
}) |
|||
@RequestMapping(value="modifyTime",method = RequestMethod.POST,produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse modifyTime(@ApiParam @Validated @RequestBody QuartzJobModule job) { |
|||
quartzJobUtil.modifyJobTime(job.getJobName(), job.getJobGroupName(), job.getCron()); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
|
|||
@RequestMapping(value="pause",method = RequestMethod.POST,produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse pause(String jobName) { |
|||
log.info("停止任务"); |
|||
quartzJobUtil.pauseJob(jobName); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
@PostMapping("/resume") |
|||
@ResponseBody |
|||
public JsonResponse resume(String jobName) { |
|||
log.info("恢复任务"); |
|||
quartzJobUtil.removeJob(jobName); |
|||
return JsonResponse.newInstance().ok(); |
|||
|
|||
} |
|||
|
|||
@PostMapping("/remove") |
|||
@ResponseBody |
|||
public JsonResponse remove(String jobName) { |
|||
log.info("移除任务"); |
|||
quartzJobUtil.removeJob(jobName); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
} |
|||
@ -0,0 +1,73 @@ |
|||
package com.ccsens.scheduler.bean.dto; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import com.ccsens.scheduler.util.Constant; |
|||
import com.fasterxml.jackson.annotation.JsonFormat; |
|||
import lombok.Data; |
|||
import org.quartz.Job; |
|||
import org.quartz.JobDataMap; |
|||
import org.quartz.JobExecutionContext; |
|||
import org.springframework.util.ClassUtils; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* @description: |
|||
* @author: whj |
|||
* @time: 2021/6/30 16:00 |
|||
*/ |
|||
@Data |
|||
public class QuartzJobModule { |
|||
/** |
|||
* 触发器开始时间 |
|||
*/ |
|||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") |
|||
private Date startTime; |
|||
/** |
|||
* 触发器结束时间 |
|||
*/ |
|||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") |
|||
private Date endTime; |
|||
/** |
|||
* job名称 |
|||
*/ |
|||
private String jobName; |
|||
/** |
|||
* job组名 |
|||
*/ |
|||
private String jobGroupName = Constant.Quartz.QZ_JOB_GROUP_NAME; |
|||
/** |
|||
* 定时器名称 |
|||
*/ |
|||
private String triggerName; |
|||
/** |
|||
* 定时器组名 |
|||
*/ |
|||
private String triggerGroupName = Constant.Quartz.QZ_TRIGGER_GROUP_NAME; |
|||
/** |
|||
* 执行定时任务的具体操作 |
|||
*/ |
|||
private String jobClass; |
|||
/** |
|||
* cron表达式 |
|||
*/ |
|||
private String cron; |
|||
/** |
|||
* job的附加信息 |
|||
*/ |
|||
private JobDataMap jobDataMap = new JobDataMap(); |
|||
/** |
|||
* 校验 |
|||
* @return |
|||
*/ |
|||
public boolean verify(){ |
|||
return !(StrUtil.isEmpty(jobName) |
|||
|| StrUtil.isEmpty(jobGroupName) |
|||
|| StrUtil.isEmpty(triggerName) |
|||
|| StrUtil.isEmpty(triggerGroupName) |
|||
|| StrUtil.isEmpty(cron) |
|||
|| !ClassUtils.hasMethod(Job.class, "execute", JobExecutionContext.class) |
|||
); |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,64 @@ |
|||
//package com.ccsens.scheduler.config;
|
|||
//
|
|||
//import cn.hutool.core.io.resource.ClassPathResource;
|
|||
//import org.quartz.Scheduler;
|
|||
//import org.quartz.ee.servlet.QuartzInitializerListener;
|
|||
//import org.springframework.beans.factory.config.PropertiesFactoryBean;
|
|||
//import org.springframework.context.annotation.Bean;
|
|||
//import org.springframework.context.annotation.Configuration;
|
|||
//import org.springframework.scheduling.quartz.SchedulerFactoryBean;
|
|||
//
|
|||
//import java.io.IOException;
|
|||
//import java.util.Properties;
|
|||
//
|
|||
///**
|
|||
// * @description:
|
|||
// * @author: whj
|
|||
// * @time: 2021/6/30 15:48
|
|||
// */
|
|||
//@Configuration
|
|||
//public class SchedulerConfig {
|
|||
// /**
|
|||
// * 读取quartz.properties 文件
|
|||
// * 将值初始化
|
|||
// * @return
|
|||
// */
|
|||
// @Bean
|
|||
// public Properties quartzProperties() throws IOException {
|
|||
// PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
|
|||
// propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
|
|||
// propertiesFactoryBean.afterPropertiesSet();
|
|||
// return propertiesFactoryBean.getObject();
|
|||
// }
|
|||
//
|
|||
// /**
|
|||
// * 将配置文件的数据加载到SchedulerFactoryBean中
|
|||
// * @return
|
|||
// * @throws IOException
|
|||
// */
|
|||
// @Bean
|
|||
// public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
|
|||
// SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
|
|||
// schedulerFactoryBean.setQuartzProperties();
|
|||
// return schedulerFactoryBean;
|
|||
// }
|
|||
//
|
|||
// /**
|
|||
// * 初始化监听器
|
|||
// * @return
|
|||
// */
|
|||
// @Bean
|
|||
// public QuartzInitializerListener executorListener(){
|
|||
// return new QuartzInitializerListener();
|
|||
// }
|
|||
//
|
|||
// /**
|
|||
// * 获得Scheduler 对象
|
|||
// * @return
|
|||
// * @throws IOException
|
|||
// */
|
|||
// @Bean
|
|||
// public Scheduler scheduler() throws IOException {
|
|||
// return schedulerFactoryBean().getScheduler();
|
|||
// }
|
|||
//}
|
|||
@ -0,0 +1,22 @@ |
|||
package com.ccsens.scheduler.service; |
|||
|
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.quartz.DisallowConcurrentExecution; |
|||
import org.quartz.JobExecutionContext; |
|||
import org.quartz.JobExecutionException; |
|||
import org.springframework.scheduling.quartz.QuartzJobBean; |
|||
|
|||
/** |
|||
* @author: whj |
|||
* @time: 2021/6/30 16:22 |
|||
*/ |
|||
@DisallowConcurrentExecution// 禁止并发执行
|
|||
@Slf4j |
|||
public class TestJobDetail extends QuartzJobBean { |
|||
@Override |
|||
protected void executeInternal(JobExecutionContext context) throws JobExecutionException { |
|||
log.info("begin delwith batch task >>>>>>>>>>>>>>>>>>>>>>>"); |
|||
String batchId = context.getJobDetail().getKey().getName(); |
|||
log.info("执行的任务id为：[{}]", batchId); |
|||
} |
|||
} |
|||
@ -0,0 +1,375 @@ |
|||
package com.ccsens.scheduler.util; |
|||
|
|||
import com.ccsens.scheduler.bean.dto.QuartzJobModule; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.quartz.*; |
|||
import org.quartz.impl.triggers.CronTriggerImpl; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.text.ParseException; |
|||
import java.text.SimpleDateFormat; |
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* @description: |
|||
* @author: whj |
|||
* @time: 2021/6/30 16:03 |
|||
*/ |
|||
@Slf4j |
|||
@Component |
|||
public class QuartzJobUtil { |
|||
@Resource |
|||
private Scheduler scheduler; |
|||
|
|||
/** |
|||
* @Description: 添加一个定时任务 |
|||
* @param quartzModel |
|||
*/ |
|||
public void addJob(QuartzJobModule quartzModel) { |
|||
if (quartzModel.verify()) { |
|||
try { |
|||
JobDetail job = JobBuilder.newJob((Class<? extends Job>) Class.forName(quartzModel.getJobClass())) |
|||
.withIdentity(quartzModel.getJobName(), quartzModel.getJobGroupName()) |
|||
.setJobData(quartzModel.getJobDataMap()).build(); |
|||
// 表达式调度构建器
|
|||
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzModel.getCron()); |
|||
// 按新的cronExpression表达式构建一个新的trigger
|
|||
TriggerBuilder<Trigger> builder = TriggerBuilder.newTrigger() |
|||
.withIdentity(quartzModel.getTriggerName(), quartzModel.getTriggerGroupName()); |
|||
if (quartzModel.getStartTime() != null) { |
|||
builder.startAt(quartzModel.getStartTime()); |
|||
} |
|||
if (quartzModel.getEndTime() != null) { |
|||
builder.endAt(quartzModel.getEndTime()); |
|||
} |
|||
Trigger trigger = builder.withSchedule(scheduleBuilder).build(); |
|||
scheduler.scheduleJob(job, trigger); |
|||
// 启动
|
|||
if (!scheduler.isShutdown()) { |
|||
scheduler.start(); |
|||
} |
|||
} |
|||
catch (Exception e) { |
|||
log.error("Add quartz job error, jobName = {}", quartzModel.getJobName()); |
|||
} |
|||
|
|||
} |
|||
else { |
|||
log.error("QuartzModel is invalid!"); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description: 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名) |
|||
* @param jobName |
|||
* @param cron |
|||
*/ |
|||
public void modifyJobTime(String jobName, String cron, Date startDate, Date endDate) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, Constant.Quartz.QZ_TRIGGER_GROUP_NAME); |
|||
|
|||
try { |
|||
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); |
|||
if (trigger == null) { |
|||
return; |
|||
} |
|||
String oldTime = trigger.getCronExpression(); |
|||
if (!oldTime.equalsIgnoreCase(cron)) { |
|||
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron); |
|||
// 按新的cronExpression表达式重新构建trigger
|
|||
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey) |
|||
.startAt(startDate) |
|||
.endAt(endDate).withSchedule(scheduleBuilder).build(); |
|||
// 按新的trigger重新设置job执行
|
|||
scheduler.rescheduleJob(triggerKey, trigger); |
|||
} |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:修改任务，（可以修改任务名，任务类，触发时间） |
|||
* 原理：移除原来的任务，添加新的任务 |
|||
* @param oldJobName |
|||
* ：原任务名 |
|||
* @param jobName |
|||
* @param jobclass |
|||
* @param cron |
|||
*/ |
|||
public void modifyJob(String oldJobName, String jobName, Class jobclass, String cron) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(oldJobName, Constant.Quartz.QZ_TRIGGER_GROUP_NAME); |
|||
JobKey jobKey = JobKey.jobKey(oldJobName, Constant.Quartz.QZ_JOB_GROUP_NAME); |
|||
try { |
|||
// 任务不存在
|
|||
if (removeJob(oldJobName, triggerKey, jobKey)) { |
|||
return; |
|||
} |
|||
|
|||
JobDetail job = JobBuilder.newJob(jobclass).withIdentity(jobName, |
|||
Constant.Quartz.QZ_JOB_GROUP_NAME) |
|||
.build(); |
|||
// 表达式调度构建器
|
|||
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron); |
|||
// 按新的cronExpression表达式构建一个新的trigger
|
|||
Trigger newTrigger = TriggerBuilder.newTrigger().withIdentity(jobName, |
|||
Constant.Quartz.QZ_TRIGGER_GROUP_NAME) |
|||
.withSchedule(scheduleBuilder).build(); |
|||
|
|||
// 交给scheduler去调度
|
|||
scheduler.scheduleJob(job, newTrigger); |
|||
|
|||
// 启动
|
|||
if (!scheduler.isShutdown()) { |
|||
scheduler.start(); |
|||
System.err.println("添加新任务:" + jobName); |
|||
} |
|||
System.err.println("修改任务【" + oldJobName + "】为:" + jobName); |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
|
|||
} |
|||
|
|||
private boolean removeJob(String oldJobName, TriggerKey triggerKey, JobKey jobKey) throws SchedulerException { |
|||
Trigger trigger = scheduler.getTrigger(triggerKey); |
|||
if (trigger == null) { |
|||
return true; |
|||
} |
|||
// 停止触发器
|
|||
deleteJob(triggerKey, jobKey); |
|||
System.err.println("移除任务:" + oldJobName); |
|||
return false; |
|||
} |
|||
|
|||
/** |
|||
* @Description: 修改一个任务的触发时间 |
|||
* @param triggerName |
|||
* @param triggerGroupName |
|||
* @param cron |
|||
*/ |
|||
public void modifyJobTime(String triggerName, String triggerGroupName, String cron) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); |
|||
try { |
|||
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); |
|||
if (trigger == null) { |
|||
return; |
|||
} |
|||
String oldTime = trigger.getCronExpression(); |
|||
if (!oldTime.equalsIgnoreCase(cron)) { |
|||
// trigger已存在，则更新相应的定时设置
|
|||
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron); |
|||
// 按新的cronExpression表达式重新构建trigger
|
|||
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build(); |
|||
// 按新的trigger重新设置job执行
|
|||
scheduler.resumeTrigger(triggerKey); |
|||
} |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description 移除一个任务(使用默认的任务组名，触发器名，触发器组名) |
|||
* @param jobName |
|||
*/ |
|||
public void removeJob(String jobName) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, Constant.Quartz.QZ_TRIGGER_GROUP_NAME); |
|||
JobKey jobKey = JobKey.jobKey(jobName, Constant.Quartz.QZ_JOB_GROUP_NAME); |
|||
try { |
|||
Trigger trigger = (Trigger) scheduler.getTrigger(triggerKey); |
|||
if (trigger == null) { |
|||
return; |
|||
} |
|||
deleteJob(triggerKey, jobKey); |
|||
System.err.println("移除任务:" + jobName); |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
private void deleteJob(TriggerKey triggerKey, JobKey jobKey) throws SchedulerException { |
|||
// 停止触发器
|
|||
scheduler.pauseTrigger(triggerKey); |
|||
// 移除触发器
|
|||
scheduler.unscheduleJob(triggerKey); |
|||
// 删除任务
|
|||
scheduler.deleteJob(jobKey); |
|||
} |
|||
|
|||
/** |
|||
* @Description: 移除一个任务 |
|||
* @param jobName |
|||
* @param jobGroupName |
|||
* @param triggerName |
|||
* @param triggerGroupName |
|||
*/ |
|||
public void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, triggerGroupName); |
|||
JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); |
|||
try { |
|||
deleteJob(triggerKey, jobKey); |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:暂停一个任务(使用默认组名) |
|||
* @param jobName |
|||
*/ |
|||
public void pauseJob(String jobName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, Constant.Quartz.QZ_JOB_GROUP_NAME); |
|||
try { |
|||
scheduler.pauseJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:暂停一个任务 |
|||
* @param jobName |
|||
* @param jobGroupName |
|||
*/ |
|||
public void pauseJob(String jobName, String jobGroupName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); |
|||
try { |
|||
scheduler.pauseJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:恢复一个任务(使用默认组名) |
|||
* @param jobName |
|||
*/ |
|||
public void resumeJob(String jobName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, Constant.Quartz.QZ_JOB_GROUP_NAME); |
|||
try { |
|||
scheduler.resumeJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:恢复一个任务 |
|||
* @param jobName |
|||
* @param jobGroupName |
|||
*/ |
|||
public void resumeJob(String jobName, String jobGroupName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); |
|||
try { |
|||
scheduler.resumeJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description:启动所有定时任务 |
|||
*/ |
|||
public void startJobs() { |
|||
try { |
|||
scheduler.start(); |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description 关闭所有定时任务 |
|||
*/ |
|||
public void shutdownJobs() { |
|||
try { |
|||
if (!scheduler.isShutdown()) { |
|||
scheduler.shutdown(); |
|||
} |
|||
} |
|||
catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description: 立即运行任务，这里的立即运行，只会运行一次，方便测试时用。 |
|||
* @param jobName |
|||
*/ |
|||
public void triggerJob(String jobName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, Constant.Quartz.QZ_JOB_GROUP_NAME); |
|||
try { |
|||
scheduler.triggerJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description: 立即运行任务，这里的立即运行，只会运行一次，方便测试时用。 |
|||
* @param jobName |
|||
* @param jobGroupName |
|||
*/ |
|||
public void triggerJob(String jobName, String jobGroupName) { |
|||
JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); |
|||
try { |
|||
scheduler.triggerJob(jobKey); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* @Description: 获取任务状态 |
|||
* @param jobName |
|||
* 触发器名 |
|||
*/ |
|||
public String getTriggerState(String jobName) { |
|||
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, Constant.Quartz.QZ_TRIGGER_GROUP_NAME); |
|||
String name = null; |
|||
try { |
|||
Trigger.TriggerState triggerState = scheduler.getTriggerState(triggerKey); |
|||
name = triggerState.name(); |
|||
} |
|||
catch (SchedulerException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
return name; |
|||
} |
|||
|
|||
/** |
|||
* @Description:获取最近5次执行时间 |
|||
* @param cron |
|||
*/ |
|||
public List<String> getRecentTriggerTime(String cron) { |
|||
List<String> list = new ArrayList<String>(); |
|||
try { |
|||
CronTriggerImpl cronTriggerImpl = new CronTriggerImpl(); |
|||
cronTriggerImpl.setCronExpression(cron); |
|||
List<Date> dates = TriggerUtils.computeFireTimes(cronTriggerImpl, null, 5); |
|||
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss"); |
|||
for (Date date : dates) { |
|||
list.add(dateFormat.format(date)); |
|||
} |
|||
} |
|||
catch (ParseException e) { |
|||
log.error("GetRecentTriggerTime error, cron = {}", cron, e); |
|||
} |
|||
return list; |
|||
} |
|||
} |
|||
Loading…
Reference in new issue