quartz實現(xiàn)定時功能實例詳解(servlet定時器配置方法)

2019-11-26 15:51:21

字體：大中小

供稿：網(wǎng)友

Quartz是一個完全由java編寫的開源作業(yè)調(diào)度框架,具體的介紹可到http://www.opensymphony.com/quartz/官方網(wǎng)站查看。

Quartz的幾個核心的接口和類為：

Job接口：自己寫的“定時程序”實現(xiàn)此接口的void execute(JobExecutionContext arg0)方法,Job還有一類為有狀態(tài)的StatefulJob接口，如果我們需要在上一個作業(yè)執(zhí)行完后，根據(jù)其執(zhí)行結(jié)果再進行下次作業(yè)的執(zhí)行，則需要實現(xiàn)此接口。
Trigger抽象類：調(diào)度類(Scheduler)在時間到時調(diào)用此類，再由trigger類調(diào)用指定的定時程序。
Quertz中提供了兩類觸發(fā)器為：SimpleTrigger,CronTrigger。前者用于實現(xiàn)比較簡單的定時功能，例如幾點開始，幾點結(jié)束，隔多長時間執(zhí)行，共執(zhí)行多少次等，后者提供了使用表達式來描述定時功能，因此適用于比較復(fù)雜的定時描述，例如每個月的最后一個周五，每周的周四等。
JobDetail類：具體某個定時程序的詳細描述，包括Name,Group,JobDataMap等。
JobExecutionContext類：定時程序執(zhí)行的run-time的上下文環(huán)境，用于得到當前執(zhí)行的Job的名字，配置的參數(shù)等。
JobDataMap類：用于描述一個作業(yè)的參數(shù)，參數(shù)可以為任何基本類型例如String,float等，也可為某個對象的引用.
JobListener,TriggerListener接口：用于監(jiān)聽觸發(fā)器狀態(tài)和作業(yè)掃行狀態(tài)，在特寫狀態(tài)執(zhí)行相應(yīng)操作。
JobStore類：在哪里執(zhí)行定進程序，可選的有在內(nèi)存中，在數(shù)據(jù)庫中。

簡單的定時程序：

復(fù)制代碼代碼如下:

public class TestJob implements Job
{
   public TestJob(){}
   public void execute(JobExecutionContext arg0) throws JobExecutionException
   {
      String name = context.getJobDetail().getJobDataMap().getString("name");
      System.out.println("job executing..."+name);   }
}

public class QuartzTest
{
 public static void main(String[] args)
 {
    QuartzTest test = new QuartzTest();
    try
   {
      test.startSchedule();
   }
  catch (Exception e)
  {
     e.printStackTrace();
  }
 }
 public void startSchedule() throws Exception
 {
     Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
     JobDetail jobDetail =
      new JobDetail("testJob", Scheduler.DEFAULT_GROUP, TestJob.class);
      //結(jié)束時間     
     long end = System.currentTimeMillis() + 9000L;
    //執(zhí)行10次，每3秒執(zhí)行一次，到9秒后結(jié)束
     SimpleTrigger trigger = new SimpleTrigger("test",null,new Date(),new Date(end),10,3000L);
      scheduler.scheduleJob(jobDetail, trigger);
     scheduler.start();
 }
}
 

執(zhí)行上面這個類基本實現(xiàn)了一個簡單的定時程序。但問題是現(xiàn)在這個類只能應(yīng)用在application中，在web環(huán)境里執(zhí)行還需要添加一些配置,例如添加servlet,添加配置文件quartz.properties或者quartz-job.xml(在ＸＭＬ文件里以配置方式定義triiger,定時描述等）。

web應(yīng)用中使用

在web.xml中添加QuartzInitializerServlet，Quartz為能夠在web應(yīng)用中使用，提供了一個QuartzInitializerServlet和一個QuartzInitializerListener，用于在加載web應(yīng)用時，對quartz進行初始化。我在使用servlet時加載成功，在使用listener時不成功，不知道怎么回事？

servlet配置：

復(fù)制代碼代碼如下:

<servlet> 
   <servlet-name>QuartzInitializer</servlet-name> 
   <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet</servlet-class> 
   <init-param>
     <param-name>shutdown-on-unload</param-name>
     <param-value>true</param-value>
   </init-param>
   <init-param>
    <param-name>config-file</param-name>
    <param-value>quartz.properties</param-value> 
   </init-param>
   <load-on-startup>2</load-on-startup>
 </servlet>
listener配置可以看源碼，主要的上面的參數(shù)配置為<context-param>,再加一個<listener>.

上面提到了quartz.properties,這是自行指定的，Quartz提供了一個默認的配置文件，可以滿足基本的j2se應(yīng)用，如果在web應(yīng)用中，我們想把job,trigger配置都寫到文件中，就需要自己來寫，并指定在初始化時加載我們自己的quratz.properties，位置放在classes下。

#============================================================================
# Configure Main Scheduler Properties  
#============================================================================
org.quartz.scheduler.instanceName = org.quartz.scheduler.instanceId = AUTO
#============================================================================
# Configure ThreadPool  
#============================================================================
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 3
org.quartz.threadPool.threadPriority = 5
#============================================================================
# Configure Plugins 
#============================================================================
org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin
org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.JobInitializationPlugin
org.quartz.plugin.jobInitializer.fileName = /scheduler/quartz_jobs.xml
org.quartz.plugin.jobInitializer.overWriteExistingJobs = true
org.quartz.plugin.jobInitializer.failOnFileNotFound = true
org.quartz.plugin.jobInitializer.scanInterval = 10

quartz要使用插件來加載自己的xml配置文件，上邊我們指定了在初始化時加載classes/scheduler/quartz_jobs.xml，默認的是加載classes/quartz_jobs.xml文件。

quartz_jobs.xml文件：
<?xml version='1.0' encoding='utf-8'?>
<quartz>
 <job>
　　 <job-detail>
  　　<name>test</name>
  　　<group>DEFAULT</group>
  　　<description>testJobhere</description>
  　　<job-class>TestJob</job-class>
  　　<job-data-map allows-transient-data="true">
   　　<entry>
    　　<key>name</key>
   　　 <value>test</value>
   　　</entry>
   </job-data-map>
 　　</job-detail>
　　 <trigger>
             <cron>
                  <name>testCron</name>
                  <group>DEFAULT</group>
                  <job-name>test</job-name>
                 <job-group>DEFALUT</job-group>
                 <cron-expression>0/3 * * * * ?</cron-expression>
             </cron>
       </trigger>
　 </job>
</quartz>

上面配置了一個作業(yè)，并聲明一個參數(shù)Name；配置了一個CronTrigger,每三秒執(zhí)行一次。如果要配置SimpleTrigger ,可以使用<simple>標簽。

上面與Job對應(yīng)的類為TestJob，源碼為：

復(fù)制代碼代碼如下:

public class TestJob implements Job
{
 public TestJob(){}
 public void execute(JobExecutionContext context) throws JobExecutionException
 {
     String name = context.getJobDetail().getJobDataMap().getString("name");
     System.out.println("job executing..."+name);
 }
}

在quartz_job.xml文件中還可以指定TriggerListener,JobListener等，可以使用<trigger-listener>,<job-listener>標簽來指定。

由于quartz目前文檔不是很多，大部分都是看源碼。總體看Quartz提供的CronTrigger使用表達式方式描述定時規(guī)律這個功能還是很強大的，在其源碼中有很多例子。

spring已經(jīng)把quartz集成在一起，并進行了封裝，使用起來還是很方便的。

上一篇：java字符串切割實例學(xué)習(xí)(獲取文件名)

下一篇：java怎么創(chuàng)建目錄(刪除/修改/復(fù)制目錄及文件)代碼實例