listenertest.java

定时器开源项目, 相对于 jcrontab, Quartz 算是更完整的一个项目, 随著开发的版本上来, 他已经脱离只是写在程序里面的计时器, 在指定的时间或区间, 处理所指定的事件. 也加入了 se

/*
 * Copyright James House (c) 2001-2004
 * 
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met: 1.
 * Redistributions of source code must retain the above copyright notice, this
 * list of conditions and the following disclaimer. 2. Redistributions in
 * binary form must reproduce the above copyright notice, this list of
 * conditions and the following disclaimer in the documentation and/or other
 * materials provided with the distribution.
 * 
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND ANY
 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE FOR ANY
 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *  
 */
package org.quartz.examples;

import java.util.Date;

import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobListener;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;

import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;

/**
 * @author James House
 */
public class ListenerTest {

    public static void schedTest(SchedulerFactory sf) throws Exception {
        Log lg = LogFactory.getLog(ListenerTest.class);

        lg.info("------- Initializing -------------------");

        Scheduler sched = sf.getScheduler();

        // 'global' listeners are called when ANY job is executed
        sched.addGlobalJobListener(new MyJobListener("myListener1"));
        // 'non-global' listeners are called when jobs that register for them
        // are executed. (see job creation below)
        sched.addJobListener(new MyJobListener("myListener2"));

        // remove entries that may be lingering in a JDBCJobStore from previous
        // run of this example... (obviously this doesn't matter for
        // RAMJobStore)
        sched.unscheduleJob("trigg1", "group1");

        lg.info("------- Initialization Complete -----------");

        lg.info("------- Scheduling Jobs -----------");

        // jobs can be scheduled before start() has been called

        long ts = System.currentTimeMillis() + 4000l; // get time a few secons
                                                      // in the future...

        JobDetail job = new JobDetail("job1", "group1", DumbJob.class);
        // register JobListener for this job (more than 1 can be registered if
        // you wish)
        job.addJobListener("myListener2");
        SimpleTrigger trigger = new SimpleTrigger("trigg1", "group1", "job1",
                "group1", new Date(ts), null, 0, 0);
        lg.info(job.getFullName() + " will run at: "
                + trigger.getNextFireTime() + " & repeat: "
                + trigger.getRepeatCount() + "/" + trigger.getRepeatInterval());
        sched.scheduleJob(job, trigger);

        job = new JobDetail("job2", "group1", DumbJob.class);
        // this job does not register for 'myListener2' so it will not be
        // notified...
        trigger = new SimpleTrigger("trigg2", "group1", "job2", "group1",
                new Date(ts + 4000l), null, 0, 0);
        lg.info(job.getFullName() + " will run at: "
                + trigger.getNextFireTime() + " & repeat: "
                + trigger.getRepeatCount() + "/" + trigger.getRepeatInterval());
        sched.scheduleJob(job, trigger);

        lg.info("------- Starting Scheduler ----------------");

        // jobs don't start firing until start() has been called...

        sched.start();

        lg.info("------- Started Scheduler -----------------");

        lg.info("------- Waiting... -----------------------");

        try {
            Thread.sleep(30l * 1000l);
        } catch (Exception e) {
        }

        lg.info("------- Shutting Down ---------------------");

        sched.shutdown();

        lg.info("------- Shutdown Complete -----------------");
    }

    public static void main(String[] args) throws Exception {
        try {

            // Configure Log4J
            // org.apache.log4j.PropertyConfigurator.configure(System.getProperty("log4jConfigFile",
            // "log4j.properties"));

            schedTest(new org.quartz.impl.StdSchedulerFactory());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class MyJobListener implements JobListener {

    String name;

    public MyJobListener(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public void jobToBeExecuted(JobExecutionContext context) {
        System.err.println(".......(" + name + "): jobToBeExecuted: "
                + context.getJobDetail().getFullName());
    }

    public void jobWasExecuted(JobExecutionContext context,
            JobExecutionException jobException) {
        System.err.println(".......(" + name + "): jobWasExecuted: "
                + context.getJobDetail().getFullName());
    }

    /** 
     * @see org.quartz.JobListener#jobExecutionVetoed(org.quartz.JobExecutionContext)
     */
    public void jobExecutionVetoed(JobExecutionContext context) {
         // TODO Auto-generated method stub
    }

}