Quartz 两种实现方式

谁践踏了优雅 2021-09-10 14:02 453阅读 0赞

# Example to run multiple jobs in Quartz #

By [mkyong][] | July 30, 2012 | Updated : August 29, 2012

In this example, we show you how to declare multiple Quartz jobs via Quartz APIs, Quartz XML and Spring. In Quartz scheduler framework, each job will be attached to an unique trigger, and run it by scheduler.

P.S In Quartz, one trigger for multiple jobs is not possible. (Correct me if this is wrong.)

## 1. Quartz APIs ##

Create 3 Quartz’s jobs, JobA, JobB and JobC.

package com.mkyong.quartz; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class JobA implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Job A is runing"); } }

package com.mkyong.quartz; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class JobB implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Job B is runing"); } }

package com.mkyong.quartz; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class JobC implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Job C is runing"); } }

Use Quartz APIs to declare above 3 Jobs, assigned to 3 particular triggers and schedule it.

package com.mkyong.quartz; import org.quartz.CronScheduleBuilder; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.impl.StdSchedulerFactory; public class CronTriggerExample { public static void main( String[] args ) throws Exception { JobKey jobKeyA = new JobKey("jobA", "group1"); JobDetail jobA = JobBuilder.newJob(JobA.class) .withIdentity(jobKeyA).build(); JobKey jobKeyB = new JobKey("jobB", "group1"); JobDetail jobB = JobBuilder.newJob(JobB.class) .withIdentity(jobKeyB).build(); JobKey jobKeyC = new JobKey("jobC", "group1"); JobDetail jobC = JobBuilder.newJob(JobC.class) .withIdentity(jobKeyC).build(); Trigger trigger1 = TriggerBuilder .newTrigger() .withIdentity("dummyTriggerName1", "group1") .withSchedule( CronScheduleBuilder.cronSchedule("0/5 * * * * ?")) .build(); Trigger trigger2 = TriggerBuilder .newTrigger() .withIdentity("dummyTriggerName2", "group1") .withSchedule( CronScheduleBuilder.cronSchedule("0/5 * * * * ?")) .build(); Trigger trigger3 = TriggerBuilder .newTrigger() .withIdentity("dummyTriggerName3", "group1") .withSchedule( CronScheduleBuilder.cronSchedule("0/5 * * * * ?")) .build(); Scheduler scheduler = new StdSchedulerFactory().getScheduler(); scheduler.start(); scheduler.scheduleJob(jobA, trigger1); scheduler.scheduleJob(jobB, trigger2); scheduler.scheduleJob(jobC, trigger3); } }

Output

Job A is runing //every 5 seconds
    Job B is runing
    Job C is runing
    Job A is runing //every 5 seconds
    Job B is runing
    Job C is runing

## 2. Quartz XML Example ##

The equivalent version in XML file. Make sure “quartz.properties” and “quartz-config.xml” are located at project classpath.

File – quartz.properties

org.quartz.scheduler.instanceName = MyScheduler
    org.quartz.threadPool.threadCount = 3
    org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
    org.quartz.plugin.jobInitializer.class =org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin 
    org.quartz.plugin.jobInitializer.fileNames = quartz-config.xml 
    org.quartz.plugin.jobInitializer.failOnFileNotFound = true

File – quartz-config.xml

<?xml version="1.0" encoding="UTF-8"?>
    <job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.quartz-scheduler.org/xml/JobSchedulingData http://www.quartz-scheduler.org/xml/job_scheduling_data_1_8.xsd" version="1.8">
    
    	<schedule>
    		<job>
    			<name>JobA</name>
    			<group>GroupDummy</group>
    			<description>This is Job A</description>
    			<job-class>com.mkyong.quartz.JobA</job-class>
    		</job>
    
    		<trigger>
    			<cron>
    				<name>dummyTriggerNameA</name>
    				<job-name>JobA</job-name>
    				<job-group>GroupDummy</job-group>
    				
    				<cron-expression>0/5 * * * * ?</cron-expression>
    			</cron>
    		</trigger>
    	</schedule>
    	
    	<schedule>
    		<job>
    			<name>JobB</name>
    			<group>GroupDummy</group>
    			<description>This is Job B</description>
    			<job-class>com.mkyong.quartz.JobB</job-class>
    		</job>
    
    		<trigger>
    			<cron>
    				<name>dummyTriggerNameB</name>
    				<job-name>JobB</job-name>
    				<job-group>GroupDummy</job-group>
    				
    				<cron-expression>0/5 * * * * ?</cron-expression>
    			</cron>
    		</trigger>
    	</schedule>
    </job-scheduling-data>

File : web.xml

<?xml version="1.0" encoding="UTF-8"?>
    <web-app ...>
    <listener>
        <listener-class>
           org.quartz.ee.servlet.QuartzInitializerListener
       </listener-class>
    </listener>
    </web-app>

## 3. Spring Example ##

The equivalent version in Spring.

package com.mkyong.job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.scheduling.quartz.QuartzJobBean; public class JobA extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { System.out.println("Job A is runing"); } }

package com.mkyong.job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.scheduling.quartz.QuartzJobBean; public class JobB extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { System.out.println("Job B is runing"); } }

package com.mkyong.job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.scheduling.quartz.QuartzJobBean; public class JobC extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { System.out.println("Job C is runing"); } }

File : Spring-Quartz.xml – Declares jobs and triggers in Spring XML bean configuration file.

Run it

package com.mkyong.common; import org.springframework.context.support.ClassPathXmlApplicationContext; public class App { public static void main(String[] args) throws Exception { new ClassPathXmlApplicationContext("Spring-Quartz.xml"); } }

Output.

INFO: Starting beans in phase 2147483647
    Jul 30, 2012 10:38:13 PM org.springframework.scheduling.quartz.SchedulerFactoryBean startScheduler
    INFO: Starting Quartz Scheduler now
    Job A is runing
    Job B is runing
    Job C is runing
    Job A is runing
    Job B is runing
    Job C is runing

资源下载：http://download.csdn.net/detail/zljjava/8995755

[mkyong]: http://www.mkyong.com/author/mkyong/