quartz2的example2

quartz2的example2

simplejob:

package com.imddy.test.quartz2.example2;

import java.util.Date;

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

public class SimpleJob implements Job {
	
	private static Logger logger = LoggerFactory.getLogger(SimpleJob.class);

	public SimpleJob() {
	}

	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		// TODO Auto-generated method stub
		JobKey jobKey = context.getJobDetail().getKey();
		logger.info("SimpleJob : " + jobKey + "工做時間在：" + new Date() );
	}

}

 

 

SimpleTiggerExample

package com.imddy.test.quartz2.example2;

import static org.quartz.DateBuilder.futureDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.JobKey.jobKey;
import static org.quartz.TriggerBuilder.newTrigger;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;

import java.util.Date;

import org.quartz.DateBuilder;
import org.quartz.DateBuilder.IntervalUnit;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SchedulerMetaData;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SimpleTriggerExample {
	
	private static Logger log = LoggerFactory.getLogger(SimpleTriggerExample.class);
	

	public SimpleTriggerExample() {
		
	}
	
	public void run() throws SchedulerException {

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

	    // First we must get a reference to a scheduler
	    SchedulerFactory sf = new StdSchedulerFactory();
	    Scheduler sched = sf.getScheduler();
	    
	    log.info("------- Scheduling Jobs ----------------");
	    
	    Date startTime = DateBuilder.nextGivenSecondDate(null, 15);
	    	    
	    JobDetail job = newJob(SimpleJob.class).withIdentity("job1", "group1").build();
	    SimpleTrigger trigger = (SimpleTrigger) newTrigger().withIdentity("trigger1", "group1").startAt(startTime).build();
	    
	    Date ft = sched.scheduleJob(job, trigger);
	    
	    log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	             + trigger.getRepeatInterval() / 1000 + " seconds");
	    
	    job = newJob(SimpleJob.class).withIdentity("job2", "group1").build();
	    trigger = (SimpleTrigger) newTrigger().withIdentity("trigger2", "group1").startAt(startTime).build();
	    
	    ft = sched.scheduleJob(job, trigger);
	    
	    log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	             + trigger.getRepeatInterval() / 1000 + " seconds");
	    
	    job = newJob(SimpleJob.class).withIdentity("job3", "group1").build();

	    trigger = newTrigger().withIdentity("trigger3", "group1").startAt(startTime)
	        .withSchedule(simpleSchedule().withIntervalInSeconds(10).withRepeatCount(10)).build();

	    ft = sched.scheduleJob(job, trigger);
	    log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	             + trigger.getRepeatInterval() / 1000 + " seconds");
	    
	    
	    
	    trigger = newTrigger().withIdentity("trigger3", "group2").startAt(startTime)
	            .withSchedule(simpleSchedule().withIntervalInSeconds(10).withRepeatCount(2)).forJob(job).build();

	        ft = sched.scheduleJob(trigger);
	        log.info(job.getKey() + " will [also] run at: " + ft + " and repeat: " + trigger.getRepeatCount()
	                 + " times, every " + trigger.getRepeatInterval() / 1000 + " seconds");

	        // job4 will run 6 times (run once and repeat 5 more times)
	        // job4 will repeat every 10 seconds
	        job = newJob(SimpleJob.class).withIdentity("job4", "group1").build();

	        trigger = newTrigger().withIdentity("trigger4", "group1").startAt(startTime)
	            .withSchedule(simpleSchedule().withIntervalInSeconds(10).withRepeatCount(5)).build();

	        ft = sched.scheduleJob(job, trigger);
	        log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	                 + trigger.getRepeatInterval() / 1000 + " seconds");

	        // job5 will run once, five minutes in the future
	        job = newJob(SimpleJob.class).withIdentity("job5", "group1").build();

	        trigger = (SimpleTrigger) newTrigger().withIdentity("trigger5", "group1")
	            .startAt(futureDate(5, IntervalUnit.MINUTE)).build();

	        ft = sched.scheduleJob(job, trigger);
	        log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	                 + trigger.getRepeatInterval() / 1000 + " seconds");

	        // job6 will run indefinitely, every 40 seconds
	        job = newJob(SimpleJob.class).withIdentity("job6", "group1").build();

	        trigger = newTrigger().withIdentity("trigger6", "group1").startAt(startTime)
	            .withSchedule(simpleSchedule().withIntervalInSeconds(40).repeatForever()).build();

	        ft = sched.scheduleJob(job, trigger);
	        log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	                 + trigger.getRepeatInterval() / 1000 + " seconds");
	        
	        log.info("------- Starting Scheduler ----------------");

	        // All of the jobs have been added to the scheduler, but none of the jobs
	        // will run until the scheduler has been started
	        sched.start();

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

	        // jobs can also be scheduled after start() has been called...
	        // job7 will repeat 20 times, repeat every five minutes
	        job = newJob(SimpleJob.class).withIdentity("job7", "group1").build();

	        trigger = newTrigger().withIdentity("trigger7", "group1").startAt(startTime)
	            .withSchedule(simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();

	        ft = sched.scheduleJob(job, trigger);
	        log.info(job.getKey() + " will run at: " + ft + " and repeat: " + trigger.getRepeatCount() + " times, every "
	                 + trigger.getRepeatInterval() / 1000 + " seconds");

	        // jobs can be fired directly... (rather than waiting for a trigger)
	        job = newJob(SimpleJob.class).withIdentity("job8", "group1").storeDurably().build();

	        sched.addJob(job, true);

	        log.info("'Manually' triggering job8...");
	        sched.triggerJob(jobKey("job8", "group1"));

	        log.info("------- Waiting 30 seconds... --------------");

	        try {
	          // wait 33 seconds to show jobs
	          Thread.sleep(30L * 1000L);
	          // executing...
	        } catch (Exception e) {
	          //
	        }

	        // jobs can be re-scheduled...
	        // job 7 will run immediately and repeat 10 times for every second
	        log.info("------- Rescheduling... --------------------");
	        trigger = newTrigger().withIdentity("trigger7", "group1").startAt(startTime)
	            .withSchedule(simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();

	        ft = sched.rescheduleJob(trigger.getKey(), trigger);
	        log.info("job7 rescheduled to run at: " + ft);

	        log.info("------- Waiting five minutes... ------------");
	        try {
	          // wait five minutes to show jobs
	          Thread.sleep(300L * 1000L);
	          // executing...
	        } catch (Exception e) {
	          //
	        }

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

	        sched.shutdown(true);

	        log.info("------- Shutdown Complete -----------------");

	        // display some stats about the schedule that just ran
	        SchedulerMetaData metaData = sched.getMetaData();
	        log.info("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");
		
	}


	public static void main(String[] args) throws SchedulerException {
		SimpleTriggerExample example = new SimpleTriggerExample();
	    example.run();

	}

}

 

同一個job任務，能夠創建多tigger調度