正文

quartz的job中注入spring对象！

IP云
IP云V管理员/5 阅读
08/09
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

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

自定义一个类:

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

然后在spring中配置:

  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对象了：

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