quartz實(shí)現(xiàn)定時(shí)功能實(shí)例詳解(servlet定時(shí)器配置方法)
Quartz是一個(gè)完全由java編寫的開源作業(yè)調(diào)度框架,具體的介紹可到http://www.opensymphony.com/quartz/官方網(wǎng)站查看。
Quartz的幾個(gè)核心的接口和類為:
Job接口:自己寫的“定時(shí)程序”實(shí)現(xiàn)此接口的void execute(JobExecutionContext arg0)方法,Job還有一類為有狀態(tài)的StatefulJob接口,如果我們需要在上一個(gè)作業(yè)執(zhí)行完后,根據(jù)其執(zhí)行結(jié)果再進(jìn)行下次作業(yè)的執(zhí)行,則需要實(shí)現(xiàn)此接口。
Trigger抽象類:調(diào)度類(Scheduler)在時(shí)間到時(shí)調(diào)用此類,再由trigger類調(diào)用指定的定時(shí)程序。
Quertz中提供了兩類觸發(fā)器為:SimpleTrigger,CronTrigger。前者用于實(shí)現(xiàn)比較簡(jiǎn)單的定時(shí)功能,例如幾點(diǎn)開始,幾點(diǎn)結(jié)束,隔多長(zhǎng)時(shí)間執(zhí)行,共執(zhí)行多少次等,后者提供了使用表達(dá)式來描述定時(shí)功能,因此適用于比較復(fù)雜的定時(shí)描述,例如每個(gè)月的最后一個(gè)周五,每周的周四等。
JobDetail類:具體某個(gè)定時(shí)程序的詳細(xì)描述,包括Name,Group,JobDataMap等。
JobExecutionContext類:定時(shí)程序執(zhí)行的run-time的上下文環(huán)境,用于得到當(dāng)前執(zhí)行的Job的名字,配置的參數(shù)等。
JobDataMap類:用于描述一個(gè)作業(yè)的參數(shù),參數(shù)可以為任何基本類型例如String,float等,也可為某個(gè)對(duì)象的引用.
JobListener,TriggerListener接口:用于監(jiān)聽觸發(fā)器狀態(tài)和作業(yè)掃行狀態(tài),在特寫狀態(tài)執(zhí)行相應(yīng)操作。
JobStore類:在哪里執(zhí)行定進(jìn)程序,可選的有在內(nèi)存中,在數(shù)據(jù)庫中。
簡(jiǎn)單的定時(shí)程序:
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é)束時(shí)間
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í)行上面這個(gè)類基本實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的定時(shí)程序。但問題是現(xiàn)在這個(gè)類只能應(yīng)用在application中,在web環(huán)境里執(zhí)行還需要添加一些配置,例如添加servlet,添加配置文件quartz.properties或者quartz-job.xml(在XML文件里以配置方式定義triiger,定時(shí)描述等)。
web應(yīng)用中使用
在web.xml中添加QuartzInitializerServlet,Quartz為能夠在web應(yīng)用中使用,提供了一個(gè)QuartzInitializerServlet和一個(gè)QuartzInitializerListener,用于在加載web應(yīng)用時(shí),對(duì)quartz進(jìn)行初始化。我在使用servlet時(shí)加載成功,在使用listener時(shí)不成功,不知道怎么回事?
servlet配置:
<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>,再加一個(gè)<listener>.
上面提到了quartz.properties,這是自行指定的,Quartz提供了一個(gè)默認(rèn)的配置文件,可以滿足基本的j2se應(yīng)用,如果在web應(yīng)用中,我們想把job,trigger配置都寫到文件中,就需要自己來寫,并指定在初始化時(shí)加載我們自己的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配置文件,上邊我們指定了在初始化時(shí)加載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>
上面配置了一個(gè)作業(yè),并聲明一個(gè)參數(shù)Name;配置了一個(gè)CronTrigger,每三秒執(zhí)行一次。如果要配置SimpleTrigger ,可以使用<simple>標(biāo)簽。
上面與Job對(duì)應(yīng)的類為TestJob,源碼為:
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á)式方式描述定時(shí)規(guī)律這個(gè)功能還是很強(qiáng)大的,在其源碼中有很多例子。
spring已經(jīng)把quartz集成在一起,并進(jìn)行了封裝,使用起來還是很方便的。
相關(guān)文章
Spring使用注解進(jìn)行引用類型的自動(dòng)裝配逐步分析
自動(dòng)裝配是springboot的核心,一般提到自動(dòng)裝配就會(huì)和springboot聯(lián)系在一起。實(shí)際上Spring Framework早就實(shí)現(xiàn)了這個(gè)功能。Spring Boot只是在其基礎(chǔ)上,通過SPI的方式,做了進(jìn)一步優(yōu)化2023-03-03
詳解Lombok安裝及Spring Boot集成Lombok
這篇文章主要介紹了詳解Lombok安裝及Spring Boot集成Lombok,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2019-03-03
Java手寫Redis服務(wù)端的實(shí)現(xiàn)
本文主要介紹了Java手寫Redis服務(wù)端的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-12-12
解決SpringBoot啟動(dòng)報(bào)錯(cuò):Failed?to?load?property?source?from?l
這篇文章主要介紹了解決SpringBoot啟動(dòng)報(bào)錯(cuò):Failed?to?load?property?source?from?location?'classpath:/application.yml'問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2025-04-04
java ArrayBlockingQueue阻塞隊(duì)列的實(shí)現(xiàn)示例

