public class CancelUnpaidOrderTask implements Job {@Autowiredprivate AppOrderService orderService;@Overridepublic void execute(JobExecutionContext ctx) throws JobExecutionException {...
}

public interface JobFactory {Job newJob(TriggerFiredBundle bundle, Scheduler scheduler) throws SchedulerException;
}

        // Get Scheduler instance from SchedulerFactory.try {this.scheduler = createScheduler(schedulerFactory, this.schedulerName);populateSchedulerContext();if (!this.jobFactorySet && !(this.scheduler instanceof RemoteScheduler)) {// Use AdaptableJobFactory as default for a local Scheduler, unless when// explicitly given a null value through the "jobFactory" bean property.this.jobFactory = new AdaptableJobFactory();}if (this.jobFactory != null) {if (this.jobFactory instanceof SchedulerContextAware) {((SchedulerContextAware) this.jobFactory).setSchedulerContext(this.scheduler.getContext());}this.scheduler.setJobFactory(this.jobFactory);}}

package org.springframework.scheduling.quartz;import java.lang.reflect.Method;import org.quartz.Job;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.spi.JobFactory;
import org.quartz.spi.TriggerFiredBundle;import org.springframework.util.ReflectionUtils;public class AdaptableJobFactory implements JobFactory {public Job newJob(TriggerFiredBundle bundle, Scheduler scheduler) throws SchedulerException {return newJob(bundle);}public Job newJob(TriggerFiredBundle bundle) throws SchedulerException {try {Object jobObject = createJobInstance(bundle);return adaptJob(jobObject);}catch (Exception ex) {throw new SchedulerException("Job instantiation failed", ex);}}protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {// Reflectively adapting to differences between Quartz 1.x and Quartz 2.0...Method getJobDetail = bundle.getClass().getMethod("getJobDetail");Object jobDetail = ReflectionUtils.invokeMethod(getJobDetail, bundle);Method getJobClass = jobDetail.getClass().getMethod("getJobClass");Class jobClass = (Class) ReflectionUtils.invokeMethod(getJobClass, jobDetail);return jobClass.newInstance();}protected Job adaptJob(Object jobObject) throws Exception {if (jobObject instanceof Job) {return (Job) jobObject;}else if (jobObject instanceof Runnable) {return new DelegatingJob((Runnable) jobObject);}else {throw new IllegalArgumentException("Unable to execute job class [" + jobObject.getClass().getName() +"]: only [org.quartz.Job] and [java.lang.Runnable] supported.");}}}

public class MyJobFactory extends AdaptableJobFactory {//这个对象Spring会帮我们自动注入进来,也属于Spring技术范畴.@Autowiredprivate AutowireCapableBeanFactory capableBeanFactory;protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {//调用父类的方法Object jobInstance = super.createJobInstance(bundle);//进行注入,这属于Spring的技术,不清楚的可以查看Spring的API.capableBeanFactory.autowireBean(jobInstance);return jobInstance;}
}

<bean id="jobFactory" class="com.gary.operation.jobdemo.demo1.MyJobFactory"></bean>

<bean name="MyScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">　　<!-- 其他属性省略 --><property name="jobFactory" ref="jobFactory"></property>
</bean>