湛蓝之海 发表于 2021-10-20 16:14:20

Spring quartz Job依赖注入使用详解

Spring quartz Job依赖注入使用详解
一、问题描述:

使用Spring整合quartz实现动态任务时,想在job定时任务中使用某个service时,直接通过加注解@Component、@Autowired是不能注入的,获取的对象为Null。如下面的代码:


@Component
@PersistJobDataAfterExecution
@DisallowConcurrentExecution
public class TicketSalePriceLessThanLowestPriceJob implements Job{

@Autowired
private XxxService xxxService;

}
二、解决方案:

1、新增一个自定义类(CustomJobFactory),继承SpringBeanJobFactory,代码如下:


import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

public class CustomJobFactory extends SpringBeanJobFactory{

@Autowired
private AutowireCapableBeanFactory capableBeanFactory;

@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
    //调用父类的方法
    Object jobInstance = super.createJobInstance(bundle);
    //进行注入
    capableBeanFactory.autowireBean(jobInstance);
    return jobInstance;
}
   
}

2、在spring.xml文件配置CustomJobFactory,如下:


<bean id="customJobFactory" class="cn.imovie.manage.task.job.CustomJobFactory"></bean>
3、将自定义CustomJobFactory注入到org.springframework.scheduling.quartz.SchedulerFactoryBean,具体如下:


<property name="jobFactory" ref="customJobFactory"></property>

完整代码如下:


<!-- 定时任务配置 start -->
<bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="dataSource" ref="dataSource"></property>   
    <!--可选,QuartzScheduler 启动时更新己存在的Job,这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了 -->   
    <property name="overwriteExistingJobs" value="true" />   
   <!--必须的,QuartzScheduler 延时启动,应用启动完后 QuartzScheduler 再启动 -->   
    <property name="startupDelay" value="10" />   
    <!-- 设置自动启动 -->   
    <property name="autoStartup" value="true" />
    <property name="jobFactory" ref="customJobFactory"></property>
    <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
    <property name="configLocation" value="classpath:spring-quartz.properties" />   
</bean>
<!-- 定时任务配置 end -->
4、然后就可以在Job任务类使用@Autowired注入service。
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

https://www.uoften.com/program/jsp/20180413/48216.html
页: [1]
查看完整版本: Spring quartz Job依赖注入使用详解