天天看點
傳回

Quartz學習——Quartz簡單入門Demo（二）

要學習Quartz架構，首先大概了解了Quartz的基本知識後，在通過簡單的例子入門，一步一個腳印的走下去。

下面介紹Quartz入門的示例，由于Quartz的存儲方式分為RAM和JDBC，分别對這兩種進行簡單的說明。并附上代碼！

首先需要添加Quartz的Jar包 ，我使用的是quartz.2.2.1版本！

要學習Quartz架構，首先大概了解了Quartz的基本知識後，在通過簡單的例子入門，一步一個腳印的走下去。

下面介紹Quartz入門的示例，由于Quartz的存儲方式分為RAM和JDBC，分别對這兩種進行簡單的說明。并附上代碼！

Demo代碼下載下傳位址：quartz_demo

<!-- 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.dufy.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;

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）：QuartzTest

package com.dufy.learn;

import java.util.Date;

import org.quartz.CronScheduleBuilder;
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;

/**
 * This is a RAM Store Quartz!
 * @author dufy
 * @date 2017.02.04
 *
 */
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.dufy.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;

public class MyJob implements Job{
	private static final Logger log = LoggerFactory.getLogger(MyJob.class);

	@Override
	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.dufy.jdbctest;

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

import org.quartz.CronScheduleBuilder;
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.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;

public class QuartzJdbcTest {
	
	public static void main(String[] args) throws SchedulerException,
			ParseException {
		startSchedule();
		//resumeJob();
	}
	/**
	 * 開始一個simpleSchedule()排程
	 */
	public static void startSchedule() {
		try {
			// 1、建立一個JobDetail執行個體，指定Quartz
			JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
			// 任務執行類
					.withIdentity("job1_1", "jGroup1")
					// 任務名，任務組
					.build();
		
			
			//觸發器類型
			SimpleScheduleBuilder builder = SimpleScheduleBuilder
					// 設定執行次數
				    .repeatSecondlyForTotalCount(5);
			
			//CronScheduleBuilder builder = CronScheduleBuilder.cronSchedule("0/2 * * * * ?");
			// 2、建立Trigger
			Trigger trigger = TriggerBuilder.newTrigger()
					.withIdentity("trigger1_1", "tGroup1").startNow()
					.withSchedule(builder)
					.build();
			
			// 3、建立Scheduler
			Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
			scheduler.start();
			// 4、排程執行
			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在運作完成之後會在資料庫中删除！

歡迎通路我的csdn部落格，我們一同成長！

"不管做什麼，隻要堅持下去就會看到不一樣！在路上，不卑不亢!"

部落格首頁：http://blog.csdn.net/u010648555

版權聲明

作者：阿飛雲

出處：部落格園阿飛雲的技術部落格--http://www.cnblogs.com/aflyun

您的支援是對部落客最大的鼓勵，感謝您的認真閱讀。

本文版權歸作者所有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接配接，否則保留追究法律責任的權利。

Quartz系列 Quartz示例 Quartz入門 Quartz demo
上一篇: Quartz源碼——JobStore儲存JonDetail和Trigger源碼分析（一）
下一篇: Quartz源碼——QuartzSchedulerThread.run() 源碼分析（三）

繼續閱讀