quartz基本使用【付属ソース】

最近quartzに設計する需要が多い.家に帰っていくつかのテストを書いてみます.全部で5つの書類がありますが、興味があれば見てもいいです.
その中でspring-quartzと原生態のquartzを分けてテストしました.
まずJobクラスを貼り付けます.
 

import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 *  job
 * @author Administrator
 *
 */
public class OrdinaryPrintJob implements Job {

	@Override
	public void execute(JobExecutionContext context)
			throws JobExecutionException {
		System.out.println("ordinary..."+new Date());
	}
}

Spring-quartz方式、jobは時間jobインタフェースを必要としない:

import java.util.Date;

import org.quartz.JobExecutionException;

/**
 * spring , job 
 *   
 * MethodInvokingJobDetailFactoryBean  MethodInvokingJob   QuartzJobBean， QuartzJobBean
 *  Job ， MethodInvokingJob  job targetMethod ， 
 * @author Administrator
 *
 */
public class SpringPrintJob {

	public void execute( )
			throws JobExecutionException {
		System.out.println("spring task.."+new Date());
	}

}

  
次に、mainメソッドを含む実際にテストされたクラスを示します.

/**
 *  
 * @author Administrator
 *
 */
public class ScheduleTest  {

	private static final String cron = "0/3 * * * * ?";
	
	/**
	 *  quartz
	 */
	public static void ordinaryScheduleTest () {
		OrdinaryTasker ot = new OrdinaryTasker(cron);
		executeProcess(ot);
	}
	
	/**
	 * spring quartz
	 */
	public static void springScheduleTest() {
		SpringTasker st = new SpringTasker(cron);
		executeProcess(st);
	}
	
	private static void executeProcess(TestTaskInterface tti) {
		//  
		tti.run();
		try {
			Thread.sleep(11000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		//  cron
		tti.changeTime();
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		//  
		tti.unschedual();
		//  
		tti.stop();
	}
	
	public static void main(String[] args) {
//		System.out.println("---------------java -------------------");
//		ordinaryScheduleTest(); //  
		System.out.println("---------------spring -------------------");
		springScheduleTest();     // spring ， java ， 
	}
	
	interface TestTaskInterface {
		
		public final String changedCron = "0/5 * * * * ?";
		
		public void run();
		
		public void stop();
		
		public void unschedual() ;
		
		public void changeTime();
	}
	
}

 
2つのスケジューリング方式を使用し、元の生態系:

import java.text.ParseException;
import java.util.Date;

import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;

import schedualer.ScheduleTest.TestTaskInterface;

public class OrdinaryTasker implements TestTaskInterface {

	private SchedulerFactory schedulerFactory = null;
	private Scheduler scheduler = null;
	private JobDetail jobDetail = null;
	private CronTrigger trigger = null;
	
	public OrdinaryTasker (String cron) {
		schedulerFactory = new StdSchedulerFactory();
		try {
			scheduler = schedulerFactory.getScheduler();
		} catch (SchedulerException e) {
			System.err.println(e);
		}
		assert(scheduler == null);
		jobDetail = new JobDetail();
		jobDetail.setJobClass(OrdinaryPrintJob.class);
		jobDetail.setName(this.getClass().getName()+"_job");
		try {
			trigger = new CronTrigger (this.getClass().getName()+"_trigger",null,cron);
		} catch (ParseException e) {
			System.err.println(e);
		}
		trigger.setStartTime(new Date());
	}
	
	@Override
	public void run() {
		try {
			//  job
			scheduler.scheduleJob(jobDetail,trigger);
			//  ， start ， job 
			scheduler.start();
			System.out.println("run start...");
		} catch (SchedulerException e) {
			e.printStackTrace();
		}
	}

	@Override
	public void stop() {
		try {
			scheduler.shutdown();
			System.out.println("stop start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		}
	}

	@Override
	public void unschedual() {
		try {
			scheduler.unscheduleJob(this.trigger.getName(), null);
			System.out.println("unschedual start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		}
	}

	@Override
	public void changeTime() {
		try {
			CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(trigger.getName(), null);
			cronTrigger.setCronExpression(TestTaskInterface.changedCron);
			scheduler.resumeTrigger(trigger.getName(), null);
			System.out.println("changeTime start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		} catch (ParseException e) {
			System.err.println(e);
		}
	}
	
}

 
Spring-quartz方式(もちろん、実際にはそうではありません.私はテストに使用しています):

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.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.scheduling.quartz.CronTriggerBean;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

import schedualer.ScheduleTest.TestTaskInterface;

/**
 * spring 
 * @author Administrator
 *
 */
public class SpringTasker implements TestTaskInterface {
	
	private SchedulerFactory schedulerFactory = null;
	private Scheduler scheduler = null;
	private JobDetail jobDetail = null;
	private CronTriggerBean trigger = null;
	
	public SpringTasker (String cron) {
		schedulerFactory = new StdSchedulerFactory();
		try {
			scheduler = schedulerFactory.getScheduler();
		} catch (SchedulerException e) {
			System.err.println(e);
		}
		assert(scheduler == null);
		// spring Jobdetail  
		MethodInvokingJobDetailFactoryBean mij = new MethodInvokingJobDetailFactoryBean();
		mij.setTargetObject( new SpringPrintJob());
		mij.setTargetMethod("execute");
		mij.setName(this.getClass().getName()+"_job");
		try {
			mij.afterPropertiesSet();
		} catch (ClassNotFoundException e1) {
			e1.printStackTrace();
		} catch (NoSuchMethodException e1) {
			e1.printStackTrace();
		}
		jobDetail = mij.getObject();
		trigger = new CronTriggerBean ();
		try {
			trigger.setCronExpression(new CronExpression(cron));
		} catch (ParseException e) {
			System.err.println(e);
		}
		trigger.setJobDetail(jobDetail);
		trigger.setName(this.getClass().getName()+"_trigger");
		try {
			trigger.afterPropertiesSet();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	@Override
	public void run() {
		SchedulerFactoryBean sfb = new SchedulerFactoryBean();
		sfb.setTriggers(new Trigger[]{trigger});
		try {
			sfb.afterPropertiesSet();
		} catch (Exception e1) {
			e1.printStackTrace();
		}
		try {
			scheduler = sfb.getObject();
			assert(scheduler == null);
			//spring scheduler  schedule ， sfb.afterPropertiesSet();  ， job 
			scheduler.start();
			System.out.println("run start...");
		} catch (SchedulerException e) {
			e.printStackTrace();
		}
	}

	@Override
	public void stop() {
		try {
			scheduler.shutdown();
			System.out.println("stop start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		}
	}

	@Override
	public void unschedual() {
		try {
			scheduler.unscheduleJob(this.trigger.getName(), null);
			System.out.println("unschedual start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		}
	}

	@Override
	public void changeTime() {
		try {
			CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(trigger.getName(), null);
			cronTrigger.setCronExpression(TestTaskInterface.changedCron);
			// 
			System.out.println(trigger.getCronExpression());
			// job pause ， block 
			//  
			scheduler.resumeJob(trigger.getName(), null);
			//  trigger, resume 
			//scheduler.rescheduleJob(trigger.getName(), null,cronTrigger);
			System.out.println("changeTime start...");
		} catch (SchedulerException e) {
			System.err.println(e);
		} catch (ParseException e) {
			System.err.println(e);
		}
	}
	
}

 
ScheduleTestクラスのmainメソッドを直接実行すると、元の生態とspring-quartzのスケジューリング結果が表示されます.
 
maven依存:

	<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>3.1.1.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context-support</artifactId>
			<version>3.1.1.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-tx</artifactId>
			<version>3.1.1.RELEASE</version>
		</dependency>
		<dependency>  
            <groupId>org.springframework</groupId>  
            <artifactId>spring-web</artifactId>  
            <version>3.0.5.RELEASE</version>  
        </dependency> 
		<dependency>
			<groupId>org.quartz-scheduler</groupId>
			<artifactId>quartz</artifactId>
			<version>1.8.5</version>
		</dependency>	

 
同級生が逃げられないならメッセージをください.