首页 > 代码库 > quartz的job中注入spring对象!

quartz的job中注入spring对象!

一般情况下,quartz的job中使用autowired注解注入的对象为空,这时候我们就要使用spring-quartz提供的AdaptableJobFactory类。

自定义一个类:

[java] view plain copy
 
  1. public class JobFactory extends AdaptableJobFactory {  
  2.       
  3.     @Autowired  
  4.     private AutowireCapableBeanFactory capableBeanFactory;  
  5.   
  6.     @Override  
  7.     protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {  
  8.         //调用父类的方法  
  9.         Object jobInstance = super.createJobInstance(bundle);  
  10.         //进行注入  
  11.         capableBeanFactory.autowireBean(jobInstance);  
  12.         return jobInstance;  
  13.     }  
  14.       
  15. }  

然后在spring中配置:

 

 

[html] view plain copy
 
  1. <!-- 定时任务的factorybean,配置其他config -->  
  2.     <bean id="jobFactory" class="com.xx.job.JobFactory"></bean>  
  3.     <bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  4.         <property name="jobFactory" ref="jobFactory"></property>  
  5.     </bean>  


这时候,我们在定义类继承job的时候,就可以使用autowired注入service对象了:

 

 

[java] view plain copy
 
    1. public class Test1Job implements Job {  
    2.     public final Logger log = Logger.getLogger(this.getClass());  
    3.       
    4.     @Autowired  
    5.     private JobTaskService jobTaskService;  
    6.       
    7.     public void execute(JobExecutionContext context) throws JobExecutionException {  
    8.         //更新上一次执行时间和下一次计划执行时间  
    9.         Date nextProcessTime = context.getNextFireTime();  
    10.         ScheduleJob job = (ScheduleJob) context.getJobDetail().getJobDataMap().get("scheduleJob");  
    11.         job.setNextProcessTime(nextProcessTime);  
    12.         jobTaskService.updateTaskByJobName(job);  
    13.           
    14.         //业务逻辑  
    15.         System.out.println("22222222222222222222:");  
    16.     }  
    17. }  

quartz的job中注入spring对象!