初探Quartz

最近项目中用到了Quartz任务调度库,在这里简单介绍一下,最新版的Quartz的基本使用和语法。
开始使用Quartz:

1.下载Quartz

下载地址点这里,下载了之后可以看到lib文件,我们在这里需要用到的jar文件,quartz---.jar是Quartz实现的jar,其他的3个jar的Quartz日志所需要的jar,下图这四个库是必须要使用的:

需要的jar包.png

2.任务具体实现

在Quartz中,所有的任务都必须实现Job接口,Job中只有一个execute(JobExecutionContext context)实现方法,我们的具体业务实现就得写在这个方法里面,这个方法将会在触发器满足调度条件是触发.
参数JobExecutionContext可以用来设置调用结果Result,通过put或者set方法.
代码示例:

package com.jelly.quartz;

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

public class Job1 implements Job{

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        System.out.println(sdf.format(new Date())+" ---- start Job");
    }
    
}

JavaDoc截图:


JavaDoc截图.png

3.设置简单调度任务

设置调度任务一共分为四个步骤

(1)实例化JobDetail(调度任务):

由于JobDetail是一个接口,所以必须通过JobBuilder实例化JobDetail,看一下具体代码:

JobBuilder jobBuilder = JobBuilder.newJob(Job1.class);
jobBuilder.withIdentity("job1", "group1");
JobDetail jobDetail = jobBuilder.build();

通过JobBuilder的newJob方法设置需要执行的Job任务类名,withIdentity是设置JobDetail的name和gruop(如果没有设置的话,将会随机生成name和group)最后通过build方法就可以实例化JobDetail.

(2)实例化Trigger(触发器):

Trigger也是个接口,只能通过TriggerBuilder去实例化,具体代码:

TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
triggerBuilder.withIdentity("tigger1", "group1");
triggerBuilder.startNow();
triggerBuilder.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(60).repeatForever());
Trigger trigger = triggerBuilder.build();

TriggerBuilder的newTrigger去获取TriggerBuilder对象,设置name和group(不设置将会随机生成),调用startNow设置Trigger开始的时间为当前时间,通过withSchedule设置触发器的调度规则。最后通过build方法获取对象.
SimpleScheduleBuilder先不用管是什么,在后面会解释,理解为任务的触发条件就行,在这里设置60秒重复一次,重复次数无限.

(3)为调度程序设置任务和触发器,开始调度:

JobDetail和Trigger实例化完成之后,设置调度程序,开始调度任务.由于Scheduler是interface,无法直接实例化,通过JavaDoc知道只能通过SchedulerFactory来获取,但是SchedulerFactory也是interface,最后找到了实现类StdSchedulerFactory,具体代码:

Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();

通过StdSchedulerFactory的getDefaultScheduler获取一个Scheduler,为Scheduler设置Job和Trigger,调用start开始调度.
还有一种获取Scheduler的方式,由于StdSchedulerFactory实现了SchedulerFactory的接口,故可以直接实例化StdSchedulerFactory,然后通过getScheduler获取Scheduler.

SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
(4)关闭任务调度:
scheduler.shutdown();

4.触发器的两种模式

任务调度有两种模式.一种是SimpleSchedule(简单模式),这种只能实现简单的调度,比如多少秒重复触发
等简单的任务调度。另外一种是CronSchedule(表达式模式),这种模式是基于Cron时间表达式.下面介绍一下这两种模式:

(1)简单模式

在这种模式下只能根据提供的Api指定一些简单的时间重复调度,可以指定重复的次数,repeatForever代表无限重复,其他重复次数可以通过withRepeatCount(int triggerRepeatCount)来指定.

triggerBuilder.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(60).repeatForever());

介绍一下常用的方法:
withIntervalInHours(int intervalInHours)设置几小时重复一次
withIntervalInMinutes(int intervalInMinutes)设置几分钟重复一次
withIntervalInSeconds(int intervalInSeconds)设置几秒钟重复一次

(2)表达式模式

表达式模式就是可以通过时间表达式来具体指定在什么时间执行任务,可以用来时间比较复杂的时间调度,在这里设置了每小时51分的时候执行任务.

triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(new CronExpression("0 51 * * * ? ")));

关于时间表达式的语法在这里就不重复介绍了,想了解的同学点这里.我觉得也没必要去记,需要的时候可以借助这个工具去生成地址,如果不能满足要求,再去找资料就行了.

完整代码:

(1)简单模式
package com.jelly.quartz;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class TestJob1 {
    
    public static void main(String[] args) {
        
        try {
            //实例化JobDetail
            JobBuilder jobBuilder = JobBuilder.newJob(Job1.class);
            jobBuilder.withIdentity("job1", "group1");
            JobDetail jobDetail = jobBuilder.build();
            //实例化Trigger
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            triggerBuilder.withIdentity("tigger1", "group1");
            triggerBuilder.startNow();
            triggerBuilder.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(60).repeatForever());
            Trigger trigger = triggerBuilder.build();
            //开始任务
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
//            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
//            Scheduler scheduler = schedulerFactory.getScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.start();
            
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        
    }
    
}
(2)表达式模式
package com.jelly.quartz;

import org.quartz.CronExpression;
import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class TestJob2 {
    
    public static void main(String[] args) {
        
        try {
            
            JobBuilder jobBuilder = JobBuilder.newJob(Job1.class);
            jobBuilder.withIdentity("job1", "group1");
            JobDetail jobDetail = jobBuilder.build();
            
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            triggerBuilder.withIdentity("tigger1", "group1");
            triggerBuilder.startNow();
            triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(new CronExpression("0 51 * * * ? ")));
            Trigger trigger = triggerBuilder.build();
            
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.start();
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        
    }
    
}

打印结果:

(1)简单模式
2016-12-05 06:01:45 ---- start Job
2016-12-05 06:02:45 ---- start Job
2016-12-05 06:03:45 ---- start Job
(2)表达式模式
2016-12-05 06:51:00 ---- start Job
2016-12-05 07:51:00 ---- start Job
2016-12-05 08:51:00 ---- start Job

参考:
JavaDoc
documentation

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容