利用Quartz來實現對任務的排程已經被廣泛地應用了，一個利用Quartz來進行任務排程的典型配置如下：

<bean id="testTask" class="com.alisoft.xx.TestTask" /> <bean id="xxJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="concurrent"> <value>false</value> </property> <property name="targetObject"> <ref bean="testTask"/> </property> <property name="targetMethod"> <value>execute</value> </property> </bean> <!-- SimpleTriggerBean可以用org.springframework.scheduling.quartz.CronTriggerBean代替 --> <bean id="xxTriggerBean" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> <property name="jobDetail"> <ref bean="xxJobDetail"/> </property> <property name="startDelay"> <value>1000</value> </property> <property name="repeatInterval"> <value>60000</value> </property> </bean> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref local="xxTriggerBean"/> </list> </property> </bean>

若有多個任務需要排程，則配置多個JobDetail、Trigger即可，待執行的Task bean沒有啥任何要求，不需要extends任何class、或者implements任何interface，只是被執行的method需要是無引數的；

但是在我們現實專案中，僅僅完成這樣的功能是還不夠的，我們還需要爭取完成以下幾點：

1. 對所有的Task實現執行開始、結束時間的記錄；
2. 對每天的Task執行結果持久化、或者通過email、旺旺訊息等方式告知相關owner；
3. 當我們有多臺Task伺服器時，如何保證每個任務只在一臺伺服器上執行；

針對以上幾個問題，我們也都有很簡單、直接的辦法可以搞定，比如說1、2兩點可以直接在每個任務中各自編碼完成，但是這樣不僅每個task都要寫非常類似的重複程式碼、而且不能保證每個任務的執行情況都被記錄，因為某些task的編碼人員就不會在意這些非功能性需求；對於第3點，我們也可以通過配置來完成向不同task伺服器部署不一樣的釋出包來完成，但這給釋出帶來了麻煩，這意味著有多少臺task伺服器，就需要通過修改配置重新打包併發布多少次；

其實我們可以利用Spring預設提供的AOP來非常優雅的解決這幾個問題：擴充套件MethodInvokingJobDetailFactoryBean來實現對任務排程時的攔截！其關鍵程式碼為MethodInvokingJobDetailFactoryBean.MethodInvokingJob.executeInternal(JobExecutionContext context);這個method中；

具體步驟如下：

1. 新增所有Task都需要實現的interface，可參考如下程式碼：
   public interface TaskHandler { /** * 任務排程執行需要實現的method */ TaskResult execute(); }
2. 基於MethodInvokingJobDetailFactoryBean實現自定義的JobDetailFactoryBean，在具體執行待排程任務的method前後加入公用邏輯，比如記錄開始、結束日期、判斷該task是否由該臺伺服器執行、任務執行完成之後將執行結果進行持久化或者發email等給相關owner；可參考如下程式碼：
   public class AppsMethodInvokingJobDetailFactoryBean extends MethodInvokingJobDetailFactoryBean { protected static final Log logger = LogFactory.getLog(AppsMethodInvokingJobDetailFactoryBean.class); /* (non-Javadoc) * @see org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean#afterPropertiesSet() */ @Override public void afterPropertiesSet() throws ClassNotFoundException, NoSuchMethodException { super.afterPropertiesSet(); logger.info("origin jobClass : " + ((JobDetail)super.getObject()).getJobClass().getName()); // Consider the concurrent flag to choose between stateful and stateless job. if(MethodInvokingJob.class.getName().equals(((JobDetail)super.getObject()).getJobClass().getName())) { ((JobDetail)super.getObject()).setJobClass(AppsMethodInvokingJob.class); } else { ((JobDetail)super.getObject()).setJobClass(AppsStatefulMethodInvokingJob.class); } logger.info("new jobClass : " + ((JobDetail)super.getObject()).getJobClass().getName()); } public static class AppsMethodInvokingJob extends MethodInvokingJob { protected static final Log logger = LogFactory.getLog(AppsMethodInvokingJob.class); private MethodInvoker methodInvoker; private String errorMessage; /** * Set the MethodInvoker to use. */ public void setMethodInvoker(MethodInvoker methodInvoker) { this.methodInvoker = methodInvoker; this.errorMessage = "Could not invoke method '" + this.methodInvoker.getTargetMethod() + "' on target object [" + this.methodInvoker.getTargetObject() + "]"; } /** * Invoke the method via the MethodInvoker. */ protected void executeInternal(JobExecutionContext context) throws JobExecutionException { Date startDate = new Date(); String taskName = methodInvoker.getTargetClass().getName(); TaskResult taskResult; try { if (logger.isInfoEnabled()) { logger.info(taskName + " job start at " + startDate); } //根據當前伺服器主機名或者IP判斷是否需要執行該任務 //TODO Code //呼叫具體task執行method程式碼 taskResult = this.methodInvoker.invoke(); } catch (Exception ex) { logger.error(taskName + " accounted a error : " + this.errorMessage, ex); throw new JobExecutionException(this.errorMessage, ex, false); } finally { if(logger.isInfoEnabled()) { logger.info(taskName + " job end at " + new Date()); } //將task執行結果taskResult進行持久化、或者通知相關owner //TODO Code } } } public static class AppsStatefulMethodInvokingJob extends AppsMethodInvokingJob { } }
3. 將自定義JobDetailFactoryBean的bean配置設定為abstract，從而減少每個task的相關配置量，新的程式碼可參考如下配置：
   <bean id="appsAbstractJobDetail" class="com.alisoft...AppsMethodInvokingJobDetailFactoryBean" abstract="true"> <property name="concurrent" value="false" /> <property name="targetMethod" value="execute" /> </bean> <bean id="testTaskHandler" class="com.alisoft...task.TestTaskHandler" /> <bean id="testTaskJobDetail" parent="appsAbstractJobDetail"> <property name="targetObject" ref="testTaskHandler" /> </bean> <bean id="testTaskTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"> <property name="jobDetail" ref="testTaskJobDetail" /> <property name="cronExpression" value="0 10 0 * * ?" /> </bean>