定时器注入spring

ApplicationContextUtil.java 

package org.job;import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;/*** Created with IntelliJ IDEA.定时器的执行优先于注入 所以需要创建一个类&＃xff0c;用来获取service* User: vincent* Date: 2017/11/8* Time: 15:39*/
public class ApplicationContextUtil implements ApplicationContextAware {private static ApplicationContext applicationContext;public static ApplicationContext getApplicationContext() {return applicationContext;}&＃64;Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {ApplicationContextUtil.applicationContext &＃61; applicationContext;}public static Object getBean(String beanName){return applicationContext.getBean(beanName);}}


JobFactory.java

package org.job;import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** Created with IntelliJ IDEA.* User: vincent* Date: 2017/10/30* Time: 17:00*/
&＃64;Configuration
public class JobFactory {&＃64;Bean(name &＃61; "jobScheduler")public Scheduler getScheduler() {SchedulerFactory schedulerfactory &＃61; new StdSchedulerFactory();Scheduler scheduler &＃61; null;try {scheduler &＃61; schedulerfactory.getScheduler();} catch (Exception e) {e.printStackTrace();}return scheduler;}}


PersonService.java

&＃64;Service("pointService")
public class PointServiceImpl implements PointService {&＃64;AutowiredPersonDao personDao;public getPersonList(){doSometing();}}

MyJob.java

&＃64;DisallowConcurrentExecution
public class MyJob implements Job {&＃64;Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {//System.out.println(DateHelper2.getCurrentDateTimeFormat());try {Thread.sleep(2000);PointService pointService &＃61; (PersonService)ApplicationContextUtil.getBean("personService");System.out.println(personService);personService.updateGlobalPointValue1();} catch (InterruptedException e) {e.printStackTrace();}}public MyJob() {}
}

JobServiceImpl.java

package org.taian.service.impl;import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.taian.service.JobService;import java.util.List;/*** Created with IntelliJ IDEA.* User: vincent* Date: 2017/11/9* Time: 14:15*/
&＃64;Service
public class JobServiceImpl implements JobService {&＃64;Autowired&＃64;Qualifier("jobScheduler")private Scheduler scheduler;&＃64;Overridepublic void doJob() {//触发器JobDetail job &＃61; JobBuilder.newJob(MyJob.class).withIdentity("job1", "jgroup1").build();Trigger trigger &＃61; TriggerBuilder.newTrigger().withIdentity("simpleTrigger", "triggerGroup").withSchedule(CronScheduleBuilder.cronSchedule("1-30 * * * * ? *")).startNow().build();try {//把作业和触发器注册到任务调度中scheduler.scheduleJob(job, trigger);//启动调度scheduler.start();Thread.sleep(5000);List currentlyExecutingJobs &＃61; scheduler.getCurrentlyExecutingJobs();System.out.println(currentlyExecutingJobs.size());for (JobExecutionContext jobExecutionContext:currentlyExecutingJobs){System.out.println(jobExecutionContext.getJobDetail().getKey());}} catch (Exception e) {e.printStackTrace();}}
}


controller.java

&＃64;ResponseBody&＃64;RequestMapping(value &＃61; "doQuartz", method &＃61; RequestMethod.GET)public String doQuartz(){jobService.doJob();return "a";}