`
guoweimail
  • 浏览: 205685 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Quartz 框架快速入门(一)

    博客分类:
  • Java
阅读更多
    创建一个 Java 工程,引入几个 JAR 到工程中才能成功构建它们。首先,你需要 Quartz 的二进制版本,包的名字是 quartz-<version>.jar。Quartz 还需要几个第三方库;这依赖于你要用到框架的什么功能而定,Commons Digester 库可以在 <QUARTZ_HOME>/lib/core 和 <QUARTZ_HOME>/lib/optional 目录中找到。如果出现java.lang.NoClassDefFoundError: javax/transaction/UserTransaction的错误,解决办法是:引入jta.jar包,这个包在quartz-1.6.0/lib/build 下。

·创建一个 Quartz Job 类

每一个 Quartz Job 必须有一个实现了 org.quartz.Job 接口的具体类。这个接口仅有一个要你在 Job 中实现的方法,execute(),方法 execute() 的原型如下:
public void execute(JobExecutionContext context) throws JobExecutionException;

当 Quartz 调度器确定到时间要激发一个 Job 的时候,它就会生成一个 Job 实例,并调用这个实例的 execute() 方法。调度器只管调用 execute() 方法,而不关心执行的结果,除了在作业执行中出问题抛出的 org.quartz.JobExecutionException 异常。

下面是我们的第一个 Quartz job,它被设计来扫描一个目录中的文并显示文件的详细信息。

package com.vista.quartz;
import java.io.File;      
import java.io.FileFilter;
import java.util.Date;      
     
import org.apache.commons.logging.Log;      
import org.apache.commons.logging.LogFactory;      
import org.quartz.Job;      
import org.quartz.JobDataMap;      
import org.quartz.JobDetail;      
import org.quartz.JobExecutionContext;      
import org.quartz.JobExecutionException; 

public class ScanDirectoryJob implements Job
{
    static Log logger = LogFactory.getLog(ScanDirectoryJob.class);//日志记录器
   
    public void execute(JobExecutionContext context) throws JobExecutionException
    {
        //Every job has its own job detail      
        JobDetail jobDetail = context.getJobDetail();      
        // The name is defined in the job definition      
        String jobName = jobDetail.getName();//任务名称      
        // Log the time the job started      
        logger.info(jobName + " fired at " + new Date());//记录任务开始执行的时间      
        // The directory to scan is stored in the job map      
        JobDataMap dataMap = jobDetail.getJobDataMap();//任务所配置的数据映射表      
        String dirName = dataMap.getString("SCAN_DIR");//获取要扫描的目录      
        // Validate the required input      
        if (dirName == null)
        {//所需要的扫描目录没有提供      
             throw new JobExecutionException( "Directory not configured" );      
        }      
        // Make sure the directory exists      
        File dir = new File(dirName);      
        if (!dir.exists())
        {//提供的是错误目录      
            throw new JobExecutionException( "Invalid Dir "+ dirName);      
        }      
        // Use FileFilter to get only XML files      
        FileFilter filter = new FileExtensionFileFilter(".xml");      
        //只统计xml文件
        File[] files = dir.listFiles(filter);      
        if (files == null || files.length <= 0)
        {//目录下没有xml文件      
            logger.info("No XML files found in " + dir);      
            // Return since there were no files      
            return;
        }      
        // The number of XML files      
        int size = files.length;         
        // Iterate through the files found      
        for (int i = 0; i < size; i++)
        {
            File file = files[i];      
            // Log something interesting about each file.      
            File aFile = file.getAbsoluteFile();      
            long fileSize = file.length();      
            String msg = aFile + " - Size: " + fileSize;      
            logger.info(msg);//记录下文件的路径和大小
        }
    }
}

     当 Quartz 调用 execute() 方法,会传递一个 org.quartz.JobExecutionContext 上下文变量,里面封装有 Quartz 的运行时环境和当前正执行的 Job。通过 JobexecutionContext,你可以访问到调度器的信息,作业和作业上的触发器的信息,还有更多更多的信息。在代码中,JobExecutionContext 被用来访问 org.quartz.JobDetail 类,JobDetail 类持有 Job 的详细信息,包括为 Job 实例指定的名称,Job 所属组,Job 是否被持久化(易失性),和许多其他感兴趣的属性。

JobDetail 又持有一个指向 org.quartz.JobDataMap 的引用。JobDataMap 中有为指定 Job 配置的自定义属性。例如,在代码中我们从 JobDataMap 中获得欲扫描的目录名,我们可以在 ScanDirectoryJob 中硬编码这个目录名,但是这样的话我们难以重用这个 Job 来扫描别的目录了。在后面你将会看到目录是如何配置到 JobDataMap 的。

execute() 方法中剩下的就是标准 Java 代码了:获得目录名并创建一个 java.io.File 对象。它还对目录名作为简单的校验,确保是一个有效且存在的目录。接着调用 File 对象的 listFiles() 方法得到目录下的文件。还创建了一个 java.io.FileFilter 对象作为参数传递给 listFiles() 方法。org.quartzbook.cavaness.FileExtensionFileFilter 实现了 java.io.FileFilter 接口,它的作用是过滤掉目录仅返回 XML 文件。默认情况下,listFiles() 方法是返回目录中所有内容,不管是文件还是子目录,所以我们必须过滤一下,因为我们只对 XML 文件感兴趣。

FileExtensionFileFilter 被用来屏蔽名称中不含字符串 “.xml” 的文件。它还屏蔽了子目录--这些子目录原本会让 listFiles() 方法正常返回。过滤器提供了一种很便利的方式选择性的向你的 Quartz 作业提供它能接受的作为输入的文件

package com.vista.quartz;
import  java.io.File;      
import  java.io.FileFilter;  

public class FileExtensionFileFilter implements  FileFilter
{
     private  String extension;//文件后缀    
    
     public  FileExtensionFileFilter(String extension)
     {      
         this.extension = extension;
     }            
     public   boolean  accept(File file)
     {//只接受指定后缀的文件      
         // Lowercase the filename for easier comparison      
         String lCaseFilename = file.getName().toLowerCase();//小写化
         return  (file.isFile() &&(lCaseFilename.indexOf(extension) >  0 )) ?  true : false ;      
     }      
}

到目前为止,我们已经创建了一个 Quartz job,但还没有决定怎么处置它--明显地,我们需以某种方式为这个 Job 设置一个运行时间表。时间表可以是一次性的事件,或者我们可能会安装它在除周日之外的每个午夜执行。你即刻将会看到,Quartz Schduler 是框架的心脏与灵魂。所有的 Job 都通过 Schduler 注册;必要时,Scheduler 也会创建 Job 类的实例,并执行实例的 execute() 方法。

·编程式安排一个 Quartz Job

所有的要 Quartz 来执行的作业必须通过调度器来注册。大多情况下,这会在调度器启动前做好。正如前面说过,这一操作也提供了声明式与编程式两种实现途径的选择。

因为每一个 Job 都必须用 Scheduler 来注册,所以先定义一个 JobDetail,并关联到这个 Scheduler 实例。

下面的程序提供了一个理解如何编程式安排一个 Job 很好的例子。代码首先调用 createScheduler() 方法从 Scheduler 工厂获取一个 Scheduler 的实例。得到 Scheduler 实例之后,把它传递给 schedulerJob() 方法,由它把 Job 同 Scheduler 进行关联。

首先,创建了我们想要运行的 Job 的 JobDetail 对象。JobDetail 构造器的参数中包含指派给 Job 的名称,逻辑组名,和实现 org.quartz.Job 接口的全限类名称。我们可以使用 JobDetail 的别的构造器。

在前面有说过,JobDetail 扮演着某一 Job 定义的角色。它带有 Job 实例的属性,能在运行时被所关联的 Job 访问到。其中在使用 JobDetail 时,的一个最重要的东西就是 JobDataMap,它被用来存放 Job 实例的状态和参数。在代码中,待扫描的目录名称就是通过  scheduleJob() 方法存入到 JobDataMap 中的。

Job 只是一个部分而已。注意我们没有在 JobDetail 对象中为 Job 设定执行日期和次数。这是 Quartz Trigger 该做的事。顾名思义,Trigger 的责任就是触发一个 Job 去执行。当用 Scheduler 注册一个 Job 的时候要创建一个 Trigger 与这个 Job 相关联。Quartz 提供了四种类型的 Trigger,但其中两种是最为常用的,它们就是在下面要用到的 SimpleTrigger 和  CronTrigger.

SimpleTrigger 是两个之中简单的那个,它主要用来激发单事件的 Job,Trigger 在指定时间激发,并重复 n 次--两次激发时间之间的延时为 m,然后结束作业。CronTrigger 非常复杂且强大。它是基于通用的公历,当需要用一种较复杂的时间表去执行一个 Job 时用到。例如,四月至九月的每个星期一、星期三、或星期五的午夜。

为更简单的使用 Trigger,Quartz 包含了一个工具类,叫做 org.quartz.TriggerUtils. TriggerUtils 提供了许多便捷的方法简化了构造和配置 trigger. 本文的例子中有用的就是 TriggerUtils 类;SimpleTrigger 和 CronTrigger 会在后面用到。

正如你看到的那样,调用了 TriggerUtils 的方法 makeSecondlyTrigger() 来创建一个每10秒种激发一次的 trigger(实际是由 TriggerUtils 生成了一个 SimpleTrigger 实例,但是我们的代码并不想知道这些)。我们同样要给这个 trigger 实例一个名称并告诉它何时激发相应的 Job;与之关联的 Job 会立即启动,因为由方法 setStartTime() 设定的是当前时间

package com.vista.quartz;

import java.util.Date;      

import org.apache.commons.logging.Log;      
import org.apache.commons.logging.LogFactory;      
import org.quartz.JobDetail;
import org.quartz.Scheduler;      
import org.quartz.SchedulerException;      
import org.quartz.Trigger;
import org.quartz.TriggerUtils;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleScheduler
{
    static Log logger = LogFactory.getLog(SimpleScheduler.class);        
    public static void main(String[] args)
    {      
         SimpleScheduler simple = new SimpleScheduler();      
         try
         {      
             // Create a Scheduler and schedule the Job      
             Scheduler scheduler = simple.createScheduler();      
             simple.scheduleJob(scheduler);      
   
             // Start the Scheduler running      
             scheduler.start();      
   
             logger.info( "Scheduler started at " + new Date());      
   
        } catch (SchedulerException ex) {      
             logger.error(ex);      
        }  
       
    }      
    public Scheduler createScheduler() throws SchedulerException
    {//创建调度器      
        return StdSchedulerFactory.getDefaultScheduler();
    }  
   
    //Create and Schedule a ScanDirectoryJob with the Scheduler      
    private void scheduleJob(Scheduler scheduler) throws SchedulerException
    {      
         // Create a JobDetail for the Job      
         JobDetail jobDetail = new JobDetail("ScanDirectory",Scheduler.DEFAULT_GROUP,ScanDirectoryJob.class);
         // Configure the directory to scan      
         jobDetail.getJobDataMap().put("SCAN_DIR","D:\\Tomcat\\conf"); //set the JobDataMap that is associated with the Job.           
         // Create a trigger that fires every 10 seconds, forever      
         Trigger trigger = TriggerUtils.makeSecondlyTrigger(10);//每10秒触发一次      
         trigger.setName("scanTrigger");      
         // Start the trigger firing from now      
         trigger.setStartTime(new Date());//设置第一次触发时间           
         // Associate the trigger with the job in the scheduler      
         scheduler.scheduleJob(jobDetail, trigger);      
    }      
}


     假如你有不只一个个 Job (你也许就是),你将需要为每一个 Job 创建各自的 JobDetail。每一个 JobDetail 必须通过 scheduleJob() 方法一一注册到 Scheduler 上。而如果你想重用了一个 Job 类,让它产生多个实例运行,那么你需要为每个实例都创建一个 JobDetail。例如,假如你想重用 ScanDirectoryJob 让它检查两个不同的目录,你需要创建并注册两个 JobDetail 实例

package com.vista.quartz;

import java.util.Date;      

import org.apache.commons.logging.Log;      
import org.apache.commons.logging.LogFactory;      
import org.quartz.JobDetail;
import org.quartz.Scheduler;      
import org.quartz.SchedulerException;      
import org.quartz.Trigger;
import org.quartz.TriggerUtils;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleScheduler
{
    static Log logger = LogFactory.getLog(SimpleScheduler.class);        
    public static void main(String[] args)
    {      
         SimpleScheduler simple = new SimpleScheduler();      
         try
         {      
             // Create a Scheduler and schedule the Job      
             Scheduler scheduler = simple.createScheduler();        
             // Jobs can be scheduled after Scheduler is running      
             scheduler.start();         
             logger.info("Scheduler started at " + new Date());        
             // Schedule the first Job      
             simple.scheduleJob(scheduler, "ScanDirectory1",ScanDirectoryJob.class,"D:\\conf1", 10);         
             // Schedule the second Job      
             simple.scheduleJob(scheduler, "ScanDirectory2",ScanDirectoryJob.class,"D:\\conf2 ", 15);      
        }
        catch (SchedulerException ex)
        {      
             logger.error(ex);      
        }      
    }      
    public Scheduler createScheduler() throws SchedulerException
    {//创建调度器      
        return StdSchedulerFactory.getDefaultScheduler();
    }  
   
    private void scheduleJob(Scheduler scheduler, String jobName,Class jobClass, String scanDir, int scanInterval) throws SchedulerException
    {        
        // Create a JobDetail for the Job      
       JobDetail jobDetail = new JobDetail(jobName,Scheduler.DEFAULT_GROUP, jobClass);        
       // Configure the directory to scan      
       jobDetail.getJobDataMap().put("SCAN_DIR", scanDir);        
       // Trigger that repeats every "scanInterval" secs forever      
       Trigger trigger = TriggerUtils.makeSecondlyTrigger(scanInterval);        
       trigger.setName(jobName + "-Trigger");        
       // Start the trigger firing from now      
       trigger.setStartTime(new Date());        
       // Associate the trigger with the job in the scheduler      
       scheduler.scheduleJob(jobDetail, trigger);      
  }      
}

分享到:
评论

相关推荐

    Quartz框架快速入门

    ### Quartz框架快速入门详解 #### 一、Quartz框架简介 Quartz是一个开源的作业调度框架,用于开发Java应用程序。它提供了强大的触发器(Trigger)机制用于关联作业(Job),同时还具备灵活的表达式用于配置定时...

    Quartz 框架快速入门

    Quartz 框架快速入门 在前面两篇文章中简单介绍了在java应用程序中如何使用Quartz框架,这一篇中我们将看到如何在web环境下通过配置文件来完成Quartz的后台作业调度,而不必手工去创建Trigger和Scheduler

    Quartz框架快速入门.pdf

    Quartz框架是一款强大的开源任务调度库,广泛应用于Java环境下的定时任务管理。要开始使用Quartz,首先需要在项目中引入必要的依赖。基础依赖是quartz-&lt;version&gt;.jar,这是Quartz的核心库。除此之外,根据你的需求,...

    Quartz_框架快速入门

    本文将引导您快速入门 Quartz 框架,了解其基本使用方法。 首先,要开始使用 Quartz,您需要从官方网站下载对应的 JAR 包,通常为 quartz-&lt;version&gt;.jar。除此之外,根据您的需求,Quartz 可能还需要一些第三方库,...

    Quartz如何从入门到精通.pdf

    Quartz入门到精通 Quartz是一个开源的作业调度框架,它...Quartz框架是一个非常实用的作业调度框架,它可以满足各种复杂的作业调度需求。使用Quartz框架,你可以轻松地实现各种复杂的作业调度,并且它非常灵活和强大。

    Java框架介绍Quartz从入门到进阶.pdf

    Quartz框架介绍和应用 Quartz是一个完全由Java编写的开源作业调度...Quartz框架是一个功能强大且灵活的作业调度框架,能够满足企业级的作业调度需求,开发者可以快速地创建和调度作业,提高工作效率和自动化处理能力。

    Quartz定时器从入门到进阶

    Quartz定时器是一个开源的作业调度框架,专为J2SE和J2EE应用程序设计,完全用Java编写。它的核心优势在于提供强大的灵活性和简单性,使得开发者可以轻松创建简单的或复杂的任务调度。Quartz支持多种特性,如数据库...

    quartz实例,quartz入门例子

    Quartz是一款开源的作业调度框架,它允许开发者创建、组织和执行计划任务。这个实例是为初学者设计的,用于帮助理解Quartz的基本概念和使用方式。在MyEclipse 6.0.1环境下,你可以直接运行这个Spring整合Quartz的...

    Quartz任务调度快速入门

    #### 一、Quartz框架简介 Quartz是一个功能强大的开源作业调度框架,被广泛应用于Java应用中实现任务的定时调度。Quartz通过对任务调度领域的核心问题进行高度抽象,提炼出了三个核心概念:**调度器(Scheduler)**...

    任务调度Quartz框架

    Quartz框架自2001年发布以来,已经在许多项目中得到广泛应用。它提供了灵活的时间表定义,使得开发者可以精确地设定任务的触发时间。Quartz不仅支持一次性任务,还支持周期性的重复任务。框架的核心特性包括: 1. *...

    分布式调度框架quartz从入门到精通

    分布式调度框架Quartz是OpenSymphony开源组织推出的一款强大的任务调度工具,专为Java平台设计。Quartz可以方便地与其他J2EE或J2SE应用结合,也可以单独使用。它支持创建复杂的工作流,能够处理从简单到成千上万个...

    Quartz中文入门教程

    Quartz中文入门教程 前言 Quartz让任务调度简单 Quartz的发展史 上手Quartz Quartz内部架构 作业 作业管理和存储 有效作业存储 ...Quartz框架的其他特征 Quartz下一步计划 了解更多Quartz特征

    任务调度框架Quartz

    Quartz 是一个功能强大且灵活的任务调度框架,广泛应用于各种企业应用中,例如定时清理系统垃圾文件、定时导入导出数据、定时发送邮件等等业务场景。Quartz 提供了高度可控的任务调度功能,能够满足大多数的调度需求...

Global site tag (gtag.js) - Google Analytics