欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

quartz的job中注入spring对象!(转帖)

程序员文章站 2022-06-14 17:26:36
...

转帖地址:http://blog.csdn.net/u012572955/article/details/51656270

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

自定义一个类:

[java] view plain copy
 
 quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency 
  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
 
 quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency 
  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
 
 quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency quartz的job中注入spring对象!(转帖)
            
    
    博客分类: Quartz quartzjobspringdependency 
  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. }