作业调度框架Quartz

时间：2021-04-13 08:08:22
Quartz是一个完全由java编写的开源作业调度框架。

一、Quartz的几个核心的接口和类为

Job接口：自己写的“定时程序”实现此接口的void execute(JobExecutionContext arg0)方法，Job还有一类为有状态的StatefulJob接口，如果我们需要在上一个作业执行完后，根据其执行结果再进行下次作业的执行，则需要实现此接口。
Trigger抽象类：调度类(Scheduler)在时间到时调用此类，再由trigger类调用指定的定时程序。
Quertz中提供了两类触发器为：SimpleTrigger,CronTrigger。前者用于实现比较简单的定时功能，例如几点开始，几点结束，隔多长时间执行，共执行多少次等，后者提供了使用表达式来描述定时功能，因此适用于比较复杂的定时描述，例如每个月的最后一个周五，每周的周四等。
JobDetail类：具体某个定时程序的详细描述，包括Name,Group,JobDataMap等。
JobExecutionContext类：定时程序执行的run-time的上下文环境，用于得到当前执行的Job的名字，配置的参数等。
JobDataMap类：用于描述一个作业的参数，参数可以为任何基本类型例如String,float等，也可为某个对象的引用.
JobListener、TriggerListener接口：用于监听触发器状态和作业扫行状态，在特写状态执行相应操作。
JobStore类：在哪里执行定进程序，可选的有在内存中，在数据库中。

二、依赖jar

org.quartz-scheduler
配合使用：org.slf4j、slf4j-nop
如果只导入org.slf4j，会报错，信息如下：
 
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
下载slf4j-nop.jar，添加到路径中或在maven配置中添加支持，就解决问题了！

三、示例

package com.test.quartzDemo;

import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SimpleJob implements Job{

private static Logger _log = LoggerFactory.getLogger(SimpleJob.class); 
//①实例Job接口方法
public void execute(JobExecutionContext jobCtx)throws JobExecutionException {
System.out.println("纸上得来终觉浅，绝知此事要躬行！"+"==="+new Date());
System.out.println("=================================");
}
}
注意，需要导入的静态代码块：
import static org.quartz.JobBuilder.*; 
import static org.quartz.SimpleScheduleBuilder.*; 
import static org.quartz.CronScheduleBuilder.*; 
import static org.quartz.CalendarIntervalScheduleBuilder.*; 
import static org.quartz.TriggerBuilder.*; 
import static org.quartz.DateBuilder.*;
 
package com.test.quartzDemo;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;

import static org.quartz.JobBuilder.*; 
import static org.quartz.SimpleScheduleBuilder.*; 
import static org.quartz.TriggerBuilder.*; 
import static org.quartz.CronScheduleBuilder.*; 
import static org.quartz.CalendarIntervalScheduleBuilder.*; 
import static org.quartz.DateBuilder.*;

public class SimpleTriggerRunner {
    public static void main( String[] args ){
    try {
    // 通过SchedulerFactory获取一个调度器实例
    SchedulerFactory schedulerFactory = new StdSchedulerFactory();
    Scheduler scheduler = schedulerFactory.getScheduler();
    // 调度启动
    scheduler.start();

    // 创建一个JobDetail实例，指定SimpleJob
    JobDetail jobDetail = newJob(SimpleJob.class)
    .withIdentity("myJob", "group1")
    .build();

    // 通过SimpleTrigger定义调度规则：马上启动，每40秒运行一次
    SimpleTrigger simpleTrigger = newTrigger()
    .withIdentity("myTrigger", "group1") 
     .startNow() 
     .withSchedule(simpleSchedule()
     .withIntervalInSeconds(40) 
     .repeatForever()) 
     .build(); 

    // 注册并进行调度
    scheduler.scheduleJob(jobDetail, simpleTrigger);

    } catch (Exception e) {
    e.printStackTrace();
    }
    }
}

四、参考文献

官网地址，提供了可参考示例及API：http://www.quartz-scheduler.org/

很好的讲解，强烈推荐：http://topmanopensource.iteye.com/blog/search?query=quartz 


标签：

相关文章