Java的作業(yè)調(diào)度類庫Quartz基本使用指南
一、常用接口:
1、Job接口:該接口只有一個(gè)方法
void execute(JobExecutionContext context)
開發(fā)者實(shí)現(xiàn)該接口定義需要執(zhí)行的任務(wù)。JobExecutionContext類提供調(diào)度上下文的各種信息
2、JobDetail:用于描敘Job實(shí)現(xiàn)類及其他的一些靜態(tài)信息
3、Trigger:描敘觸發(fā)Job執(zhí)行的時(shí)間觸發(fā)規(guī)則
4、Calendar:定義了一個(gè)關(guān)聯(lián)Trigger可能(或者不可能)觸發(fā)的時(shí)間空間。它沒有定義觸發(fā)的真實(shí)時(shí)間,而是用在在普通的Schedule需要限制Trigger觸發(fā)的時(shí)候。大部分Calendar包含默認(rèn)所有的時(shí)間,并且用戶去排除部分時(shí)間。
5、Scheduler:運(yùn)行容器,使用SchedulerFactory創(chuàng)建Scheduler實(shí)例
二、代碼示例:
1、使用Quartz,需要實(shí)現(xiàn)Job接口;
public class TestJob implements Job { public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Hello World! - " + new Date()); //do more... } }
2、調(diào)度【比較簡單,直接看代碼就可以了】
public class quartzTest { public static void main(String args[]) throws SchedulerException, ParseException { JobDetail jobDetail= JobBuilder.newJob(TestJob.class) .withIdentity("testJob_1","group_1") .build(); Trigger trigger= TriggerBuilder .newTrigger() .withIdentity("trigger_1","group_1") .startNow() .withSchedule(SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(10) //時(shí)間間隔 .withRepeatCount(5) //重復(fù)次數(shù)(將執(zhí)行6次) ) .build(); SchedulerFactory sf = new StdSchedulerFactory(); Scheduler sched = sf.getScheduler(); sched.scheduleJob(jobDetail,trigger); sched.start(); } }
這里使用的是2.2.1版本,參考官方文檔的示例??吹揭恍﹨⒖紩褂玫陌姹颈容^老,所以會(huì)有一些出入,很多方法都被棄用了,所以還是直接看文檔比較實(shí)在,Quartz的官方網(wǎng)站地址是:http://www.quartz-scheduler.org/
三、Quartz2.2.1配置文件示例
# Default Properties file for use by StdSchedulerFactory # to create a Quartz Scheduler Instance, if a different # properties file is not explicitly specified. # #集群配置 org.quartz.scheduler.instanceName: DefaultQuartzScheduler org.quartz.scheduler.rmi.export: false org.quartz.scheduler.rmi.proxy: false org.quartz.scheduler.wrapJobExecutionInUserTransaction: false 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.misfireThreshold: 60000 #============================================================================ # Configure JobStore #============================================================================ #默認(rèn)配置,數(shù)據(jù)保存到內(nèi)存 #org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore #持久化配置 org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore.useProperties:true #數(shù)據(jù)庫表前綴 org.quartz.jobStore.tablePrefix:qrtz_ org.quartz.jobStore.dataSource:qzDS #============================================================================ # Configure Datasources #============================================================================ #JDBC驅(qū)動(dòng) org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartzdb org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:123456 org.quartz.dataSource.qzDS.maxConnection:10
四、數(shù)據(jù)庫相關(guān)
持久化須事先在相應(yīng)數(shù)據(jù)庫創(chuàng)建Quartz的數(shù)據(jù)表,在Quartz發(fā)布包里面的docs/dbTables有對應(yīng)不同數(shù)據(jù)庫的SQL腳本
例如,這里使用的是MYSQL:
數(shù)據(jù)表字段解釋:
- 表qrtz_job_details: 保存job詳細(xì)信息,該表需要用戶根據(jù)實(shí)際情況初始化
- job_name:集群中job的名字,該名字用戶自己可以隨意定制,無強(qiáng)行要求
- job_group:集群中job的所屬組的名字,該名字用戶自己隨意定制,無強(qiáng)行要求
- job_class_name:實(shí)現(xiàn)類的完全包名,quartz就是根據(jù)這個(gè)路徑到classpath找到該job類
- is_durable:是否持久化,把該屬性設(shè)置為1,quartz會(huì)把job持久化到數(shù)據(jù)庫中
- job_data:一個(gè)blob字段,存放持久化job對象
- 表qrtz_triggers: 保存trigger信息
- trigger_name: trigger的名字,該名字用戶自己可以隨意定制,無強(qiáng)行要求
- trigger_group:trigger所屬組的名字,該名字用戶自己隨意定制,無強(qiáng)行要求
- job_name: qrtz_job_details表job_name的外鍵
- job_group: qrtz_job_details表job_group的外鍵
- trigger_state:當(dāng)前trigger狀態(tài),設(shè)置為ACQUIRED,如果設(shè)置為WAITING,則job不會(huì)觸發(fā)
- trigger_cron:觸發(fā)器類型,使用cron表達(dá)式
- 表qrtz_cron_triggers:存儲(chǔ)cron表達(dá)式表
- trigger_name: qrtz_triggers表trigger_name的外鍵
- trigger_group: qrtz_triggers表trigger_group的外鍵
- cron_expression:cron表達(dá)式
- 表qrtz_scheduler_state:存儲(chǔ)集群中note實(shí)例信息,quartz會(huì)定時(shí)讀取該表的信息判斷集群中每個(gè)實(shí)例的當(dāng)前狀態(tài)
- instance_name:之前配置文件中org.quartz.scheduler.instanceId配置的名字,就會(huì)寫入該字段,如果設(shè)置為AUTO,quartz會(huì)根據(jù)物理機(jī)名和當(dāng)前時(shí)間產(chǎn)生一個(gè)名字
- last_checkin_time:上次檢查時(shí)間
- checkin_interval:檢查間隔時(shí)間
相關(guān)文章
Java實(shí)現(xiàn)遞歸讀取文件夾下的所有文件
這篇文章主要為大家詳細(xì)介紹了如何利用Java實(shí)現(xiàn)遞歸讀取文件夾下的所有文件,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-02-02java中BeanUtils.copyProperties的用法(超詳細(xì))
本文介紹了BeanUtils.copyProperties()方法的使用,包括其功能、用法、注意事項(xiàng)和示例代碼,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-08-08JAVA JDK8 List分組獲取第一個(gè)元素的方法
今天小編就為大家分享一篇關(guān)于JAVA JDK8 List分組獲取第一個(gè)元素的方法,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧2018-12-12解決SpringBoot整合MybatisPlus分模塊管理遇到的bug
這篇文章主要介紹了解決SpringBoot整合MybatisPlus分模塊管理遇到的bug,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07