Quartz与Spring的整合-Quartz中的job如何自动注入spring容器托管的对象

public class CancelUnpaidOrderTask implements Job {
  @Autowired
  private AppOrderService orderService;

  @Override
  public 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技术范畴.
  @Autowired
  private 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>

https://www.leftso.com/article/15.html