OpenSymphony的Quartz里的作业、调度器使用举例

 任务调度框架，它简单、易用。既可在单机J2SE应用中使用，也可在web应用中使用。 

     下载地址：http://www./quarz/download.action，quarz现在最新的版本是1.6。

     如果需要在web应用中使用Quartz，只需将quartz-1.6.jar or quartz-all-1.6.jar文件复制到WEB-INF的lib目录下即可。

    一. Quarz的配置文件quartz.properties的介绍

    将该文件放在Wen应用的src目录下，使用举例如下：

    # 配置主调度属性
   org.quartz.scheduler.instanceName = QuartzScheduler
   org.quartz.scheduler.instanceId = AUTO
   # 配置线程池
   org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool

   # 配置线程池的线程数量
   org.quartz.threadPool.threadCount = 5

   # 配置线程池里线程的优先级

   org.quartz.threadPool.threadPriority = 5
   # 配置作业存储
   org.quartz.jobStore.misfireThreshold = 60000
   org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

    二. Quarz中的作业使用举例

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.util.*;

public class TestJob implements Job
{
    
    public void execute(JobExecutionContext context) throws JobExecutionException
    {
        System.out.println(new Date() +"    作业调度开始。");
        for (int i = 0; i < 100 ; i++)
        {
            System.out.println("作业完成" + i + 1 + "%");
        }
        System.out.println(new Date() +"    作业调度结束。");

    }
}

    三. Quarz里的调度器使用举例

import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.JobDetail;
import org.quartz.SchedulerException;
import org.quartz.SimpleTrigger;

public class MyQuartzServer
{
    public static void main(String[] args)
    {
        MyQuartzServer server = new MyQuartzServer();
        try
        {
            server.startScheduler();
        }
        catch (SchedulerException ex)
        {
            ex.printStackTrace(); 
        }
    }
    
    protected void startScheduler() throws SchedulerException 
    {
        //使用工厂创建调度器实例
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); 
        //以作业创建JobDetail实例
        JobDetail jobDetail = new JobDetail("dd", Scheduler.DEFAULT_GROUP,TestJob.class);
        //创建trigger
        Trigger trigger = new SimpleTrigger("dd",Scheduler.DEFAULT_GROUP, 5000, 200) ;
        //调度器将作业与trigger关联起来
        scheduler.scheduleJob(jobDetail, trigger ); 
        //开始调度
        scheduler.start();
    }
}

 

posted on 2007-02-22 15:18 阿蜜果 阅读(2083) 评论(7)  编辑  收藏 所属分类: Open Source