spring quartz

Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个，百个，甚至是好几万个Jobs这样复杂的程序。Jobs可以做成标准的Java组件或 EJBs。

Quartz是一个完全由java编写的开源作业调度框架。不要让作业调度这个术语吓着你。尽管Quartz框架整合了许多额外功能， 但就其简易形式看，你会发现它易用得简直让人受不了！。简单地创建一个实现org.quartz.Job接口的java类。Job接口包含唯一的方法：

public void execute(JobExecutionContext context)
throws JobExecutionException;

在你的Job接口实现类里面，添加一些逻辑到execute()方法。一旦你配置好Job实现类并设定好调度时间表，Quartz将密切注意剩余时间。当调度程序确定该是通知你的作业的时候，Quartz框架将调用你Job实现类（作业类）上的execute()方法并允许做它该做的事情。无需报告任何东西给调度器或调用任何特定的东西。仅仅执行任务和结束任务即可。如果配置你的作业在随后再次被调用，Quartz框架将在恰当的时间再次调用它。

Quartz框架的核心是调度器。调度器负责管理Quartz应用运行时环境。调度器不是靠自己做所有的工作，而是依赖框架内一些非常重要的部件。Quartz不仅仅是线程和线程管理。为确保可伸缩性，Quartz采用了基于多线程的架构。启动时，框架初始化一套worker线程，这套线程被调度器用来执行预定的作业。这就是Quartz怎样能并发运行多个作业的原理。Quartz依赖一套松耦合的线程池管理部件来管理线程环境。

pom.xml

<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.2</version>
</dependency>

ScheduleDto

public class ScheduleDto {

private String jobName;// 定时任务名称

private String jobGroup; // 定时任务所属组

private String triggerName; //triggerName

private String triggerGroup; //triggerGroup

private Date StartTime; //开始时间

private Date nextFireTime; //下次调度时间

private String triggerState; //调度状态-NONE，NORMAL，PAUSED，COMPLETE，ERROR，BLOCKED-无，正常，已暂停，完成，错误，已阻止

spring quartz

@Component
public class QuartzJobComponent {

/**
* 查询所以的quartz
* @return
* @throws Exception
*/
public List<ScheduleDto> getScheduleList() throws Exception {
List<ScheduleDto> list = new ArrayList<>();
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.getTriggerGroupNames();
for (String groupName : scheduler.getJobGroupNames()) {
for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) {
ScheduleDto dto = new ScheduleDto();
String jobName = jobKey.getName();
String jobGroup = jobKey.getGroup();
dto.setJobName(jobName);
dto.setJobGroup(jobGroup);
List<Trigger> triggers = (List<Trigger>) scheduler.getTriggersOfJob(jobKey);
Trigger trigger = triggers.get(0);
dto.setTriggerName(trigger.getKey().getName());
dto.setTriggerGroup(trigger.getKey().getGroup());
dto.setStartTime(trigger.getStartTime());
dto.setNextFireTime(trigger.getNextFireTime());
dto.setTriggerState(scheduler.getTriggerState(trigger.getKey()).name());
list.add(dto);
}
}
return list;
}

/**
* 查询是否存在返回quartz状态
* @return
* @throws Exception
*/
public String getSchedStatus(String name, String group) throws Exception {
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
TriggerKey TriggerKey = new TriggerKey("trigger" + name, group);
String status = scheduler.getTriggerState(TriggerKey).name();
return status;
}

/**
* 恢复调度器
* @param bean
* @throws Exception
*/
public void starSched(Integer id, String uri) throws Exception {
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
JobKey jobKey = JobKey.jobKey("job" + id, uri);
scheduler.resumeJob(jobKey);
}

/**
* 暂停调度器
* @param bean
* @throws Exception
*/
public void pauseSched(Integer id, String uri) throws Exception {
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
JobKey jobKey = JobKey.jobKey("job" + id, uri);
scheduler.pauseJob(jobKey);
}

/**
* 删除调度器
* @param bean
* @throws Exception
*/
public void deleteSched(Integer id, String uri) throws Exception {
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
JobKey jobKey = JobKey.jobKey("job" + id, uri);
scheduler.deleteJob(jobKey);
}

/**
* 添加调度器
* @param bean
* @throws Exception
*/
public void addQuartzJob(String frequency,Integer id,String uri) throws Exception{
Scheduler scheduler = new StdSchedulerFactory().getScheduler();
if (StringUtils.isNotEmpty(frequency)) {
String frequencyBefore = frequency.substring(0, frequency.length() - 1);
String frequencyAfter = frequency.substring(frequency.length() - 1);
Long afterTime = MetricUtils.getABCTime(frequencyAfter) / 1000;
/** 获取执行频率的（秒） **/
int second = (int) (Long.valueOf(frequencyBefore) * afterTime);
/**创建执行的任务**/
JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class)
.withIdentity("job" + id, uri)
.usingJobData("id", id).build();

/**创建执行任务的触发器**/
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger" + id, uri).startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(second)
.repeatForever())
.build();
/**调度任务**/
scheduler.scheduleJob(jobDetail, trigger);
}

}

}

SimpleJob

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class SimpleJob implements Job {

@Override
public void execute(JobExecutionContext context) throws JobExecutionException {

JobDataMap dataMap = context.getJobDetail().getJobDataMap();
Integer id = dataMap.getInt("id");
system.out.println(id);

}

}