Quartz2.2.1在JAVA中的简单用法 （二）
浏览数：28 /
时间：2015年06月08日
先前在上一篇博客中介绍了Quartz2.2.1在JAVA中的简单用法，但是只是单个任务的创建，而实际应用中有的时候会有多个任务需要执行，这里简单介绍一下多个任务的创建，也算是上一篇博客的一个小小的补充。
点击这里可以查看上一篇博客
Quartz2.2.1在JAVA中的简单用法 （一）
1、新建一个WebProject工程项目。注意：项目的jdk版本必须在1.6以上，才能支持Quartz2.2.1，不然会报错，版本不支持。。
2、引入解压Quartz2.2.1.zip之后所得到的6个jar包文件，这里简单的说明一下：除了第一个jar（c3p0-0.9.1.1.jar）可以不用引入，这个jar包貌似是数据库连接池所需要的jar包，反正暂时都没怎么用到，不过还是建议都引入进项目中以免报错。因为官方下载下来就有，应该是quartz框架集成中有用到这个jar中的某些功能，其他的都需要引入到项目中来，大家可以亲自试一试，先一个一个的加到项目中，看看分别会报什么错，
3、编写任务调度工具类
package com.common;
import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.job.TestJobOne;
import com.job.TestJobTwo;
/**
* 任务调度公共类
* @remark
* @author feizi
* @time 2015-3-23下午3:04:12
*/
public class QuartzUtil {
private final static String JOB_GROUP_NAME = "QUARTZ_JOBGROUP_NAME";//任务组
private final static String TRIGGER_GROUP_NAME = "QUARTZ_TRIGGERGROUP_NAME";//触发器组
private static Logger log = LoggerFactory.getLogger(QuartzUtil.class);//日志
/**
* 添加任务的方法
* @param jobName 任务名
* @param triggerName 触发器名
* @param jobClass 执行任务的类
* @param seconds 间隔时间
* @throws SchedulerException
*/
public static void addJob(String jobName,String triggerName,Class<? extends Job> jobClass,int seconds) throws SchedulerException{
log.info("==================initialization=================");
//创建一个SchedulerFactory工厂实例
SchedulerFactory sf = new StdSchedulerFactory();
//通过SchedulerFactory构建Scheduler对象
Scheduler sche = sf.getScheduler();
log.info("===================initialize finshed===================");
log.info("==============add the Job to Scheduler==================");
//用于描叙Job实现类及其他的一些静态信息，构建一个作业实例
JobDetail jobDetail = JobBuilder.newJob(jobClass)
.withIdentity(jobName, JOB_GROUP_NAME)
.build();
//构建一个触发器，规定触发的规则
Trigger trigger = TriggerBuilder.newTrigger()//创建一个新的TriggerBuilder来规范一个触发器
.withIdentity(triggerName, TRIGGER_GROUP_NAME)//给触发器起一个名字和组名
.startNow()//立即执行
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(seconds)//时间间隔 单位：秒
.repeatForever()//一直执行
)
.build();//产生触发器
//向Scheduler中添加job任务和trigger触发器
sche.scheduleJob(jobDetail, trigger);
//启动
sche.start();
}
/**
* 测试
* @param args
*/
public static void main(String[] args) {
try {
//添加第一个任务 每隔10秒执行一次
QuartzUtil.addJob("job1", "trigger1", TestJobOne.class, 2);
//添加第二个任务 每隔20秒执行一次
QuartzUtil.addJob("Job2", "trigger2", TestJobTwo.class, 5);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
4、编写实际任务执行类，执行实际的业务操作。
（1）任务一、
package com.job;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
* 实际执行任务的业务类,需要实现Job接口
* @remark
* @author feizi
* @time 2015-3-23下午2:48:57
*/
public class TestJobOne implements Job {
/**
* 执行任务的方法
*/
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("================执行任务一....");
//do more...这里可以执行其他需要执行的任务
}
}
（2）任务二、
package com.job;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
* 实际执行任务的业务类,需要实现Job接口
* @remark
* @author feizi
* @time 2015-3-23下午2:49:46
*/
public class TestJobTwo implements Job {
/**
* 执行任务的方法
*/
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("================执行任务二....");
//do more...这里可以执行其他需要执行的任务
}
}
5、在任务调度工具类QuartzUtil中写个main方法测试一下。
之后运行QuartzUtil类中的main测试方法。
6、上面的任务调度的入口是在main方法里面启动的，是通过手动执行的方式开启任务的，但是实际的项目在运行中不可能说通过这种手动方式去调用，那么我们必须在项目中找到一个入口来启动这个任务，我这里使用的是通过在一个Servlet的初始化方法中去启动这个任务，因为根据Servlet的生命周期，在Tomcat容器启动之后，就会去Web.xm文件中去加载Servlet，然后调用Servlet的初始化方法，并且只运行一次。
编写Servlet类：
package com.servlet;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import org.quartz.SchedulerException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.common.QuartzUtil;
import com.job.TestJobOne;
import com.job.TestJobTwo;
public class InitServlet extends HttpServlet {
private static final long serialVersionUID = -5652071148837106939L;
private Logger log = LoggerFactory.getLogger(InitServlet.class);
/**
* 因为我们不需要处理请求与响应的消息操作，所以这个地方只留一个初始化的操作就行了，用以执行任务调度的入口
*/
public void init() throws ServletException {
log.info("==================启动InitServlet...");
try {
//添加第一个任务 每隔2秒执行一次
QuartzUtil.addJob("job1", "trigger1", TestJobOne.class, 2);
//添加第二个任务 每隔5秒执行一次
QuartzUtil.addJob("Job2", "trigger2", TestJobTwo.class, 5);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
在web.xml文件中注册Servlet，这里的<load-on-startup>0</load-on-startup>Servlet启动优先级也可以不用做调整，因为这个例子里面只有一个Servlet，但是如果项目中有多个Servlet的话 可以通过设置这个值调整Servlet的启动优先级顺序。
web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5"
xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
<display-name></display-name>
<servlet>
<servlet-name>InitServlet</servlet-name>
<servlet-class>com.servlet.InitServlet</servlet-class>
<load-on-startup>0</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>InitServlet</servlet-name>
<url-pattern>/InitServlet</url-pattern>
</servlet-mapping>
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
</web-app>
启动Tomcat容器，查看控制台:
郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。
