controller中@autowired报错_quartz（四）如何在job中使用spring自动注入

2020-12-31 20:41:07.311 ERROR 22456 --- [eduler_Worker-5] org.quartz.core.ErrorLogger : Job (repeat.test2 threw an exception.org.quartz.SchedulerException: Job threw an unhandled exception.at org.quartz.core.JobRunShell.run(JobRunShell.java:213)at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573)
Caused by: java.lang.NullPointerException: nullat com.example.docker_images.job.HelloJob.execute(HelloJob.java:26)at org.quartz.core.JobRunShell.run(JobRunShell.java:202)... 1 common frames omitted


import com.example.docker_images.entity.User;
import com.example.docker_images.entity.common.CwConstant;
import com.example.docker_images.service.IUserService;
import lombok.extern.slf4j.Slf4j;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;import javax.annotation.Resource;
import java.util.List;&＃64;Slf4j
public class HelloJob implements Job {&＃64;Resourceprivate IUserService iUserService;&＃64;Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {//通过jobDetail获取数据String payload &＃61; context.getTrigger().getJobDataMap().getString(CwConstant.PAYLOAD);System.out.println(payload);System.out.println("hello world!!!");List list &＃61; iUserService.list();System.out.println(list.size());}
}


org.quartz-schedulerquartz2.2.1


org.springframework.bootspring-boot-starter-quartz



import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;public final class ApplicationContextHolder extends SpringBeanJobFactoryimplements ApplicationContextAware {private static ApplicationContext context;private transient AutowireCapableBeanFactory beanFactory;&＃64;Overridepublic void setApplicationContext(final ApplicationContext context) {beanFactory &＃61; context.getAutowireCapableBeanFactory();ApplicationContextHolder.context &＃61; context;}&＃64;Overrideprotected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {final Object job &＃61; super.createJobInstance(bundle);beanFactory.autowireBean(job);return job;}public static ApplicationContext getContext() {return context;}
}

import com.example.docker_images.job.ApplicationContextHolder;
import org.quartz.Scheduler;
import org.quartz.spi.JobFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;import java.io.IOException;&＃64;Configuration
public class QuartzConfiguration {&＃64;Autowiredprivate ApplicationContext applicationContext;/*** Create the job factory bean** &＃64;return Job factory bean*/&＃64;Beanpublic JobFactory jobFactory() {ApplicationContextHolder jobFactory &＃61; new ApplicationContextHolder();jobFactory.setApplicationContext(applicationContext);return jobFactory;}/*** Create the Scheduler Factory bean** &＃64;return scheduler factory object*/&＃64;Beanpublic SchedulerFactoryBean schedulerFactory() {SchedulerFactoryBean factory &＃61; new SchedulerFactoryBean();factory.setAutoStartup(true);factory.setSchedulerName("CarWash Scheduler");factory.setOverwriteExistingJobs(true);factory.setJobFactory(jobFactory());return factory;}/*** 获得Scheduler 对象** &＃64;return* &＃64;throws IOException*/&＃64;Beanpublic Scheduler scheduler() throws IOException {return schedulerFactory().getScheduler();}
}


import com.example.docker_images.entity.common.APIResult;
import com.example.docker_images.entity.common.CwConstant;
import com.example.docker_images.entity.common.ReturnCodeEnum;
import com.example.docker_images.entity.job.JobPayload;
import com.example.docker_images.job.HelloJob;
import com.example.docker_images.service.JobService;
import com.example.docker_images.util.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Set;import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.TriggerBuilder.newTrigger;&＃64;Slf4j
&＃64;Service
public class JobServiceImpl implements JobService {//这里不可以使用&＃64;Resource来注入&＃xff0c;必须使用&＃64;Autowired&＃64;Autowiredprivate SchedulerFactoryBean schedulerFactory;&＃64;Overridepublic APIResult initiate(JobPayload payload) {try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();JobDetail jobDetail &＃61; JobBuilder.newJob(HelloJob.class).withIdentity(payload.getName(), payload.getGroup()).build();switch (payload.getScheduleType()){case CwConstant.JobType.NOW:Trigger build &＃61; newTrigger().withIdentity(payload.getName(), payload.getGroup()).startNow().usingJobData(CwConstant.PAYLOAD,payload.getDataMap()).withDescription(payload.getDesc()).build();scheduler.scheduleJob(jobDetail,build);scheduler.start();log.info("成功创建即刻执行任务!!!");break;case CwConstant.JobType.ONCE:Trigger trigger &＃61; newTrigger().withIdentity(payload.getName(), payload.getGroup()).startAt(DateUtil.parseYYYYMMDD(payload.getCron())).usingJobData(CwConstant.PAYLOAD,payload.getDataMap()).withDescription(payload.getDesc()).build();scheduler.scheduleJob(jobDetail,trigger);scheduler.start();log.info("成功创建未来执行一次任务!!!");break;case CwConstant.JobType.REPEAT:CronTrigger cronTrigger &＃61; newTrigger().withIdentity(payload.getName(), payload.getGroup()).usingJobData(CwConstant.PAYLOAD,payload.getDataMap()).withDescription(payload.getDesc()).withSchedule(cronSchedule(payload.getCron())).build();scheduler.scheduleJob(jobDetail,cronTrigger);scheduler.start();log.info("成功创建重复任务!!!");break;}} catch (Exception e) {log.info("job initial failure:{}",e);return APIResult.error(ReturnCodeEnum.JOB_INITIAL_FAILURE);}return APIResult.success(null);}&＃64;Overridepublic APIResult getJobList(String name, String groupName) {List jobs &＃61; new ArrayList<>();try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();Set jobKeys;if(StringUtils.isEmpty(groupName)){if(!StringUtils.isEmpty(name)){CronTrigger trigger &＃61; (CronTrigger)scheduler.getTrigger(new TriggerKey(name, groupName));jobs.add(JobPayload.getInstance(trigger));return APIResult.success(jobs);}jobKeys &＃61; scheduler.getJobKeys(GroupMatcher.anyGroup());}else {jobKeys &＃61; scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName));}jobKeys.forEach(jobKey -> {try {CronTrigger trigger &＃61; (CronTrigger)scheduler.getTrigger(new TriggerKey(jobKey.getName(), jobKey.getGroup()));JobPayload instance &＃61; JobPayload.getInstance(trigger);jobs.add(instance);} catch (SchedulerException e) {log.info("任务不存在&＃xff1a;{}",e);}});log.info("获取任务列表成功!!!");}catch (Exception e){log.info("任务列表获取失败{}",e);return APIResult.success(jobs);}return APIResult.success(jobs);}&＃64;Overridepublic APIResult update(JobPayload jobPayload) {try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();TriggerKey triggerKey &＃61; new TriggerKey(jobPayload.getName(), jobPayload.getGroup());switch (jobPayload.getScheduleType()){case CwConstant.JobType.ONCE://获取trigger,修改执行频率Trigger trigger &＃61; scheduler.getTrigger(triggerKey);Date startTime &＃61; trigger.getStartTime();Date date &＃61; DateUtil.parseYYYYMMDD(jobPayload.getCron());boolean equals &＃61; date.equals(startTime);if(!equals){Trigger build &＃61; newTrigger().withIdentity(triggerKey).startAt(date).withDescription(jobPayload.getDesc()).usingJobData(CwConstant.PAYLOAD,jobPayload.getDataMap()).build();scheduler.rescheduleJob(triggerKey,build);}case CwConstant.JobType.REPEAT:CronTrigger cronTrigger &＃61; (CronTrigger)scheduler.getTrigger(triggerKey);String cronExpression &＃61; cronTrigger.getCronExpression();if(!ObjectUtils.nullSafeEquals(jobPayload.getCron(),cronExpression)){CronTrigger build &＃61; newTrigger().withIdentity(triggerKey).withDescription(jobPayload.getDesc()).usingJobData(CwConstant.PAYLOAD,jobPayload.getDataMap()).withSchedule(cronSchedule(jobPayload.getCron())).build();scheduler.rescheduleJob(triggerKey,build);}}log.info("更新任务成功!!!");}catch (Exception e){log.info("修改失败:{}",e);return APIResult.error(ReturnCodeEnum.JOB_INITIAL_FAILURE);}return APIResult.success(null);}&＃64;Overridepublic APIResult delete(String name, String groupName) {try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();TriggerKey triggerKey &＃61; new TriggerKey(name, groupName);if(scheduler.checkExists(triggerKey)){scheduler.pauseTrigger(triggerKey);scheduler.unscheduleJob(triggerKey);scheduler.deleteJob(new JobKey(name,groupName));log.info("任务删除成功!!!");}}catch (Exception e){log.info("删除任务失败:{}",e);return APIResult.error(ReturnCodeEnum.JOB_INITIAL_FAILURE);}return APIResult.success(null);}&＃64;Overridepublic APIResult pauseJob(String name, String groupName) {try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();scheduler.pauseTrigger(new TriggerKey(name, groupName));log.info("暂停任务成功!!!");}catch (Exception e){log.info("暂停任务失败:{}",e);return APIResult.error(ReturnCodeEnum.JOB_INITIAL_FAILURE);}return APIResult.success(null);}&＃64;Overridepublic APIResult resumeJob(String name, String groupName) {try {Scheduler scheduler &＃61; schedulerFactory.getScheduler();scheduler.resumeTrigger(new TriggerKey(name, groupName));log.info("恢复任务成功!!!");}catch (Exception e){log.info("恢复任务失败:{}",e);return APIResult.error(ReturnCodeEnum.JOB_INITIAL_FAILURE);}return APIResult.success(null);}
}

2020-12-31 21:58:02.709 INFO 12472 --- [nio-8088-exec-2] c.e.d.service.impl.JobServiceImpl : 成功创建重复任务!!!
{name:&＃39;ljl&＃39;}
hello world!!!
2020-12-31 21:58:07.706 INFO 12472 --- [eduler_Worker-1] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} inited
2020-12-31 21:58:07.712 DEBUG 12472 --- [eduler_Worker-1] c.e.d.mapper.UserMapper.selectList : &＃61;&＃61;> Preparing: SELECT id,user_name FROM user
2020-12-31 21:58:07.720 DEBUG 12472 --- [eduler_Worker-1] c.e.d.mapper.UserMapper.selectList : &＃61;&＃61;> Parameters:
2020-12-31 21:58:07.754 DEBUG 12472 --- [eduler_Worker-1] c.e.d.mapper.UserMapper.selectList : <&＃61;&＃61; Total: 2
2
{name:&＃39;ljl&＃39;}
hello world!!!
2020-12-31 21:58:12.008 DEBUG 12472 --- [eduler_Worker-2] c.e.d.mapper.UserMapper.selectList : &＃61;&＃61;> Preparing: SELECT id,user_name FROM user
2020-12-31 21:58:12.008 DEBUG 12472 --- [eduler_Worker-2] c.e.d.mapper.UserMapper.selectList : &＃61;&＃61;> Parameters:
2020-12-31 21:58:12.036 DEBUG 12472 --- [eduler_Worker-2] c.e.d.mapper.UserMapper.selectList : <&＃61;&＃61; Total: 2
2