版本:v2.2.1 完整版 大小:4.41 MB
类别:编程辅助 系统:WinXP, Win7, Win8, Win10
立即下载quartz2.2.1.jar是一款用于java调度框架quartz最经典好用版本2.2.1的jar包,包含了doc以及相关的jar包,可以让编程开发人员更加优质便捷的进行相关的工作,有需要的朋友就来IT猫扑下载吧!
一个完全由java编写的开源作业调度框架。不要让作业调度这个术语吓着你。尽管Quartz框架整合了许多额外功能, 但就其简易形式看,你会发现它易用得简直让人受不了!。简单地创建一个实现org.quartz.Job接口的java类。Job接口包含唯一的方法:
public void execute(JobExecutionContext context)
throws JobExecutionException;
在你的Job接口实现类里面,添加一些逻辑到execute()方法。一旦你配置好Job实现类并设定好调度时间表,Quartz将密切注意剩余时间。当调度程序确定该是通知你的作业的时候,Quartz框架将调用你Job实现类(作业类)上的execute()方法并允许做它该做的事情。无需报告任何东西给调度器或调用任何特定的东西。仅仅执行任务和结束任务即可。如果配置你的作业在随后再次被调用,Quartz框架将在恰当的时间再次调用它。
新建一个Webproject工程项目。注意:项目的jdk版本必须在1.6以上,才能支持Quartz2.2.1,不然会报错,版本不支持。。
引入解压Quartz2.2.1.zip之后所得到的6个jar包文件,这里简单的说明一下:除了第一个jar(c3p0-0.9.1.1.jar)可以不用引入,这个jar包貌似是数据库连接池所需要的jar包,反正暂时都没怎么用到,不过还是建议都引入进项目中以免报错。因为官方下载下来就有,应该是quartz框架集成中有用到这个jar中的某些功能,其他的都需要引入到项目中来,大家可以亲自试一试,先一个一个的加到项目中,看看分别会报什么错,
编写任务调度工具类
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 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();
}
}
}
编写实际任务执行类,执行实际的业务操作
任务一
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...这里可以执行其他需要执行的任务
}
}
任务二
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...这里可以执行其他需要执行的任务
}
}
在任务调度工具类QuartzUtil中写个main方法测试一下。
之后运行QuartzUtil类中的main测试方法。
上面的任务调度的入口是在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,这里的
web.xml
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">
启动Tomcat容器,查看控制台:
查看全部