quartz注解调用service

如果要在Job中注解调用业务逻辑层Service即下面代码所示

@Autowired

private TestJobService testJobService;

package com.demo.job;
import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import com.demo.service.job.TestJobService;
public class QuartzJobFactory implements Job {
private final Logger log = Logger.getLogger(QuartzJobFactory.class);
@Autowired
private TestJobService testJobService;
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
log.info("----->>任务开始<<-----");
ScheduleJob scheduleJob = (ScheduleJob) context.getMergedJobDataMap().get("scheduleJob");
System.out.println("任务名称 = [" + scheduleJob.getJobName() + "]t任务组 = [" + scheduleJob.getJobGroup() + "]");
testJobService.backupCust();
}
}

需要在spring配置文件中添加代码如下

<!-- 定时任务 -->
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="jobFactory">
<bean class="com.demo.job.MySpringBeanJobFactory"></bean>
</property>
</bean>

 另外需要创建一个MySpringBeanJobFactory类重构createJobInstance方法

package com.demo.job;
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 MySpringBeanJobFactory extends SpringBeanJobFactory {
@Autowired
private AutowireCapableBeanFactory beanFactory;
/**
* 这里我们覆盖了super的createJobInstance方法，对其创建出来的类再进行autowire。
*/
@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
Object jobInstance = super.createJobInstance(bundle);
beanFactory.autowireBean(jobInstance);
return jobInstance;
}
}