定時(shí)任務(wù)，是指定一個(gè)未來(lái)的時(shí)間范圍執(zhí)行一定任務(wù)的功能。在當(dāng)前WEB應(yīng)用中，多數(shù)應(yīng)用都具備任務(wù)調(diào)度功能，針對(duì)不同的語(yǔ)音，不同的操作系統(tǒng)， 都有其自己的語(yǔ)法及解決方案，windows操作系統(tǒng)把它叫做任務(wù)計(jì)劃，linux中cron服務(wù)都提供了這個(gè)功能，在我們開(kāi)發(fā)業(yè)務(wù)系統(tǒng)中很多時(shí)候會(huì)涉及到這個(gè)功能。本場(chǎng)chat將使用java語(yǔ)言完成日常開(kāi)發(fā)工作中常用定時(shí)任務(wù)的使用，希望給大家工作及學(xué)習(xí)帶來(lái)幫助。

一、定時(shí)任務(wù)場(chǎng)景

（1）驅(qū)動(dòng)處理工作流程

作為一個(gè)新的預(yù)支付訂單被初始化放置，如果該訂單在指定時(shí)間內(nèi)未進(jìn)行支付，則將被認(rèn)為超時(shí)訂單進(jìn)行關(guān)閉處理；電商系統(tǒng)中應(yīng)用較多，用戶購(gòu)買商品產(chǎn)生訂單，但未進(jìn)行支付，訂單產(chǎn)生30分鐘內(nèi)未支付將關(guān)閉訂單（且滿足該場(chǎng)景數(shù)量龐大），不可能采用人工干預(yù)。

（2）系統(tǒng)維護(hù)

調(diào)度工作將獲取系統(tǒng)異常日志，及某些關(guān)鍵點(diǎn)數(shù)據(jù)存儲(chǔ)到數(shù)據(jù)庫(kù)中，每個(gè)工作日（節(jié)假日除外平日）在11:30 PM轉(zhuǎn)儲(chǔ)到數(shù)據(jù)庫(kù)，且生成一個(gè)XML文件發(fā)送至某位員工郵箱。

（3）在應(yīng)用程序內(nèi)提供提醒服務(wù)。

系統(tǒng)定時(shí)提醒登錄用戶某時(shí)間點(diǎn)執(zhí)行相關(guān)工作。

（4）定時(shí)對(duì)賬任務(wù)

公司與三方公司（運(yùn)營(yíng)商，銀行等）業(yè)務(wù)，每天零點(diǎn)后進(jìn)行當(dāng)天業(yè)務(wù)的對(duì)賬，將對(duì)賬信息結(jié)果數(shù)據(jù)發(fā)送至相關(guān)負(fù)責(zé)人郵箱，第二天工作時(shí)間進(jìn)行處理不匹配數(shù)據(jù)。

（5）數(shù)據(jù)統(tǒng)計(jì)

數(shù)據(jù)記錄較多，實(shí)時(shí)從數(shù)據(jù)庫(kù)讀取查詢會(huì)產(chǎn)生一定時(shí)間，為客戶體驗(yàn)及性能需要，故每周（天，小時(shí)）將數(shù)據(jù)進(jìn)行匯總，從而在展示數(shù)據(jù)時(shí)能夠快速的呈現(xiàn)數(shù)據(jù)。

使用定時(shí)任務(wù)的場(chǎng)景還有很多... 看來(lái)定時(shí)任務(wù)在我們?nèi)粘５拈_(kāi)發(fā)中真的應(yīng)用很廣泛...

二、主流定時(shí)任務(wù)技術(shù)講解 Timer

相信大家都已經(jīng)非常熟悉 java.util.Timer 了，它是最簡(jiǎn)單的一種實(shí)現(xiàn)任務(wù)調(diào)度的方法，下面給出一個(gè)具體的例子：

package com.ibm.scheduler; 
 import java.util.Timer; 
 import java.util.TimerTask; 

 public class TimerTest extends TimerTask { 

 private String jobName = ""; 

 public TimerTest(String jobName) { 
  super(); 
  this.jobName = jobName; 
 } 

 @Override 
 public void run() { 
 System.out.println("execute " + jobName); 
 } 

 public static void main(String[] args) { 
  Timer timer = new Timer(); 
  long delay1 = 1 * 1000; 
  long period1 = 1000; 
  // 從現(xiàn)在開(kāi)始 1 秒鐘之后，每隔 1 秒鐘執(zhí)行一次 job1 
  timer.schedule(new TimerTest("job1"), delay1, period1); 
  long delay2 = 2 * 1000; 
  long period2 = 2000; 
  // 從現(xiàn)在開(kāi)始 2 秒鐘之后，每隔 2 秒鐘執(zhí)行一次 job2 
  timer.schedule(new TimerTest("job2"), delay2, period2); 
  } 
 }

/**
輸出結(jié)果:
execute job1
execute job1
execute job2
execute job1
execute job1
execute job2
*/

使用 Timer 實(shí)現(xiàn)任務(wù)調(diào)度的核心類是 Timer 和 TimerTask。其中 Timer 負(fù)責(zé)設(shè)定 TimerTask 的起始與間隔執(zhí)行時(shí)間。使用者只需要?jiǎng)?chuàng)建一個(gè) TimerTask 的繼承類，實(shí)現(xiàn)自己的 run 方法，然后將其丟給 Timer 去執(zhí)行即可。Timer 的設(shè)計(jì)核心是一個(gè) TaskList 和一個(gè) TaskThread。Timer 將接收到的任務(wù)丟到自己的 TaskList 中，TaskList 按照 Task 的最初執(zhí)行時(shí)間進(jìn)行排序。TimerThread 在創(chuàng)建 Timer 時(shí)會(huì)啟動(dòng)成為一個(gè)守護(hù)線程。這個(gè)線程會(huì)輪詢所有任務(wù)，找到一個(gè)最近要執(zhí)行的任務(wù)，然后休眠，當(dāng)?shù)竭_(dá)最近要執(zhí)行任務(wù)的開(kāi)始時(shí)間點(diǎn)，TimerThread 被喚醒并執(zhí)行該任務(wù)。之后 TimerThread 更新最近一個(gè)要執(zhí)行的任務(wù)，繼續(xù)休眠。

Timer 的優(yōu)點(diǎn)在于簡(jiǎn)單易用，但由于所有任務(wù)都是由同一個(gè)線程來(lái)調(diào)度，因此所有任務(wù)都是串行執(zhí)行的，同一時(shí)間只能有一個(gè)任務(wù)在執(zhí)行，前一個(gè)任務(wù)的延遲或異常都將會(huì)影響到之后的任務(wù)（這點(diǎn)需要注意）。

ScheduledExecutor

鑒于 Timer 的上述缺陷，Java 5 推出了基于線程池設(shè)計(jì)的 ScheduledExecutor。其設(shè)計(jì)思想是，每一個(gè)被調(diào)度的任務(wù)都會(huì)由線程池中一個(gè)線程去執(zhí)行，因此任務(wù)是并發(fā)執(zhí)行的，相互之間不會(huì)受到干擾。需 要注意的是，只有當(dāng)任務(wù)的執(zhí)行時(shí)間到來(lái)時(shí)，ScheduedExecutor 才會(huì)真正啟動(dòng)一個(gè)線程，其余時(shí)間 ScheduledExecutor 都是在輪詢?nèi)蝿?wù)的狀態(tài)。

package com.ibm.scheduler;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledExecutorTest implements Runnable {
 private String jobName = "";

 public ScheduledExecutorTest(String jobName) {
  super();
  this.jobName = jobName;
 }

 @Override
 public void run() {
  System.out.println("execute " + jobName);
 }

 public static void main(String[] args) {
  ScheduledExecutorService service = Executors.newScheduledThreadPool(10);

  long initialDelay1 = 1;
  long period1 = 1;
  // 從現(xiàn)在開(kāi)始1秒鐘之后，每隔1秒鐘執(zhí)行一次job1
  service.scheduleAtFixedRate(
    new ScheduledExecutorTest("job1"), initialDelay1,
    period1, TimeUnit.SECONDS);

  long initialDelay2 = 1;
  long delay2 = 1;
  // 從現(xiàn)在開(kāi)始2秒鐘之后，每隔2秒鐘執(zhí)行一次job2
  service.scheduleWithFixedDelay(
    new ScheduledExecutorTest("job2"), initialDelay2,
    delay2, TimeUnit.SECONDS);
 }
}

/**
輸出結(jié)果:
execute job1
execute job1
execute job2
execute job1
execute job1
execute job2
*/

上述代碼展示了 ScheduledExecutorService 中兩種最常用的調(diào)度方法 ScheduleAtFixedRate 和 ScheduleWithFixedDelay。ScheduleAtFixedRate 每次執(zhí)行時(shí)間為上一次任務(wù)開(kāi)始起向后推一個(gè)時(shí)間間隔，即每次執(zhí)行時(shí)間為 :initialDelay, initialDelay+period, initialDelay+2*period, … ScheduleWithFixedDelay每次執(zhí)行時(shí)間為上一次任務(wù)結(jié)束起向后推一個(gè)時(shí)間間隔，即每次執(zhí)行時(shí)間為：initialDelay, initialDelay+executeTime+delay, initialDelay+2*executeTime+2*delay。由此可見(jiàn)，ScheduleAtFixedRate 是基于固定時(shí)間間隔進(jìn)行任務(wù)調(diào)度，ScheduleWithFixedDelay 取決于每次任務(wù)執(zhí)行的時(shí)間長(zhǎng)短，是基于不固定時(shí)間間隔進(jìn)行任務(wù)調(diào)度。

用 ScheduledExecutor 和 Calendar 實(shí)現(xiàn)復(fù)雜任務(wù)調(diào)度

Timer 和 ScheduledExecutor 都僅能提供基于開(kāi)始時(shí)間與重復(fù)間隔的任務(wù)調(diào)度，不能勝任更加復(fù)雜的調(diào)度需求。比如，設(shè)置每星期二的 16:38:10 執(zhí)行任務(wù)。該功能使用 Timer 和 ScheduledExecutor 都不能直接實(shí)現(xiàn)，但我們可以借助 Calendar 間接實(shí)現(xiàn)該功能。

package com.ibm.scheduler;

import java.util.Calendar;
import java.util.Date;
import java.util.TimerTask;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledExceutorTest2 extends TimerTask {

 private String jobName = "";

 public ScheduledExceutorTest2(String jobName) {
  super();
  this.jobName = jobName;
 }

 @Override
 public void run() {
  System.out.println("Date = "+new Date()+", execute " + jobName);
 }

 /**
  * 計(jì)算從當(dāng)前時(shí)間currentDate開(kāi)始，滿足條件dayOfWeek, hourOfDay, 
  * minuteOfHour, secondOfMinite的最近時(shí)間
  * @return
  */
 public Calendar getEarliestDate(Calendar currentDate, int dayOfWeek,
   int hourOfDay, int minuteOfHour, int secondOfMinite) {
  //計(jì)算當(dāng)前時(shí)間的WEEK_OF_YEAR,DAY_OF_WEEK, HOUR_OF_DAY, MINUTE,SECOND等各個(gè)字段值
  int currentWeekOfYear = currentDate.get(Calendar.WEEK_OF_YEAR);
  int currentDayOfWeek = currentDate.get(Calendar.DAY_OF_WEEK);
  int currentHour = currentDate.get(Calendar.HOUR_OF_DAY);
  int currentMinute = currentDate.get(Calendar.MINUTE);
  int currentSecond = currentDate.get(Calendar.SECOND);

  //如果輸入條件中的dayOfWeek小于當(dāng)前日期的dayOfWeek,則WEEK_OF_YEAR需要推遲一周
  boolean weekLater = false;
  if (dayOfWeek < currentDayOfWeek) {
   weekLater = true;
  } else if (dayOfWeek == currentDayOfWeek) {
   //當(dāng)輸入條件與當(dāng)前日期的dayOfWeek相等時(shí)，如果輸入條件中的
   //hourOfDay小于當(dāng)前日期的
   //currentHour，則WEEK_OF_YEAR需要推遲一周 
   if (hourOfDay < currentHour) {
    weekLater = true;
   } else if (hourOfDay == currentHour) {
     //當(dāng)輸入條件與當(dāng)前日期的dayOfWeek, hourOfDay相等時(shí)，
     //如果輸入條件中的minuteOfHour小于當(dāng)前日期的
    //currentMinute，則WEEK_OF_YEAR需要推遲一周
    if (minuteOfHour < currentMinute) {
     weekLater = true;
    } else if (minuteOfHour == currentSecond) {
      //當(dāng)輸入條件與當(dāng)前日期的dayOfWeek, hourOfDay， 
      //minuteOfHour相等時(shí)，如果輸入條件中的
     //secondOfMinite小于當(dāng)前日期的currentSecond，
     //則WEEK_OF_YEAR需要推遲一周
     if (secondOfMinite < currentSecond) {
      weekLater = true;
     }
    }
   }
  }
  if (weekLater) {
   //設(shè)置當(dāng)前日期中的WEEK_OF_YEAR為當(dāng)前周推遲一周
   currentDate.set(Calendar.WEEK_OF_YEAR, currentWeekOfYear + 1);
  }
  // 設(shè)置當(dāng)前日期中的DAY_OF_WEEK,HOUR_OF_DAY,MINUTE,SECOND為輸入條件中的值。
  currentDate.set(Calendar.DAY_OF_WEEK, dayOfWeek);
  currentDate.set(Calendar.HOUR_OF_DAY, hourOfDay);
  currentDate.set(Calendar.MINUTE, minuteOfHour);
  currentDate.set(Calendar.SECOND, secondOfMinite);
  return currentDate;

 }

 public static void main(String[] args) throws Exception {

  ScheduledExceutorTest2 test = new ScheduledExceutorTest2("job1");
  //獲取當(dāng)前時(shí)間
  Calendar currentDate = Calendar.getInstance();
  long currentDateLong = currentDate.getTime().getTime();
  System.out.println("Current Date = " + currentDate.getTime().toString());
  //計(jì)算滿足條件的最近一次執(zhí)行時(shí)間
  Calendar earliestDate = test
    .getEarliestDate(currentDate, 3, 16, 38, 10);
  long earliestDateLong = earliestDate.getTime().getTime();
  System.out.println("Earliest Date = "
    + earliestDate.getTime().toString());
  //計(jì)算從當(dāng)前時(shí)間到最近一次執(zhí)行時(shí)間的時(shí)間間隔
  long delay = earliestDateLong - currentDateLong;
  //計(jì)算執(zhí)行周期為一星期
  long period = 7 * 24 * 60 * 60 * 1000;
  ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
  //從現(xiàn)在開(kāi)始delay毫秒之后，每隔一星期執(zhí)行一次job1
  service.scheduleAtFixedRate(test, delay, period,
    TimeUnit.MILLISECONDS);
 }
}

/**
輸出結(jié)果:
Current Date = Wed Feb 02 17:32:01 CST 2011
Earliest Date = Tue Feb 8 16:38:10 CST 2011
Date = Tue Feb 8 16:38:10 CST 2011, execute job1
Date = Tue Feb 15 16:38:10 CST 2011, execute job1
*/

上述代碼實(shí)現(xiàn)了每星期二 16:38:10 調(diào)度任務(wù)的功能。其核心在于根據(jù)當(dāng)前時(shí)間推算出最近一個(gè)星期二 16:38:10 的絕對(duì)時(shí)間，然后計(jì)算與當(dāng)前時(shí)間的時(shí)間差，作為調(diào)用 ScheduledExceutor 函數(shù)的參數(shù)。計(jì)算最近時(shí)間要用到 java.util.calendar 的功能。首先需要解釋 calendar 的一些設(shè)計(jì)思想。Calendar 有以下幾種唯一標(biāo)識(shí)一個(gè)日期的組合方式：

引用

YEAR + MONTH + DAY_OF_MONTH

YEAR + MONTH + WEEK_OF_MONTH + DAY_OF_WEEK

YEAR + MONTH + DAY_OF_WEEK_IN_MONTH + DAY_OF_WEEK

YEAR + DAY_OF_YEAR

YEAR + DAY_OF_WEEK + WEEK_OF_YEAR

上述組合分別加上 HOUROFDAY + MINUTE + SECOND 即為一個(gè)完整的時(shí)間標(biāo)識(shí)。

上述DEMO采用了最后一種組合方式。輸入為 DAY_OF_WEEK, HOUR_OF_DAY, MINUTE, SECOND 以及當(dāng)前日期 , 輸出為一個(gè)滿足 DAY_OF_WEEK, HOUR_OF_DAY, MINUTE, SECOND 并且距離當(dāng)前日期最近的未來(lái)日期。計(jì)算的原則是從輸入的 DAY_OF_WEEK 開(kāi)始比較，如果小于當(dāng)前日期的 DAY_OF_WEEK，則需要向 WEEK_OF_YEAR 進(jìn)一， 即將當(dāng)前日期中的 WEEK_OF_YEAR 加一并覆蓋舊值；如果等于當(dāng)前的 DAY_OF_WEEK, 則繼續(xù)比較 HOUR_OF_DAY；如果大于當(dāng)前的 DAY_OF_WEEK，則直接調(diào)用 java.util.calenda 的 calendar.set(field, value) 函數(shù)將當(dāng)前日期的 DAY_OF_WEEK, HOUR_OF_DAY, MINUTE, SECOND 賦值為輸入值，依次類推，直到比較至 SECOND。我們可以根據(jù)輸入需求選擇不同的組合方式來(lái)計(jì)算最近執(zhí)行時(shí)間。

用上述方法實(shí)現(xiàn)該任務(wù)調(diào)度比較繁瑣，期待需要一個(gè)更加完善的任務(wù)調(diào)度工具來(lái)解決這些復(fù)雜的調(diào)度問(wèn)題。幸運(yùn)的是，開(kāi)源工具包 Quartz 在這方面展現(xiàn)了強(qiáng)大的能力。

Quartz

OpenSymphony開(kāi)源組織在Job scheduling領(lǐng)域又一個(gè)開(kāi)源項(xiàng)目，它可以與J2EE與J2SE應(yīng)用程序相結(jié)合也可以單獨(dú)使用。Quartz可以用來(lái)創(chuàng)建簡(jiǎn)單或?yàn)檫\(yùn)行十個(gè)，百個(gè)，甚至是好幾萬(wàn)個(gè)Jobs這樣復(fù)雜的程序。

先來(lái)看一個(gè)例子吧：

package com.test.quartz;

import static org.quartz.DateBuilder.newDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;

import java.util.GregorianCalendar;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.calendar.AnnualCalendar;

public class QuartzTest {

 public static void main(String[] args) {
  try {
   //創(chuàng)建scheduler
   Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

   //定義一個(gè)Trigger
   Trigger trigger = newTrigger().withIdentity("trigger1", "group1") //定義name/group
    .startNow()//一旦加入scheduler，立即生效
    .withSchedule(simpleSchedule() //使用SimpleTrigger
     .withIntervalInSeconds(1) //每隔一秒執(zhí)行一次
     .repeatForever()) //一直執(zhí)行，奔騰到老不停歇
    .build();

   //定義一個(gè)JobDetail
   JobDetail job = newJob(HelloQuartz.class) //定義Job類為HelloQuartz類，這是真正的執(zhí)行邏輯所在
    .withIdentity("job1", "group1") //定義name/group
    .usingJobData("name", "quartz") //定義屬性
    .build();

   //加入這個(gè)調(diào)度
   scheduler.scheduleJob(job, trigger);

   //啟動(dòng)之
   scheduler.start();

   //運(yùn)行一段時(shí)間后關(guān)閉
   Thread.sleep(10000);
   scheduler.shutdown(true);
  } catch (Exception e) {
   e.printStackTrace();
  }
 }
}
package com.test.quartz;

import java.util.Date;

import org.quartz.DisallowConcurrentExecution;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloQuartz implements Job {
 public void execute(JobExecutionContext context) throws JobExecutionException {
  JobDetail detail = context.getJobDetail();
  String name = detail.getJobDataMap().getString("name");
  System.out.println("say hello to " + name + " at " + new Date());
 }
}

通過(guò)以上例子：Quartz最重要的3個(gè)基本要素：

•Scheduler：調(diào)度器。所有的調(diào)度都是由它控制。

•Trigger： 定義觸發(fā)的條件。例子中，它的類型是SimpleTrigger，每隔1秒中執(zhí)行一次（什么是SimpleTrigger下面會(huì)有詳述）。

•JobDetail & Job： JobDetail 定義的是任務(wù)數(shù)據(jù)，而真正的執(zhí)行邏輯是在Job中，例子中是HelloQuartz。 為什么設(shè)計(jì)成JobDetail + Job，不直接使用Job？這是因?yàn)槿蝿?wù)是有可能并發(fā)執(zhí)行，如果Scheduler直接使用Job，就會(huì)存在對(duì)同一個(gè)Job實(shí)例并發(fā)訪問(wèn)的問(wèn)題。而JobDetail & Job 方式，sheduler每次執(zhí)行，都會(huì)根據(jù)JobDetail創(chuàng)建一個(gè)新的Job實(shí)例，這樣就可以規(guī)避并發(fā)訪問(wèn)的問(wèn)題。

Quartz API

Quartz的API的風(fēng)格在2.x以后，采用的是DSL風(fēng)格（通常意味著fluent interface風(fēng)格），就是示例中newTrigger()那一段東西。它是通過(guò)Builder實(shí)現(xiàn)的，就是以下幾個(gè)。（下面大部分代碼都要引用這些Builder )

//job相關(guān)的builder
import static org.quartz.JobBuilder.*;

//trigger相關(guān)的builder
import static org.quartz.TriggerBuilder.*;
import static org.quartz.SimpleScheduleBuilder.*;
import static org.quartz.CronScheduleBuilder.*;
import static org.quartz.DailyTimeIntervalScheduleBuilder.*;
import static org.quartz.CalendarIntervalScheduleBuilder.*;

//日期相關(guān)的builder
import static org.quartz.DateBuilder.*;DSL風(fēng)格寫起來(lái)會(huì)更加連貫，暢快，而且由于不是使用setter的風(fēng)格，語(yǔ)義上會(huì)更容易理解一些。對(duì)比一下：

JobDetail jobDetail=new JobDetailImpl("jobDetail1","group1",HelloQuartz.class);
jobDetail.getJobDataMap().put("name", "quartz");

SimpleTriggerImpl trigger=new SimpleTriggerImpl("trigger1","group1");
trigger.setStartTime(new Date());
trigger.setRepeatInterval(1);
trigger.setRepeatCount(-1);

關(guān)于name和group

JobDetail和Trigger都有name和group。

name是它們?cè)谶@個(gè)sheduler里面的唯一標(biāo)識(shí)。如果我們要更新一個(gè)JobDetail定義，只需要設(shè)置一個(gè)name相同的JobDetail實(shí)例即可。

group是一個(gè)組織單元，sheduler會(huì)提供一些對(duì)整組操作的API，比如 scheduler.resumeJobs()。

Trigger

在開(kāi)始詳解每一種Trigger之前，需要先了解一下Trigger的一些共性。

StartTime & EndTime

startTime和endTime指定的Trigger會(huì)被觸發(fā)的時(shí)間區(qū)間。在這個(gè)區(qū)間之外，Trigger是不會(huì)被觸發(fā)的。 所有Trigger都會(huì)包含這兩個(gè)屬性。

優(yōu)先級(jí)（Priority）

當(dāng)scheduler比較繁忙的時(shí)候，可能在同一個(gè)時(shí)刻，有多個(gè)Trigger被觸發(fā)了，但資源不足（比如線程池不足）。那么這個(gè)時(shí)候比剪刀石頭布更好的方式，就是設(shè)置優(yōu)先級(jí)。優(yōu)先級(jí)高的先執(zhí)行。 需要注意的是，優(yōu)先級(jí)只有在同一時(shí)刻執(zhí)行的Trigger之間才會(huì)起作用，如果一個(gè)Trigger是9:00，另一個(gè)Trigger是9:30。那么無(wú)論后一個(gè)優(yōu)先級(jí)多高，前一個(gè)都是先執(zhí)行。 優(yōu)先級(jí)的值默認(rèn)是5，當(dāng)為負(fù)數(shù)時(shí)使用默認(rèn)值。最大值似乎沒(méi)有指定，但建議遵循Java的標(biāo)準(zhǔn)，使用1-10，不然鬼才知道看到【優(yōu)先級(jí)為10】是時(shí)，上頭還有沒(méi)有更大的值。

Misfire（錯(cuò)失觸發(fā)）策略

類似的Scheduler資源不足的時(shí)候，或者機(jī)器崩潰重啟等，有可能某一些Trigger在應(yīng)該觸發(fā)的時(shí)間點(diǎn)沒(méi)有被觸發(fā)，也就是Miss Fire了。這個(gè)時(shí)候Trigger需要一個(gè)策略來(lái)處理這種情況。每種Trigger可選的策略各不相同。這里有兩個(gè)點(diǎn)需要重點(diǎn)注意：

MisFire的觸發(fā)是有一個(gè)閥值，這個(gè)閥值是配置在JobStore的。比RAMJobStore是org.quartz.jobStore.misfireThreshold。只有超過(guò)這個(gè)閥值，才會(huì)算MisFire。小于這個(gè)閥值，Quartz是會(huì)全部重新觸發(fā)。所有MisFire的策略實(shí)際上都是解答兩個(gè)問(wèn)題：

•已經(jīng)MisFire的任務(wù)還要重新觸發(fā)嗎？

•如果發(fā)生MisFire，要調(diào)整現(xiàn)有的調(diào)度時(shí)間嗎？

比如SimpleTrigger的MisFire策略有：

•MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY 這個(gè)不是忽略已經(jīng)錯(cuò)失的觸發(fā)的意思，而是說(shuō)忽略MisFire策略。它會(huì)在資源合適的時(shí)候，重新觸發(fā)所有的MisFire任務(wù)，并且不會(huì)影響現(xiàn)有的調(diào)度時(shí)間。比如，SimpleTrigger每15秒執(zhí)行一次，而中間有5分鐘時(shí)間它都MisFire了，一共錯(cuò)失了20個(gè)，5分鐘后，假設(shè)資源充足了，并且任務(wù)允許并發(fā)，它會(huì)被一次性觸發(fā)。這個(gè)屬性是所有Trigger都適用。

•MISFIRE_INSTRUCTION_FIRE_NOW 忽略已經(jīng)MisFire的任務(wù)，并且立即執(zhí)行調(diào)度。這通常只適用于只執(zhí)行一次的任務(wù)。

•MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT 將startTime設(shè)置當(dāng)前時(shí)間，立即重新調(diào)度任務(wù)，包括的MisFire的。

•MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_REMAINING_REPEAT_COUNT 類似MISFIREINSTRUCTIONRESCHEDULENOWWITHEXISTINGREPEAT_COUNT，區(qū)別在于會(huì)忽略已經(jīng)MisFire的任務(wù)。

•MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_EXISTING_COUNT 在下一次調(diào)度時(shí)間點(diǎn)，重新開(kāi)始調(diào)度任務(wù)，包括的MisFire的。

•MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT 類似于MISFIREINSTRUCTIONRESCHEDULENEXTWITHEXISTINGCOUNT，區(qū)別在于會(huì)忽略已經(jīng)MisFire的任務(wù)。

•MISFIRE_INSTRUCTION_SMART_POLICY 所有的Trigger的MisFire默認(rèn)值都是這個(gè)，大致意思是“把處理邏輯交給聰明的Quartz去決定”?；静呗允?。

•如果是只執(zhí)行一次的調(diào)度，使用MISFIRE_INSTRUCTION_FIRE_NOW。

•如果是無(wú)限次的調(diào)度(repeatCount是無(wú)限的)，使用MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT。

•否則，使用MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT MisFire的東西挺繁雜的，可以參考這篇。

Calendar

這里的Calendar不是jdk的java.util.Calendar，不是為了計(jì)算日期的。它的作用是在于補(bǔ)充Trigger的時(shí)間?？梢耘懦蚣尤肽骋恍┨囟ǖ臅r(shí)間點(diǎn)。

以”每月25日零點(diǎn)自動(dòng)還卡債“為例，我們想排除掉每年的2月25號(hào)零點(diǎn)這個(gè)時(shí)間點(diǎn)（因?yàn)橛?.14，所以2月一定會(huì)破產(chǎn)）。這個(gè)時(shí)間，就可以用Calendar來(lái)實(shí)現(xiàn)。

例子：

AnnualCalendar cal = new AnnualCalendar(); //定義一個(gè)每年執(zhí)行Calendar，精度為天，即不能定義到2.25號(hào)下午2:00
java.util.Calendar excludeDay = new GregorianCalendar();
excludeDay.setTime(newDate().inMonthOnDay(2, 25).build());
cal.setDayExcluded(excludeDay, true); //設(shè)置排除2.25這個(gè)日期
scheduler.addCalendar("FebCal", cal, false, false); //scheduler加入這個(gè)Calendar

//定義一個(gè)Trigger
Trigger trigger = newTrigger().withIdentity("trigger1", "group1") 
 .startNow()//一旦加入scheduler，立即生效
 .modifiedByCalendar("FebCal") //使用Calendar !!
 .withSchedule(simpleSchedule()
  .withIntervalInSeconds(1) 
  .repeatForever()) 
 .build();

Quartz體貼地為我們提供以下幾種Calendar，注意，所有的Calendar既可以是排除，也可以是包含，取決于：

•HolidayCalendar。指定特定的日期，比如20140613。精度到天。

•DailyCalendar。指定每天的時(shí)間段（rangeStartingTime, rangeEndingTime)，格式是HH:MM[:SS[:mmm]]。也就是最大精度可以到毫秒。

•WeeklyCalendar。指定每星期的星期幾，可選值比如為java.util.Calendar.SUNDAY。精度是天。

•MonthlyCalendar。指定每月的幾號(hào)。可選值為1-31。精度是天

•AnnualCalendar。 指定每年的哪一天。使用方式如上例。精度是天。

•CronCalendar。指定Cron表達(dá)式。精度取決于Cron表達(dá)式，也就是最大精度可以到秒。

Trigger實(shí)現(xiàn)類

Quartz有以下幾種Trigger實(shí)現(xiàn)：

SimpleTrigger

指定從某一個(gè)時(shí)間開(kāi)始，以一定的時(shí)間間隔（單位是毫秒）執(zhí)行的任務(wù)。它適合的任務(wù)類似于：9:00 開(kāi)始，每隔1小時(shí)，執(zhí)行一次。它的屬性有：

•repeatInterval 重復(fù)間隔

•repeatCount 重復(fù)次數(shù)。實(shí)際執(zhí)行次數(shù)是 repeatCount+1。因?yàn)樵趕tartTime的時(shí)候一定會(huì)執(zhí)行一次。下面有關(guān)repeatCount 屬性的都是同理。

例子：

CalendarIntervalTrigger

類似于SimpleTrigger，指定從某一個(gè)時(shí)間開(kāi)始，以一定的時(shí)間間隔執(zhí)行的任務(wù)。 但是不同的是SimpleTrigger指定的時(shí)間間隔為毫秒，沒(méi)辦法指定每隔一個(gè)月執(zhí)行一次（每月的時(shí)間間隔不是固定值），而CalendarIntervalTrigger支持的間隔單位有秒，分鐘，小時(shí)，天，月，年，星期。 相較于SimpleTrigger有兩個(gè)優(yōu)勢(shì)：1、更方便，比如每隔1小時(shí)執(zhí)行，你不用自己去計(jì)算1小時(shí)等于多少毫秒。 2、支持不是固定長(zhǎng)度的間隔，比如間隔為月和年。但劣勢(shì)是精度只能到秒。它適合的任務(wù)類似于：9:00 開(kāi)始執(zhí)行，并且以后每周 9:00 執(zhí)行一次。它的屬性有:

•interval 執(zhí)行間隔

•intervalUnit 執(zhí)行間隔的單位（秒，分鐘，小時(shí)，天，月，年，星期）

例子：

calendarIntervalSchedule()
 .withIntervalInDays(1) //每天執(zhí)行一次
 .build();

calendarIntervalSchedule()
 .withIntervalInWeeks(1) //每周執(zhí)行一次
 .build();

DailyTimeIntervalTrigger

指定每天的某個(gè)時(shí)間段內(nèi)，以一定的時(shí)間間隔執(zhí)行任務(wù)。并且它可以支持指定星期。它適合的任務(wù)類似于：指定每天9:00 至 18:00 ，每隔70秒執(zhí)行一次，并且只要周一至周五執(zhí)行。 它的屬性有:

•startTimeOfDay 每天開(kāi)始時(shí)間

•endTimeOfDay 每天結(jié)束時(shí)間

•daysOfWeek 需要執(zhí)行的星期

•interval 執(zhí)行間隔

•intervalUnit 執(zhí)行間隔的單位（秒，分鐘，小時(shí)，天，月，年，星期）

•repeatCount 重復(fù)次數(shù)

例子:

dailyTimeIntervalSchedule()
 .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00開(kāi)始
 .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(16, 0)) //16：00 結(jié)束 
 .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五執(zhí)行
 .withIntervalInHours(1) //每間隔1小時(shí)執(zhí)行一次
 .withRepeatCount(100) //最多重復(fù)100次（實(shí)際執(zhí)行100+1次）
 .build();

dailyTimeIntervalSchedule()
 .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00開(kāi)始
 .endingDailyAfterCount(10) //每天執(zhí)行10次，這個(gè)方法實(shí)際上根據(jù) startTimeOfDay+interval*count 算出 endTimeOfDay
 .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五執(zhí)行
 .withIntervalInHours(1) //每間隔1小時(shí)執(zhí)行一次
 .build();

CronTrigger

適合于更復(fù)雜的任務(wù)，它支持類型于Linux Cron的語(yǔ)法（并且更強(qiáng)大）?；旧纤采w了以上三個(gè)Trigger的絕大部分能力（但不是全部）—— 當(dāng)然，也更難理解。它適合的任務(wù)類似于：每天0:00,9:00,18:00各執(zhí)行一次。它的屬性只有：

Cron表達(dá)式

但這個(gè)表示式本身就夠復(fù)雜了。下面會(huì)有說(shuō)明。例子：

cronSchedule("0 0/2 8-17 * * ?") // 每天8:00-17:00，每隔2分鐘執(zhí)行一次
 .build();

cronSchedule("0 30 9 ? * MON") // 每周一，9:30執(zhí)行一次
.build();

weeklyOnDayAndHourAndMinute(MONDAY,9, 30) //等同于 0 30 9 ? * MON 
 .build();

Cron表達(dá)式

•星號(hào)()：可用在所有字段中，表示對(duì)應(yīng)時(shí)間域的每一個(gè)時(shí)刻，例如， 在分鐘字段時(shí)，表示“每分鐘”；

•問(wèn)號(hào)（?）：該字符只在日期和星期字段中使用，它通常指定為“無(wú)意義的值”，相當(dāng)于點(diǎn)位符；

•減號(hào)(-)：表達(dá)一個(gè)范圍，如在小時(shí)字段中使用“10-12”，則表示從10到12點(diǎn)，即10,11,12；

•逗號(hào)(,)：表達(dá)一個(gè)列表值，如在星期字段中使用“MON,WED,FRI”，則表示星期一，星期三和星期五；

•斜杠(/)：x/y表達(dá)一個(gè)等步長(zhǎng)序列，x為起始值，y為增量步長(zhǎng)值。如在分鐘字段中使用0/15，則表示為0,15,30和45秒，而5/15在分鐘字段中表示5,20,35,50，你也可以使用*/y，它等同于0/y；

•L：該字符只在日期和星期字段中使用，代表“Last”的意思，但它在兩個(gè)字段中意思不同。L在日期字段中，表示這個(gè)月份的最后一天，如一月的31號(hào)，非閏年二月的28號(hào)；如果L用在星期中，則表示星期六，等同于7。但是，如果L出現(xiàn)在星期字段里，而且在前面有一個(gè)數(shù)值X，則表示“這個(gè)月的最后X天”，例如，6L表示該月的最后星期五；

•W：該字符只能出現(xiàn)在日期字段里，是對(duì)前導(dǎo)日期的修飾，表示離該日期最近的工作日。例如15W表示離該月15號(hào)最近的工作日，如果該月15號(hào)是星期六，則匹配14號(hào)星期五；如果15日是星期日，則匹配16號(hào)星期一；如果15號(hào)是星期二，那結(jié)果就是15號(hào)星期二。但必須注意關(guān)聯(lián)的匹配日期不能夠跨月，如你指定1W，如果1號(hào)是星期六，結(jié)果匹配的是3號(hào)星期一，而非上個(gè)月最后的那天。W字符串只能指定單一日期，而不能指定日期范圍；

•LW組合：在日期字段可以組合使用LW，它的意思是當(dāng)月的最后一個(gè)工作日； 井號(hào)(#)：該字符只能在星期字段中使用，表示當(dāng)月某個(gè)工作日。如6#3表示當(dāng)月的第三個(gè)星期五(6表示星期五，#3表示當(dāng)前的第三個(gè))，而4#5表示當(dāng)月的第五個(gè)星期三，假設(shè)當(dāng)月沒(méi)有第五個(gè)星期三，忽略不觸發(fā)；

•C：該字符只在日期和星期字段中使用，代表“Calendar”的意思。它的意思是計(jì)劃所關(guān)聯(lián)的日期，如果日期沒(méi)有被關(guān)聯(lián)，則相當(dāng)于日歷中所有日期。例如5C在日期字段中就相當(dāng)于日歷5日以后的第一天。1C在星期字段中相當(dāng)于星期日后的第一天。

Cron表達(dá)式對(duì)特殊字符的大小寫不敏感，對(duì)代表星期的縮寫英文大小寫也不敏感。一些例子：

JobDetail & Job

JobDetail是任務(wù)的定義，而Job是任務(wù)的執(zhí)行邏輯。在JobDetail里會(huì)引用一個(gè)Job Class定義。一個(gè)最簡(jiǎn)單的例子：

public class JobTest {
 public static void main(String[] args) throws SchedulerException, IOException {
   JobDetail job=newJob()
    .ofType(DoNothingJob.class) //引用Job Class
    .withIdentity("job1", "group1") //設(shè)置name/group
    .withDescription("this is a test job") //設(shè)置描述
    .usingJobData("age", 18) //加入屬性到ageJobDataMap
    .build();

   job.getJobDataMap().put("name", "quertz"); //加入屬性name到JobDataMap

   //定義一個(gè)每秒執(zhí)行一次的SimpleTrigger
   Trigger trigger=newTrigger()
     .startNow()
     .withIdentity("trigger1")
     .withSchedule(simpleSchedule()
      .withIntervalInSeconds(1)
      .repeatForever())
     .build();

   Scheduler sche=StdSchedulerFactory.getDefaultScheduler();
   sche.scheduleJob(job, trigger);

   sche.start();

   System.in.read();

   sche.shutdown();
 }
}


public class DoNothingJob implements Job {
 public void execute(JobExecutionContext context) throws JobExecutionException {
  System.out.println("do nothing");
 }
}

從上例我們可以看出，要定義一個(gè)任務(wù)，需要干幾件事：

•創(chuàng)建一個(gè)org.quartz.Job的實(shí)現(xiàn)類，并實(shí)現(xiàn)實(shí)現(xiàn)自己的業(yè)務(wù)邏輯。比如上面的DoNothingJob。

•定義一個(gè)JobDetail，引用這個(gè)實(shí)現(xiàn)類

•加入scheduleJob Quartz調(diào)度一次任務(wù)，會(huì)干如下的事：

•JobClass jobClass=JobDetail.getJobClass()

•Job jobInstance=jobClass.newInstance()。所以Job實(shí)現(xiàn)類，必須有一個(gè)public的無(wú)參構(gòu)建方法。

•jobInstance.execute(JobExecutionContext context)。JobExecutionContext是Job運(yùn)行的上下文，可以獲得Trigger、Scheduler、JobDetail的信息。

也就是說(shuō)，每次調(diào)度都會(huì)創(chuàng)建一個(gè)新的Job實(shí)例，這樣的好處是有些任務(wù)并發(fā)執(zhí)行的時(shí)候，不存在對(duì)臨界資源的訪問(wèn)問(wèn)題——當(dāng)然，如果需要共享JobDataMap的時(shí)候，還是存在臨界資源的并發(fā)訪問(wèn)的問(wèn)題。

JobDataMap

Job是newInstance的實(shí)例，那我怎么傳值給它？ 比如我現(xiàn)在有兩個(gè)發(fā)送郵件的任務(wù)，一個(gè)是發(fā)給"liLei",一個(gè)發(fā)給"hanmeimei",不能說(shuō)我要寫兩個(gè)Job實(shí)現(xiàn)類LiLeiSendEmailJob和HanMeiMeiSendEmailJob。實(shí)現(xiàn)的辦法是通過(guò)JobDataMap。

每一個(gè)JobDetail都會(huì)有一個(gè)JobDataMap。JobDataMap本質(zhì)就是一個(gè)Map的擴(kuò)展類，只是提供了一些更便捷的方法，比如getString()之類的。

我們可以在定義JobDetail，加入屬性值，方式有二：

•newJob().usingJobData("age", 18) //加入屬性到ageJobDataMap

•job.getJobDataMap().put("name", "quertz"); //加入屬性name到JobDataMap

然后在Job中可以獲取這個(gè)JobDataMap的值，方式同樣有二：

public class HelloQuartz implements Job {
 private String name;
 public void execute(JobExecutionContext context) throws JobExecutionException {
  JobDetail detail = context.getJobDetail();
  JobDataMap map = detail.getJobDataMap(); //方法一：獲得JobDataMap
  System.out.println("say hello to " + name + "[" + map.getInt("age") + "]" + " at "
       + new Date());
 }

 //方法二：屬性的setter方法，會(huì)將JobDataMap的屬性自動(dòng)注入
 public void setName(String name) { 
  this.name = name;
 }
}

對(duì)于同一個(gè)JobDetail實(shí)例，執(zhí)行的多個(gè)Job實(shí)例，是共享同樣的JobDataMap，也就是說(shuō)，如果你在任務(wù)里修改了里面的值，會(huì)對(duì)其他Job實(shí)例（并發(fā)的或者后續(xù)的）造成影響。

除了JobDetail，Trigger同樣有一個(gè)JobDataMap，共享范圍是所有使用這個(gè)Trigger的Job實(shí)例。

Job并發(fā)

Job是有可能并發(fā)執(zhí)行的，比如一個(gè)任務(wù)要執(zhí)行10秒中，而調(diào)度算法是每秒中觸發(fā)1次，那么就有可能多個(gè)任務(wù)被并發(fā)執(zhí)行。

有時(shí)候我們并不想任務(wù)并發(fā)執(zhí)行，比如這個(gè)任務(wù)要去”獲得數(shù)據(jù)庫(kù)中所有未發(fā)送郵件的名單“，如果是并發(fā)執(zhí)行，就需要一個(gè)數(shù)據(jù)庫(kù)鎖去避免一個(gè)數(shù)據(jù)被多次處理。這個(gè)時(shí)候一個(gè)@DisallowConcurrentExecution解決這個(gè)問(wèn)題。就是這樣：

public class DoNothingJob implements Job {
 @DisallowConcurrentExecution
 public void execute(JobExecutionContext context) throws JobExecutionException {
  System.out.println("do nothing");
 }
}

注意，@DisallowConcurrentExecution是對(duì)JobDetail實(shí)例生效，也就是如果你定義兩個(gè)JobDetail，引用同一個(gè)Job類，是可以并發(fā)執(zhí)行的。

JobExecutionException

Job.execute()方法是不允許拋出除JobExecutionException之外的所有異常的（包括RuntimeException)，所以編碼的時(shí)候，最好是try-catch住所有的Throwable，小心處理。

其他屬性

•Durability（耐久性？) 如果一個(gè)任務(wù)不是durable，那么當(dāng)沒(méi)有Trigger關(guān)聯(lián)它的時(shí)候，它就會(huì)被自動(dòng)刪除。

•RequestsRecovery 如果一個(gè)任務(wù)是"requests recovery"，那么當(dāng)任務(wù)運(yùn)行過(guò)程非正常退出時(shí)（比如進(jìn)程崩潰，機(jī)器斷電，但不包括拋出異常這種情況），Quartz再次啟動(dòng)時(shí)，會(huì)重新運(yùn)行一次這個(gè)任務(wù)實(shí)例。

可以通過(guò)JobExecutionContext.isRecovering()查詢?nèi)蝿?wù)是否是被恢復(fù)的。

Scheduler

•Scheduler就是Quartz的大腦，所有任務(wù)都是由它來(lái)設(shè)施。

•Schduelr包含一個(gè)兩個(gè)重要組件: JobStore和ThreadPool。

•JobStore是會(huì)來(lái)存儲(chǔ)運(yùn)行時(shí)信息的，包括Trigger,Schduler,JobDetail，業(yè)務(wù)鎖等。它有多種實(shí)現(xiàn)RAMJob(內(nèi)存實(shí)現(xiàn))，JobStoreTX(JDBC，事務(wù)由Quartz管理），JobStoreCMT(JDBC，使用容器事務(wù))，ClusteredJobStore(集群實(shí)現(xiàn))、TerracottaJobStore(什么是Terractta)。

•ThreadPool就是線程池，Quartz有自己的線程池實(shí)現(xiàn)。所有任務(wù)的都會(huì)由線程池執(zhí)行。

SchedulerFactory

SchdulerFactory，顧名思義就是來(lái)用創(chuàng)建Schduler了，有兩個(gè)實(shí)現(xiàn)：DirectSchedulerFactory和 StdSchdulerFactory。前者可以用來(lái)在代碼里定制你自己的Schduler參數(shù)。后者是直接讀取classpath下的quartz.properties（不存在就都使用默認(rèn)值）配置來(lái)實(shí)例化Schduler。通常來(lái)講，我們使用StdSchdulerFactory也就足夠了。

SchdulerFactory本身是支持創(chuàng)建RMI stub的，可以用來(lái)管理遠(yuǎn)程的Scheduler，功能與本地一樣，可以遠(yuǎn)程提交個(gè)Job什么的。DirectSchedulerFactory的創(chuàng)建接口：

/**
  * Same as
  * {@link DirectSchedulerFactory#createScheduler(ThreadPool threadPool, JobStore jobStore)},
  * with the addition of specifying the scheduler name and instance ID. This
  * scheduler can only be retrieved via
  * {@link DirectSchedulerFactory#getScheduler(String)}
  *
  * @param schedulerName
  *   The name for the scheduler.
  * @param schedulerInstanceId
  *   The instance ID for the scheduler.
  * @param threadPool
  *   The thread pool for executing jobs
  * @param jobStore
  *   The type of job store
  * @throws SchedulerException
  *   if initialization failed
  */


  public void createScheduler(String schedulerName,
    String schedulerInstanceId, ThreadPool threadPool, JobStore jobStore)
   throws SchedulerException;

StdSchdulerFactory的配置例子， 更多配置，參考Quartz配置指南：

org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10 
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

三、Quartz 集成 Spring

開(kāi)發(fā)一個(gè)job類，普通java類，需要有一個(gè)執(zhí)行的方法：

package com.tgb.lk.demo.quartz;
import java.util.Date;
public class MyJob {
  public void work() {
   System.out.println("date:" + new Date().toString());
  }
}

把類放到spring容器中，可以使用配置也可以使用注解：

<bean id="myJob" class="com.tgb.lk.demo.quartz.MyJob" />

配置jobDetail，指定job對(duì)象：

<!-- 配置jobDetail，指定job對(duì)象 -->
 <bean id="accountJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
  <property name="targetObject">
   <ref bean="accountJob" />
  </property>
  <property name="targetMethod">
   <value>work</value>
  </property>
 </bean>

配置一個(gè)trigger，需要指定一個(gè)cron表達(dá)式，指定任務(wù)的執(zhí)行時(shí)機(jī)：

<!-- accountTrigger 的配置 -->
  <bean id="accountTrigger"
   class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
   <property name="jobDetail">
    <ref bean="accountJobDetail" />
   </property>
   <property name="cronExpression">
    <value>0/3 * * * * ?</value>
   </property>
  </bean>

配置調(diào)度工廠：

<!-- 啟動(dòng)觸發(fā)器的配置開(kāi)始 -->
 <bean name="startQuertz" lazy-init="false" autowire="no"
  class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
  <property name="triggers">
   <list>
    <ref bean="myJobTrigger" />
   </list>
  </property>
 </bean>
 <!-- 啟動(dòng)觸發(fā)器的配置結(jié)束 -->

項(xiàng)目啟動(dòng)，定時(shí)器開(kāi)始執(zhí)行。

四、分析不同定時(shí)任務(wù)優(yōu)缺點(diǎn)，尋找一種符合你項(xiàng)目需求的定時(shí)任務(wù) Timer管理延時(shí)任務(wù)的缺陷

以前在項(xiàng)目中也經(jīng)常使用定時(shí)器，比如每隔一段時(shí)間清理項(xiàng)目中的一些垃圾文件，每隔一段時(shí)間進(jìn)行日志清理；然而Timer是存在一些缺陷的，因?yàn)門imer在執(zhí)行定時(shí)任務(wù)時(shí)只會(huì)創(chuàng)建一個(gè)線程，所以如果存在多個(gè)任務(wù)，且任務(wù)時(shí)間過(guò)長(zhǎng)，超過(guò)了兩個(gè)任務(wù)的間隔時(shí)間，會(huì)發(fā)生一些缺陷

Timer當(dāng)任務(wù)拋出異常時(shí)的缺陷

如果TimerTask拋出RuntimeException，Timer會(huì)停止所有任務(wù)的運(yùn)行

Timer執(zhí)行周期任務(wù)時(shí)依賴系統(tǒng)時(shí)間

Timer執(zhí)行周期任務(wù)時(shí)依賴系統(tǒng)時(shí)間，如果當(dāng)前系統(tǒng)時(shí)間發(fā)生變化會(huì)出現(xiàn)一些執(zhí)行上的變化，ScheduledExecutorService基于時(shí)間的延遲，不會(huì)由于系統(tǒng)時(shí)間的改變發(fā)生執(zhí)行變化。

對(duì)異常的處理

Quartz的某次執(zhí)行任務(wù)過(guò)程中拋出異常，不影響下一次任務(wù)的執(zhí)行，當(dāng)下一次執(zhí)行時(shí)間到來(lái)時(shí)，定時(shí)器會(huì)再次執(zhí)行任務(wù)；而TimerTask則不同，一旦某個(gè)任務(wù)在執(zhí)行過(guò)程中拋出異常，則整個(gè)定時(shí)器生命周期就結(jié)束，以后永遠(yuǎn)不會(huì)再執(zhí)行定時(shí)器任務(wù)。

精確到和功能

Quartz每次執(zhí)行任務(wù)都創(chuàng)建一個(gè)新的任務(wù)類對(duì)象，而TimerTask則每次使用同一個(gè)任務(wù)類對(duì)象。 Quartz可以通過(guò)cron表達(dá)式精確到特定時(shí)間執(zhí)行，而TimerTask不能。Quartz擁有TimerTask所有的功能，而TimerTask則沒(méi)有上述，基本說(shuō)明了在以后的開(kāi)發(fā)中盡可能使用ScheduledExecutorService(JDK1.5以后)替代Timer。

五、cron 在線表達(dá)式生成器 http://cron.qqe2.com/ 附錄 cron 表達(dá)式

cron表達(dá)式用于配置cronTrigger的實(shí)例。cron表達(dá)式實(shí)際上是由七個(gè)子表達(dá)式組成。這些表達(dá)式之間用空格分隔。

•Seconds （秒）

•Minutes（分）

•Hours（小時(shí)）

•Day-of-Month （天）

•Month（月）

•Day-of-Week （周）

•Year（年）

例："0 0 12 ? * WED” 意思是：每個(gè)星期三的中午12點(diǎn)執(zhí)行。個(gè)別子表達(dá)式可以包含范圍或者列表。例如：上面例子中的WED可以換成"MON-FRI"，"MON,WED,FRI"，甚至"MON-WED,SAT"。子表達(dá)式范圍：

•Seconds (0~59)

•Minutes (0~59)

•Hours (0~23)

•Day-of-Month (1~31,但是要注意有些月份沒(méi)有31天)

•Month (0~11，或者"JAN, FEB, MAR, APR, MAY, JUN, JUL, AUG, SEP, OCT, NOV,DEC")

•Day-of-Week (1~7,1=SUN 或者"SUN, MON, TUE, WED, THU, FRI, SAT”)

•Year (1970~2099)

Cron表達(dá)式的格式：秒 分 時(shí) 日 月 周 年(可選)。

字段名 | 允許的值 | 允許的特殊字符 ------- | ------ | ------ | ------ 秒 | 0-59 | , - * / 分 | 0-59 | , - * / 小時(shí) | 0-23 | , - * / 日 | 1-31 | , - * ? / L W C 月 | 1-12 or JAN-DEC | , - * / 周幾 | 1-7 or SUN-SAT | , - * ? / L C # 年(可選字段) | empty 1970-2099 | , - * /

字符含義：

•*：代表所有可能的值。因此，“*”在Month中表示每個(gè)月，在Day-of-Month中表示每天，在Hours表示每小時(shí)

•-：表示指定范圍。

•,：表示列出枚舉值。例如：在Minutes子表達(dá)式中，“5,20”表示在5分鐘和20分鐘觸發(fā)。

•/：被用于指定增量。例如：在Minutes子表達(dá)式中，“0/15”表示從0分鐘開(kāi)始，每15分鐘執(zhí)行一次。"3/20"表示從第三分鐘開(kāi)始，每20分鐘執(zhí)行一次。和"3,23,43"（表示第3，23，43分鐘觸發(fā)）的含義一樣。

•?：用在Day-of-Month和Day-of-Week中，指“沒(méi)有具體的值”。當(dāng)兩個(gè)子表達(dá)式其中一個(gè)被指定了值以后，為了避免沖突，需要將另外一個(gè)的值設(shè)為“?”。例如：想在每月20日觸發(fā)調(diào)度，不管20號(hào)是星期幾，只能用如下寫法：0 0 0 20 * ?，其中最后以為只能用“?”，而不能用“*”。

•L：用在day-of-month和day-of-week字串中。它是單詞“l(fā)ast”的縮寫。它在兩個(gè)子表達(dá)式中的含義是不同的。

•在day-of-month中，“L”表示一個(gè)月的最后一天，一月31號(hào)，3月30號(hào)。

•在day-of-week中，“L”表示一個(gè)星期的最后一天，也就是“7”或者“SAT”

•如果“L”前有具體內(nèi)容，它就有其他的含義了。例如：“6L”表示這個(gè)月的倒數(shù)第六天。“FRIL”表示這個(gè)月的最后一個(gè)星期五。

•注意：在使用“L”參數(shù)時(shí)，不要指定列表或者范圍，這樣會(huì)出現(xiàn)問(wèn)題。

•W：“Weekday”的縮寫。只能用在day-of-month字段。用來(lái)描敘最接近指定天的工作日（周一到周五）。例如：在day-of-month字段用“15W”指“最接近這個(gè)月第15天的工作日”，即如果這個(gè)月第15天是周六，那么觸發(fā)器將會(huì)在這個(gè)月第14天即周五觸發(fā)；如果這個(gè)月第15天是周日，那么觸發(fā)器將會(huì)在這個(gè)月第 16天即周一觸發(fā)；如果這個(gè)月第15天是周二，那么就在觸發(fā)器這天觸發(fā)。注意一點(diǎn)：這個(gè)用法只會(huì)在當(dāng)前月計(jì)算值，不會(huì)越過(guò)當(dāng)前月。“W”字符僅能在 day-of-month指明一天，不能是一個(gè)范圍或列表。也可以用“LW”來(lái)指定這個(gè)月的最后一個(gè)工作日，即最后一個(gè)星期五。

•# ：只能用在day-of-week字段。用來(lái)指定這個(gè)月的第幾個(gè)周幾。例：在day-of-week字段用"6#3" or "FRI#3"指這個(gè)月第3個(gè)周五（6指周五，3指第3個(gè)）。如果指定的日期不存在，觸發(fā)器就不會(huì)觸發(fā)。

表達(dá)式例子：

0 * * * * ? 每1分鐘觸發(fā)一次

0 0 * * * ? 每天每1小時(shí)觸發(fā)一次

0 0 10 * * ? 每天10點(diǎn)觸發(fā)一次

0 * 14 * * ? 在每天下午2點(diǎn)到下午2:59期間的每1分鐘觸發(fā)

0 30 9 1 * ? 每月1號(hào)上午9點(diǎn)半

0 15 10 15 * ? 每月15日上午10:15觸發(fā)

*/5 * * * * ? 每隔5秒執(zhí)行一次

0 */1 * * * ? 每隔1分鐘執(zhí)行一次

0 0 5-15 * * ? 每天5-15點(diǎn)整點(diǎn)觸發(fā)

0 0/3 * * * ? 每三分鐘觸發(fā)一次

0 0-5 14 * * ? 在每天下午2點(diǎn)到下午2:05期間的每1分鐘觸發(fā)

0 0/5 14 * * ? 在每天下午2點(diǎn)到下午2:55期間的每5分鐘觸發(fā)

0 0/5 14,18 * * ? 在每天下午2點(diǎn)到2:55期間和下午6點(diǎn)到6:55期間的每5分鐘觸發(fā)

0 0/30 9-17 * * ? 朝九晚五工作時(shí)間內(nèi)每半小時(shí)

0 0 10,14,16 * * ? 每天上午10點(diǎn)，下午2點(diǎn)，4點(diǎn)

0 0 12 ? * WED 表示每個(gè)星期三中午12點(diǎn)

0 0 17 ? * TUES,THUR,SAT 每周二、四、六下午五點(diǎn)

0 10,44 14 ? 3 WED 每年三月的星期三的下午2:10和2:44觸發(fā)

0 15 10 ? * MON-FRI 周一至周五的上午10:15觸發(fā)

0 0 23 L * ? 每月最后一天23點(diǎn)執(zhí)行一次

0 15 10 L * ? 每月最后一日的上午10:15觸發(fā)

0 15 10 ? * 6L 每月的最后一個(gè)星期五上午10:15觸發(fā)

0 15 10 * * ? 2005 2005年的每天上午10:15觸發(fā)

0 15 10 ? * 6L 2002-2005 2002年至2005年的每月的最后一個(gè)星期五上午10:15觸發(fā)

0 15 10 ? * 6#3 每月的第三個(gè)星期五上午10:15觸發(fā)

以上這篇Java實(shí)現(xiàn)Web應(yīng)用中的定時(shí)任務(wù)(實(shí)例講解)就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論