SSM框架极简便携式集成Quartz任务调度

SSM框架极简便携式集成Quartz任务调度

SSM集成Quartz，实际操作只需两步：

1.配置自定义的Job（添加job的相关属性，修改任务方法）

2.将Job注册到JobRegister

即可在项目中运行属于你的Quartz任务调度，方便实用，易于操作。

1.添加maven依赖

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

2.配置基本任务属性类BaseJob

BaseJob：作用用于配置自定义Job时候存储属性内容，以及用于配置JobDataMap来传数据

import lombok.Getter;
import lombok.Setter;
import org.quartz.JobDataMap;
/**
* 基本任务属性
*
* @author ： CatalpaFlat
* @date ：Create in 16:14 2017/11/16
*/
public abstract class BaseJob {
@Getter
@Setter
protected String jobName;
@Getter
@Setter
protected String cronTime;
@Getter
@Setter
protected String jobGroupName;
@Getter
@Setter
protected String triggerGroupName;
@Getter
@Setter
protected JobDataMap jobDataMap;
}

3.自定义任务TestJob

自定义任务：通过构造方法，配置Job的基本属性，以及将业务逻辑在execute中进行呈现。

/**
* 测试任务
*
* @author CatalpaFlat
* @date Create in 9:47 2017/11/15
*/
@Component
public class TestJob extends BaseJob implements Job {
public TestJob() {
super.setCronTime("0/2 * * * * ?");
super.setJobName(this.getClass().getSimpleName());
}
/**
* 把要执行的操作，写在execute方法中
*/
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println("\t\t"+TestJob.class.getName()+":"+ System.currentTimeMillis());
//TODO you logic
}
}

4.任务注册器JobRegister

任务注册器：JobRegister将自定义的Job注册进来，

/**
* 注册自定义任务
*
* @author CatalpaFlat
* @date Create in 14:26 2017/11/16
*/
public interface JobRegister {
/**
* 测试Job
*/
Class<? extends BaseJob> TEST_JOB = TestJob.class;

Class<? extends BaseJob> CHEN_JOB = ChenJob.class;
}

5.自定义初始化Quartz类

InitQuartz：初始化job到Scheduler

/**
* 初始化任务调度
*
* @author ： CatalpaFlat
* @date ：Create in 14:49 2017/11/16
*/
public class InitQuartz {

private static Set<Class> jobs = new HashSet<>();

/**
* 获取已经注册的任务
*/
private void initJobNameList() throws IllegalAccessException {
Field[] fields = JobRegister.class.getFields();
for (Field field : fields) {
Class name = (Class) field.get(field.getName());
jobs.add(name);
}
System.out.println("有多少个job："+jobs.size());
}

/**
* 动态添加任务
*/
private void addJobByCronTrigger() throws IllegalAccessException, InstantiationException {
for (Class cls : jobs) {
BaseJob bJob = (BaseJob) cls.newInstance();
QuartzUtil.addJobByCronTrigger(cls, bJob);
}
}

/**
* 初始化Quartz
*/
public void init() {
try {
//初始化JobName
initJobNameList();
//开始添加任务
addJobByCronTrigger();
} catch (InstantiationException | IllegalAccessException e) {
e.printStackTrace();
}
}
}

6.将Quartz整合到spring

在application.xml中进行注入即可：

<!--spring启动后初始化Quartz-->
<bean id="initQuartz" class="com.chen.module.quartz.InitQuartz" init-method="init"/>

7.测试

直接启动Tomcat

8.小注意

若是出现重复初始化Quartz，那么可能是以下问题：

web.xml中配置了：

<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

将其去除即可。