一个简单的quartz集群版helloWorld示例演示

package com.telek.springframework.scheduling.quartz; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.quartz.Job; import org.quartz.JobDetail; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.Scheduler; import org.quartz.StatefulJob; import org.springframework.beans.factory.BeanNameAware; import org.springframework.beans.factory.FactoryBean; import org.springframework.beans.factory.InitializingBean; import org.springframework.util.MethodInvoker; /** * This is a cluster safe Quartz/Spring FactoryBean implementation, which * produces a JobDetail implementation that can invoke any no-arg method on any * Class. * <p> * Use this Class instead of the MethodInvokingJobDetailBeanFactory Class * provided by Spring when deploying to a web environment like Tomcat. * <p> * <b>Implementation</b><br> * Instead of associating a MethodInvoker with a JobDetail or a Trigger object, * like Spring's MethodInvokingJobDetailFactoryBean does, I made the * [Stateful]MethodInvokingJob, which is not persisted in the database, create * the MethodInvoker when the [Stateful]MethodInvokingJob is created and * executed. * <p> * A method can be invoked one of several ways: * <ul> * <li>The name of the Class to invoke (targetClass) and the static method to * invoke (targetMethod) can be specified. * <li>The Object to invoke (targetObject) and the static or instance method to * invoke (targetMethod) can be specified (the targetObject must be Serializable * when concurrent=="false"). * <li>The Class and static Method to invoke can be specified in one property * (staticMethod). example: staticMethod = * "example.ExampleClass.someStaticMethod" <br> * <b>Note:</b> An Object[] of method arguments can be specified (arguments), * but the Objects must be Serializable if concurrent=="false". * </ul> * <p> * I wrote MethodInvokingJobDetailFactoryBean, because Spring's * MethodInvokingJobDetailFactoryBean does not produce Serializable JobDetail * objects, and as a result cannot be deployed into a clustered environment like * Tomcat (as is documented within the Class). * <p> * <b>Example</b> <code> * <ul> * &lt;bean id="<i>exampleTrigger</i>" class="org.springframework.scheduling.quartz.CronTriggerBean"&gt; * <ul> <i>&lt;!-- Execute example.ExampleImpl.fooBar() at 2am every day --&gt;</i><br> &lt;property name="<a href="http://www.opensymphony.com/quartz/api/org/quartz/CronTrigger.html">cronExpression</a>" value="0 0 2 * * ?" /&gt;<br> &lt;property name="jobDetail"&gt; <ul> &lt;bean class="frameworkx.springframework.scheduling.quartz.<b>MethodInvokingJobDetailFactoryBean</b>"&gt; <ul> &lt;property name="concurrent" value="<i>false</i>"/&gt;<br> &lt;property name="targetClass" value="<i>example.ExampleImpl</i>" /&gt;<br> &lt;property name="targetMethod" value="<i>fooBar</i>" /&gt; </ul> &lt;/bean&gt; </ul> &lt;/property&gt; </ul> &lt;/bean&gt; <p> &lt;bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"&gt; <ul> &lt;property name="triggers"&gt; <ul> &lt;list&gt; <ul> &lt;ref bean="<i>exampleTrigger</i>" /&gt; </ul> &lt;/list&gt; </ul> &lt;/property&gt; </ul> &lt;/bean&gt; </ul> * </code> In this example we created a MethodInvokingJobDetailFactoryBean, * which will produce a JobDetail Object with the jobClass property set to * StatefulMethodInvokingJob.class (concurrent=="false"; Set to * MethodInvokingJob.class when concurrent=="true"), which will in turn invoke * the static <code>fooBar</code>() method of the " * <code>example.ExampleImpl</code>" Class. The Scheduler is the heart of the * whole operation; without it, nothing will happen. * <p> * For more information on <code>cronExpression</code> syntax visit <a * href="http://www.opensymphony.com/quartz/api/org/quartz/CronTrigger.html" * >http://www.opensymphony.com/quartz/api/org/quartz/CronTrigger.html</a> * * @author Stephen M. Wick * * @see #afterPropertiesSet() */ public class MethodInvokingJobDetailFactoryBean implements FactoryBean, BeanNameAware, InitializingBean { private Log logger = LogFactory.getLog(getClass()); /** * The JobDetail produced by the <code>afterPropertiesSet</code> method of * this Class will be assigned to the Group specified by this property. * Default: Scheduler.DEFAULT_GROUP * * @see #afterPropertiesSet() * @see Scheduler#DEFAULT_GROUP */ private String group = Scheduler.DEFAULT_GROUP; /** * Indicates whether or not the Bean Method should be invoked by more than * one Scheduler at the specified time (like when deployed to a cluster, * and/or when there are multiple Spring ApplicationContexts in a single * JVM<i> - Tomcat 5.5 creates 2 or more instances of the DispatcherServlet * (a pool), which in turn creates a separate Spring ApplicationContext for * each instance of the servlet</i>) * <p> * Used by <code>afterPropertiesSet</code> to set the JobDetail.jobClass to * MethodInvokingJob.class or StatefulMethodInvokingJob.class when true or * false, respectively. Default: true * * @see #afterPropertiesSet() */ private boolean concurrent = true; /** * Used to set the JobDetail.durable property. Default: false * <p> * Durability - if a job is non-durable, it is automatically deleted from * the scheduler once there are no longer any active triggers associated * with it. * * @see <a * href="http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html">http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html</a> * @see #afterPropertiesSet() */ private boolean durable = false; /** * Used by <code>afterPropertiesSet</code> to set the JobDetail.volatile * property. Default: false * <p> * Volatility - if a job is volatile, it is not persisted between re-starts * of the Quartz scheduler. * <p> * I set the default to false to be the same as the default for a Quartz * Trigger. An exception is thrown when the Trigger is non-volatile and the * Job is volatile. If you want volatility, then you must set this property, * and the Trigger's volatility property, to true. * * @see <a * href="http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html">http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html</a> * @see #afterPropertiesSet() */ private boolean volatility = false; /** * Used by <code>afterPropertiesSet</code> to set the * JobDetail.requestsRecovery property. Default: false<BR> * <p> * RequestsRecovery - if a job "requests recovery", and it is executing * during the time of a 'hard shutdown' of the scheduler (i.e. the process * it is running within crashes, or the machine is shut off), then it is * re-executed when the scheduler is started again. In this case, the * JobExecutionContext.isRecovering() method will return true. * * @see <a * href="http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html">http://www.opensymphony.com/quartz/wikidocs/TutorialLesson3.html</a> * @see #afterPropertiesSet() */ private boolean shouldRecover = false; /** * A list of names of JobListeners to associate with the JobDetail object * created by this FactoryBean. * * @see #afterPropertiesSet() **/ private String[] jobListenerNames; /** * The name assigned to this bean in the Spring ApplicationContext. Used by * <code>afterPropertiesSet</code> to set the JobDetail.name property. * * @see afterPropertiesSet() * @see JobDetail#setName(String) **/ private String beanName; /** * The JobDetail produced by the <code>afterPropertiesSet</code> method, and * returned by the <code>getObject</code> method of the Spring FactoryBean * interface.