Quartz学习——Quartz简单入门Demo（二）

要学习Quartz框架，首先大概了解了Quartz的基本知识后，在经过简单的例子入门，一步一个脚印的走下去。 
下面介绍Quartz入门的示例，因为Quartz的存储方式分为RAM和JDBC，分别对这两种进行简单的说明。并附上代码！ 
首先须要添加Quartz的Jar包 ，我使用的是quartz.2.2.1版本！ 
Demo代码下载地址：quartz-study

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

　

1：RAM方式 
要测试RAMdemo的代码，请先删除demo中这个quartz.properties文件，或者重命名！不然会测试不成功！ 
（1）：Job

package com.liuzhihu.learn;

import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 
 * @author liuzhihu
 *
 */
public class RAMJob implements Job {

	private static Logger _log = LoggerFactory.getLogger(RAMJob.class);

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

		_log.info("Say hello to Quartz" + new Date());
	}

}

 

（2）：RAMQuartz

 

package com.liuzhihu.learn;

import java.util.Date;

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;

/***
 * 
 * @author liuzhihu
 *
 */
public class RAMQuartz {

	private static Logger _log = LoggerFactory.getLogger(RAMQuartz.class);

	public static void main(String[] args) throws SchedulerException {
		// 1.建立Scheduler的工厂
		SchedulerFactory sf = new StdSchedulerFactory();
		// 2.从工厂中获取调度器实例
		Scheduler scheduler = sf.getScheduler();

		// 3.建立JobDetail
		JobDetail jb = JobBuilder.newJob(RAMJob.class).withDescription("this is a ram job") // job的描述
				.withIdentity("ramJob", "ramGroup") // job 的name和group
				.build();

		// 任务运行的时间，SimpleSchedle类型触发器有效
		long time = System.currentTimeMillis() + 3 * 1000L; // 3秒后启动任务
		Date statTime = new Date(time);

		// 4.建立Trigger
		// 使用SimpleScheduleBuilder或者CronScheduleBuilder
		Trigger t = TriggerBuilder.newTrigger().withDescription("").withIdentity("ramTrigger", "ramTriggerGroup")
				 .withSchedule(SimpleScheduleBuilder.simpleSchedule())
				.startAt(statTime) // 默认当前时间启动
				//.withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?")) // 两秒执行一次
				.build();

		// 5.注册任务和定时器
		scheduler.scheduleJob(jb, t);

		// 6.启动 调度器
		scheduler.start();
		_log.info("启动时间 ： " + new Date());

	}
}

　

运行结果： 
SimpleScheduleBuilder：

 

CronScheduleBuilder：

 

 

2.JDBC方式

使用jdbc方式，就要配置quartz.properties文件，而且在开始的时候在数据库中新增表！ 
我使用的数据库是mysql，数据库中表在quartz_demo里面有，须要的请在里面下载！ 
运行 tables_db2_v8.sql 这个文件。

#JDBC驱动
org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz_test
org.quartz.dataSource.qzDS.user:root
org.quartz.dataSource.qzDS.password:root
org.quartz.dataSource.qzDS.maxConnection:10 

（1）MyJob

 

package com.liuzhihu.jdbctest;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/***
 * 
 * @author liuzhihu
 *
 */
public class MyJob implements Job {
	private static final Logger log = LoggerFactory.getLogger(MyJob.class);

	public void execute(JobExecutionContext context) throws JobExecutionException {
		log.info("MyJob  is start ..................");

		log.info("Hello quzrtz  " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss ").format(new Date()));

		log.info("MyJob  is end .....................");
	}

}

　　

（2）QuartzJdbcTest

 

package com.liuzhihu.jdbctest;

import java.text.ParseException;
import java.util.List;

import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

/***
 * 
 * @author liuzhihu
 *
 */
public class QuartzJdbcTest {

	public static void main(String[] args) throws SchedulerException, ParseException {
		startSchedule();
		// resumeJob();
	}

	/**
	 * 开始一个simpleSchedule()调度
	 */
	public static void startSchedule() {
		try {
			// 一、建立一个JobDetail实例，指定Quartz
			JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
					// 任务执行类
					.withIdentity("job1_1", "jGroup1")
					// 任务名，任务组
					.build();

			// 触发器类型
			SimpleScheduleBuilder builder = SimpleScheduleBuilder
					// 设置执行次数
					.repeatSecondlyForTotalCount(5);

			// CronScheduleBuilder builder =
			// CronScheduleBuilder.cronSchedule("0/2 * * * * ?");
			// 二、建立Trigger
			Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1_1", "tGroup1").startNow()
					.withSchedule(builder).build();

			// 三、建立Scheduler
			Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
			scheduler.start();
			// 四、调度执行
			scheduler.scheduleJob(jobDetail, trigger);
			try {
				Thread.sleep(60000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}

			// 一分钟后，关闭调度器
			scheduler.shutdown();

		} catch (SchedulerException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 从数据库中找到已经存在的job，并从新开户调度
	 */
	public static void resumeJob() {
		try {

			SchedulerFactory schedulerFactory = new StdSchedulerFactory();
			Scheduler scheduler = schedulerFactory.getScheduler();
			JobKey jobKey = new JobKey("job1_1", "jGroup1");
			List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
			// SELECT TRIGGER_NAME, TRIGGER_GROUP FROM {0}TRIGGERS WHERE
			// SCHED_NAME = {1} AND JOB_NAME = ? AND JOB_GROUP = ?
			// 从新恢复在jGroup1组中，名为job1_1的 job的触发器运行
			if (triggers.size() > 0) {
				for (Trigger tg : triggers) {
					// 根据类型判断
					if ((tg instanceof CronTrigger) || (tg instanceof SimpleTrigger)) {
						// 恢复job运行
						scheduler.resumeJob(jobKey);
					}
				}
				scheduler.start();
			}

		} catch (Exception e) {
			e.printStackTrace();

		}
	}
}

　　

运行结果： 

 

 

 

控制台打印： 

 

Cron和Simple类型，Simple类型的若是JobDetail没有设置.storeDurably(true)，则job在运行完成以后会在数据库中删除！

 

原文地址:http://blog.csdn.net/u010648555/article/details/54863394