最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時間:2013年12月10日 10:25:20   作者:  
Quartz是一個完全由java編寫的開源作業(yè)調(diào)度框架,下面提供一個小例子供大家參考,還有在servlet配置的方法

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é)果再進(jìn)行下次作業(yè)的執(zhí)行,則需要實現(xiàn)此接口。
Trigger抽象類:調(diào)度類(Scheduler)在時間到時調(diào)用此類,再由trigger類調(diào)用指定的定時程序。
Quertz中提供了兩類觸發(fā)器為:SimpleTrigger,CronTrigger。前者用于實現(xiàn)比較簡單的定時功能,例如幾點開始,幾點結(jié)束,隔多長時間執(zhí)行,共執(zhí)行多少次等,后者提供了使用表達(dá)式來描述定時功能,因此適用于比較復(fù)雜的定時描述,例如每個月的最后一個周五,每周的周四等。
JobDetail類:具體某個定時程序的詳細(xì)描述,包括Name,Group,JobDataMap等。
JobExecutionContext類:定時程序執(zhí)行的run-time的上下文環(huán)境,用于得到當(dāng)前執(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í)行定進(jìn)程序,可選的有在內(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(在XML文件里以配置方式定義triiger,定時描述等)。

web應(yīng)用中使用
 
在web.xml中添加QuartzInitializerServlet,Quartz為能夠在web應(yīng)用中使用,提供了一個QuartzInitializerServlet和一個QuartzInitializerListener,用于在加載web應(yīng)用時,對quartz進(jìn)行初始化。我在使用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提供了一個默認(rèn)的配置文件,可以滿足基本的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,默認(rèn)的是加載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>標(biāo)簽。

上面與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>標(biāo)簽來指定。

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

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

相關(guān)文章

  • Java?static關(guān)鍵字詳細(xì)解析

    Java?static關(guān)鍵字詳細(xì)解析

    這篇文章主要介紹了Java?static關(guān)鍵字詳細(xì)解析,java中的static關(guān)鍵字主要用于內(nèi)存管理,可以用在變量、方法、代碼塊和嵌套類中。更多相關(guān)介紹,需要的小伙伴可以參考一下
    2022-08-08
  • java ArrayBlockingQueue阻塞隊列的實現(xiàn)示例

    java ArrayBlockingQueue阻塞隊列的實現(xiàn)示例

    ArrayBlockingQueue是一個基于數(shù)組實現(xiàn)的阻塞隊列,本文就來介紹一下java ArrayBlockingQueue阻塞隊列的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下
    2024-02-02
  • Spring boot集成Kafka+Storm的示例代碼

    Spring boot集成Kafka+Storm的示例代碼

    這篇文章主要介紹了Spring boot集成Kafka+Storm的示例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-12-12
  • Java多線程volatile原理及用法解析

    Java多線程volatile原理及用法解析

    這篇文章主要介紹了Java多線程volatile原理及用法解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-07-07
  • 最新評論

    乐昌市| 永年县| 巩留县| 苍梧县| 辽宁省| 大姚县| 南涧| 双鸭山市| 雅江县| 景洪市| 定结县| 紫云| 隆尧县| 宁河县| 葵青区| 霍林郭勒市| 栾川县| 禹州市| 淮北市| 敦化市| 健康| 葵青区| 六枝特区| 观塘区| 固始县| 方正县| 普陀区| 鹤庆县| 诸暨市| 阿勒泰市| 屯昌县| 青田县| 海晏县| 五莲县| 道真| 电白县| 玉龙| 永州市| 青田县| 禄丰县| 闸北区|