Spring quartz Job依赖注入使用详解
程序员文章站
2022-06-20 08:12:00
spring quartz job依赖注入使用详解
一、问题描述:
使用spring整合quartz实现动态任务时,想在job定时任务中使用某个service时,直...
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。
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!