Quartz 简单的一个实例

SimpleJob.java

 

package com.test.job;

 

import org.quartz.Job;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

 

public class SimpleJob implements Job{

    public void execute(JobExecutionContext context)

           throws JobExecutionException {

       // your business logic

       // ...

       System.out.println("simpleJob running ....");

    }

}

TestSimpleJob.java

 

package com.test.job;

 

import java.text.ParseException;

 

import org.quartz.CronExpression;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.SimpleTrigger;

import org.quartz.impl.StdSchedulerFactory;

 

public class TestSimpleJob {

    public static void main(String[] args){

       try {

           Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

          

           String jobName = "simpleJob";

           String groupName = "DEFAULT";

          

           //删除作业

           if(scheduler.getJobDetail(jobName,groupName) != null){

              scheduler.deleteJob(jobName, groupName);

           }

          

           //作业的详细信息

           //任务名称，任务组名称，任务实现类

           JobDetail jobDetail = new JobDetail(jobName,groupName,SimpleJob.class);

          

           //创建简单触发器

           SimpleTrigger simpleTrigger = new SimpleTrigger("simpleTrigger",null);

 

           simpleTrigger.setRepeatCount(100); // 调用100次

           simpleTrigger.setRepeatInterval(5*1000);  //每5秒钟调用一次

 

           //注册作业

           scheduler.scheduleJob(jobDetail, simpleTrigger);

          

          

           CronTrigger cronTrigger = new CronTrigger("cronTrigger",null);

           CronExpression cronExpression = null;

           try {

              cronExpression = new CronExpression("0 0 12 * * ?");  //每天12点运行

              cronTrigger.setCronExpression(cronExpression);

             

              //注册作业

              scheduler.scheduleJob(jobDetail, cronTrigger);

             

              if(! scheduler.isShutdown()){

                  scheduler.start();

              }

             

          

           } catch (ParseException e) {

              e.printStackTrace();

           }

          

       } catch (SchedulerException e) {

           e.printStackTrace();

       }

    }

}