2. 程式人生 > >Java定時任務Quartz一

Java定時任務Quartz一

阿新 • • 發佈：2019-02-03

1.概要

      Quartz是由OpenSymphony提供的強大的開源任務排程框架。官網地址：http://www.quartz-scheduler.org/，純Java實現。

  • 強大的排程功能：很容易與Spring整合，提供排程執行環境的持久化機制，儲存並恢復任務排程現場。即使系統因故障關閉，任務排程現場資料也不會丟失；
  • 靈活的應用方式：允許靈活的定義觸發器的排程時間表，並可以對觸發器和任務進行關聯對映，提供了元件式的監聽器、各種外掛、執行緒池等功能，支援任務和排程的多種組合方式、支援排程資料的多種儲存方式，支援分散式和叢集操作；
  • 主要用到的設計模式：Builder模式、Factory模式、元件模式、鏈式寫法；
  • 核心概念：排程器——負責定期、定時、定頻率的去執行任務；任務——具體的業務邏輯；觸發器——排程器排程任務的時間；
  • 重要組成：Job——介面且可以接收引數；JobDetail——Job的實現類和相關的靜態資訊；JobBuilder——定義或者建立JobDetail的例項；JobStore——用來儲存Job資料；Trigger——描述觸發Job執行時的時間觸發規則；TriggerBuilder——定義或者建立觸發器的例項；ThreadPool——執行緒池Job執行的基礎設施；Scheduler——Quartz獨立執行的容器；Calendar——一個Trigger可以和多個Calendar關聯，以排除或者包含某些時間點；監聽器——JobListener、TriggerListener、SchedulerLIstener監聽對應的元件。

2.Quartz的基本使用

1.每兩秒鐘列印一次Hello World：

建立Job實現類HelloJob

package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class HelloJob implements Job{
	@Override
	public void execute(JobExecutionContext arg0) throws JobExecutionException {
		//列印當前執行時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("任務執行時間為:"+sf.format(startTime));
		System.out.println("Hello World");
	}
}

建立Job測試類HelloScheduler

package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
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;
public class HelloScheduler {
	public static void main(String[] args) throws SchedulerException {
		// 建立一個JobDetail例項與HelloJob類繫結
		JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
		// 建立一個Trigger例項，定義該Job立即執行，且每隔兩秒鐘執行一次直到永遠
		Trigger trigger = TriggerBuilder.newTrigger().withIdentity("mtTrigger", "group1").startNow()
				.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
		//建立scheduler例項
		SchedulerFactory sFactory = new StdSchedulerFactory();
		Scheduler scheduler = sFactory.getScheduler();
		scheduler.start();
		//列印當前時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("列印當前時間:"+sf.format(startTime));
		scheduler.scheduleJob(jobDetail,trigger);
	}
}
2.淺談Job&JobDetail

     Job:實現業務邏輯的任務介面，job介面非常容易實現，只有一個execute方法，類似TimerTask的run方法，在裡面編寫業務邏輯。Job在Quartz中的生命週期：每次排程器執行Job時，它在呼叫execute方法前會建立一個新Job例項；當呼叫完成後，關聯的job物件例項會被釋放，釋放的例項會被垃圾回收機制回收。JobDetail為job提供了很多設定屬性name、group、jobClass、jobDataMap（用來儲存特定Job例項的狀態資訊），排程器需要藉助JobDetail物件來新增Job例項。

package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
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;
public class HelloScheduler {
	public static void main(String[] args) throws SchedulerException {
		// 建立一個JobDetail例項與HelloJob類繫結
		JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
		System.out.println("JobDetail's name:"+jobDetail.getKey().getName());
		System.out.println("JobDetail's group:"+jobDetail.getKey().getGroup());
		System.out.println("JobDetail's jobClass:"+jobDetail.getJobClass().getName());
		// 建立一個Trigger例項，定義該Job立即執行，且每隔兩秒鐘執行一次直到永遠
		Trigger trigger = TriggerBuilder.newTrigger().withIdentity("mtTrigger", "group1").startNow()
				.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
		//建立scheduler例項
		SchedulerFactory sFactory = new StdSchedulerFactory();
		Scheduler scheduler = sFactory.getScheduler();
		scheduler.start();
		//列印當前時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("列印當前時間:"+sf.format(startTime));
		scheduler.scheduleJob(jobDetail,trigger);
	}
}
3.淺談JobExecutionContext&JobDataMap

      當Schedule呼叫一個Job，就會將JobExecutionContext傳遞給Job的execute方法；Job能通過JobExecutionContext物件訪問到Quartz執行時的環境以及Job本身的明細資料。在進行任務排程時，JobDataMap儲存在JobExecutionContext中，非常方便獲取；JobDataMap可以用來裝載任何可序列化的資料物件，當job例項物件被執行時這些引數物件會傳遞給它；JobDataMap實現了JDK的Map介面，並且添加了一些非常方便的方法用來存取基本資料型別。獲取JobDataMap的兩種方式：

  • 從Map中直接獲取，示例程式碼如下Job：
package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;
public class HelloJob implements Job{
	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		//列印當前執行時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("任務執行時間為:"+sf.format(startTime));
		JobKey key = context.getJobDetail().getKey();
		System.out.println("My job name and group are:"+key.getName()+":"+key.getGroup());
		TriggerKey triggerKey = context.getTrigger().getKey();
		System.out.println("My trigger name and group are:"+triggerKey.getName()+":"+triggerKey.getGroup());
		JobDataMap jobMap = context.getJobDetail().getJobDataMap();
		JobDataMap triggerMap = context.getTrigger().getJobDataMap();
//		JobDataMap dataMap = context.getMergedJobDataMap(); //獲取合併處理後的引數集合
		String jobMsg = jobMap.getString("message");
		Float floatValue = jobMap.getFloat("float");
		String triggerMsg = triggerMap.getString("triggerMsg");
		Double doubleValue = triggerMap.getDouble("double");
		System.out.println("My job params are:"+jobMsg+":"+floatValue);
		System.out.println("My trigger params are:"+triggerMsg+":"+doubleValue);
	}
}

示例程式碼Schedule：

package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
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;
public class HelloScheduler {
	public static void main(String[] args) throws SchedulerException {
		// 建立一個JobDetail例項與HelloJob類繫結
		JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").
				usingJobData("message", "Hello MyJob1").usingJobData("float", 3.14F).build();
		
		//如果傳遞引數過程中key相同，則trigger的引數值會覆蓋jobdetail裡面的引數值
		// 建立一個Trigger例項，定義該Job立即執行，且每隔兩秒鐘執行一次直到永遠
		Trigger trigger = TriggerBuilder.newTrigger().withIdentity("mtTrigger", "group1").
				usingJobData("triggerMsg", "Hello MyTrigger1").usingJobData("double", 2.0D).
				startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().
						withIntervalInSeconds(2).repeatForever()).build();
		//建立scheduler例項
		SchedulerFactory sFactory = new StdSchedulerFactory();
		Scheduler scheduler = sFactory.getScheduler();
		scheduler.start();
		//列印當前時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("列印當前時間:"+sf.format(startTime));
		scheduler.scheduleJob(jobDetail,trigger);
	}
}
  • Job實現類中新增setter方法對應JobDataMap的鍵值(Quartz框架預設的JobFactory實現類在初始化Job例項物件時會自動地呼叫這些setter方法)，如下程式碼所示Job：
package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;
public class HelloJob implements Job{
	private String message;
	private Float floatValue;
	private Double doubleValue;
	
	public String getMessage() {
		return message;
	}
	public void setMessage(String message) {
		this.message = message;
	}
	public Float getFloatValue() {
		return floatValue;
	}
	public void setFloatValue(Float floatValue) {
		this.floatValue = floatValue;
	}
	public Double getDoubleValue() {
		return doubleValue;
	}
	public void setDoubleValue(Double doubleValue) {
		this.doubleValue = doubleValue;
	}
	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		//列印當前執行時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("任務執行時間為:"+sf.format(startTime));
		JobKey key = context.getJobDetail().getKey();
		System.out.println("My job name and group are:"+key.getName()+":"+key.getGroup());
		TriggerKey triggerKey = context.getTrigger().getKey();
		System.out.println("My trigger name and group are:"+triggerKey.getName()+":"+triggerKey.getGroup());
		System.out.println("Message is:"+message);
		System.out.println("Float is:"+floatValue);
		System.out.println("Double is:"+doubleValue);
	}
}

示例程式碼Schedule：

package com.luna.timer.quarts;
import java.text.SimpleDateFormat;
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;
public class HelloScheduler {
	public static void main(String[] args) throws SchedulerException {
		// 建立一個JobDetail例項與HelloJob類繫結
		JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").
				usingJobData("message", "Hello MyJob1").usingJobData("floatValue", 3.14F).build();
		
		//如果傳遞引數過程中key相同，則trigger的引數值會覆蓋jobdetail裡面的引數值
		// 建立一個Trigger例項，定義該Job立即執行，且每隔兩秒鐘執行一次直到永遠
		Trigger trigger = TriggerBuilder.newTrigger().withIdentity("mtTrigger", "group1").
				usingJobData("triggerMsg", "Hello MyTrigger1").usingJobData("doubleValue", 2.0D).
				startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().
						withIntervalInSeconds(2).repeatForever()).build();
		//建立scheduler例項
		SchedulerFactory sFactory = new StdSchedulerFactory();
		Scheduler scheduler = sFactory.getScheduler();
		scheduler.start();
		//列印當前時間
		Date startTime = new Date();
		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		System.out.println("列印當前時間:"+sf.format(startTime));
		scheduler.scheduleJob(jobDetail,trigger);
	}
}

相關推薦

Java定時任務Quartz一

1.概要      Quartz是由OpenSymphony提供的強大的開源任務排程框架。官網地址：http://www.quartz-scheduler.org/，純Java實現。強大的排程功能：很容

java定時任務 Quartz時間配置

 java Quartz定時器任務與Spring task定時的幾種實現 基於java 的定時任務實現， Quartz 時間詳細配置    請查閱   http://www.cnblogs.com/sihuanian/p/5010872.html

Java 定時任務執行(一):定時器 Timer 的使用.

https://www.ibm.com/developerworks/cn/java/j-lo-taskschedule/   閱讀目錄 一、概念 二、Timer類注意事項 三、scheduleAtFixedRate(TimerTask task,Date f

Java定時任務Quartz二

1.Trigger通用屬性      Trigger的觸發器通用屬性：JobKey——job例項的標識，觸發器被觸發時，該指定的job例項會執行；StartTime——表示觸發器的時間表首次被觸發的時間，它的值的型別是Java.util.Date；EndTime——指定觸發器

Java定時任務工具Quartz——學習筆記（一）

最近在準備做一個生日提醒的Demo，於是有了這篇部落格。咳咳，雖然可以在手機日曆設定提醒，但是我們要有自力更生的覺悟以及能力，自己能做當然用自己的嘛。 一、初步瞭解 百度百科是這樣介紹Quartz這個專案的。 Quartz可以用來建立簡單或為執行

Quartz定時任務框架(一) 入門案例

介紹 Quartz是一套支援時間排程的框架，官網http://www.quartz-scheduler.org/, jar 包下載，點這裡 入門案例 1. quartz.properties檔案 這個檔案不是必須建立的，如果需要建立使用，必須建立在ca

atititt java定時任務框架選型Spring Quartz 註解總結

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

Java定時任務Timer排程器【一】 原始碼分析（圖文詳解版）

就以鬧鐘的例子開頭吧（後續小節皆以鬧鐘為例，所有原始碼只列關鍵部分）。 public class ScheduleDemo { public static void main(String[] args) throws InterruptedException {

Quartz cron 表示式(linux 定時器，java 定時任務，spring task定時任務)

原文地址：https://blog.csdn.net/feng27156/article/details/39293403 Quartz cron 表示式的格式十分類似於 UNIX cron 格式，但還是有少許明顯的區別。區別之一就是 Quartz 的格式向下支援到秒級別的計劃，而 UNIX cron 計劃

java-定時任務排程工具Timer/Quartz|springboot整合定時排程

什麼是定時任務排程 定時任務排程：基於給定的時間點，給定的時間間隔或者給定的執行次數自動執行任務。 兩種java定時任務排程工具卻別 Timer Quartz 小弟!功能簡單,開銷小 大

SpringCloud之java定時器quartz定時任務cron表示式

quartz定時任務cron表示式例子： 0 * * * * ? 每1分鐘觸發一次 0 0 * * * ? 每天每1小時觸發一次 0 0 10 * * ? 每天10點觸發一次 0 * 14 * * ?

java web定時任務---quartz

寫在前面: 　　前面有簡單的記錄下Timer定時的用法，但是在此次專案中，選擇的是quartz來完成定時操作任務的。兩者都可以完成定時操作,但是spring可以整合quartz，並且配置起來也比較簡便，還可以同時跑多個任務。就選擇了quartz,quartz的用法也很強大，

java版定時任務quartz【石英鐘】

我的疑問？ 怎麼實現job和trigger的可配置呢？ 例如我想執行一個類，但是呢？如果這個類定義了，是不是就固定了？除非可以額外傳引數，google下真的可以傳引數。【How to pass i

Quartz使用-入門使用(java定時任務實現)

Quartz是一個大名鼎鼎的Java版開源定時排程器，功能強悍，使用方便。 一、核心概念 Quartz的原理不是很複雜，只要搞明白幾個概念，然後知道如何去啟動和關閉一個排程程式即可。 1、Job 表示一個工作，要執行的具體內容。此介面中只有一個方法 void e

Spring+Quartz實現動態新增定時任務（一）

在最近工作中，由於涉及到定時任務特別多，而這些工作又是由下屬去完成的，在生成環境中經常會出現業務邏輯錯誤，分析下來多數是定時任務執行問題，所以就希望把定時任務優化一下，主要實現2個方面1.定時任務動態配置及持久化2.視覺化的管理介面，可以非常清晰的管理自己的所有定時任務首先，

[BAT][JAVA]定時任務之-Quartz使用篇

 定時任務之-Quartz使用篇         Quartz是OpenSymphony開源組織在Job scheduling領域又一個開源專案,它可以與J2EE與J2SE應用程式相結合也可以單獨使用。Quartz可以用來建立簡單或為執行十個，百個，甚至是好幾萬個Jobs這

Java定時任務排程工具詳解（5）— Quartz 之 Trigger

五、淺談Trigger Trigger是什麼 Quartz中的觸發器用來告訴排程程式作業什麼時候觸發 即Trigger物件是用來觸發執行Job的 Quartz框架中的Trigger示意圖 觸發器通用屬性 JobKey：表示job例項的標識，觸發

Java定時任務Timer和Quartz

定時任務排程 基於給定的時間點，給定的時間間隔或者給定的執行次數自動執行的任務 定時任務工具 Timer Quartz Timer能完成一些簡單的定時任務，能實現具體某個時間執行任務。只有一個後臺執行定時任務。 Quartz能實

Java Web實現定時任務quartz方式

<servlet>     <servlet-name>QuartzInitializer</servlet-name>     <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet<

[譯]Java定時任務排程-Quartz文件（九）Job Stores

JobStore主要是追蹤排程過程中所有的資料，包括jobs、triggers、calendars等等。為Quartz Scheduler選擇合適的JobStore是很重要的。幸運的是，一旦瞭解了JobStore的區別，這是一件很簡單的事。一般在Schedule