quratz 中的job 监听器listener 中获取spring容器中的bean

淩亂°似流年 2022-05-23 03:29 234阅读 0赞

## quratz 中的job 监听器listener 中获取spring容器中bean ##

> 我们知道 由于listener 启动会先于spring 容器 况且 quratz 中的bean 是独立于spring外运行的 也就是说 spring把创建bean 的生命周期权限托管给了quratz 所以要想在job 或者job 的listener 中注入spring 的bean 肯定是不行的 但是我们可以使用别的方法。下面我写一个自己认为最简单的方法：

###### 先创建一个spring 的SpringUtil 的工具类 ，该工具类主要是利用实现了ApplicationContextAware 接口 利用set 方法 先实例化一个ApplicationContext 然后就可以获取对应的bean源码如下 ######

> 源码 注意 前提别忘记把该工具类交给spring 管理

package com.iflytek.quartz.util;
    
    import org.springframework.beans.BeansException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    
    @Component
    public class SpringUtil implements ApplicationContextAware{ 
    
        private static ApplicationContext applicationContext;
    
        @Override
        public  void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
            if(SpringUtil.applicationContext == null) {
                SpringUtil.applicationContext = applicationContext;
            }
        }
    
        //获取applicationContext
        public static ApplicationContext getApplicationContext() {
            return applicationContext;
        }
    
        //通过name获取 Bean.
        public static Object getBean(String name){
            return getApplicationContext().getBean(name);
        }
    
        //通过class获取Bean.
        public static <T> T getBean(Class<T> clazz){
            return getApplicationContext().getBean(clazz);
        }
    
        //通过name,以及Clazz返回指定的Bean
        public static <T> T getBean(String name,Class<T> clazz){
            return getApplicationContext().getBean(name, clazz);
        }
    
    }

> 我的job listener 源码：

package com.iflytek.quartz.listener;
    
    import org.apache.log4j.Logger;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.quartz.JobListener;
    import org.springframework.stereotype.Component;
    
    import com.iflytek.quartz.service.QaTaskService;
    import com.iflytek.quartz.util.SpringUtil;
    
    /** * job 监听器 * @author zhangh * @date 2018年5月25日下午2:06:46 */
    @Component
    public class MyJobListener implements JobListener { 
        private static Logger log = Logger.getLogger(MyJobListener.class);
    
        /** * 获取该JobListener的名称 */
        @Override
        public String getName() {
            return getClass().getSimpleName();
        }
    
        /** * Scheduler在JobDetail将要被执行时调用这个方法 */
        @Override
        public void jobToBeExecuted(JobExecutionContext context) {
            //log.info(context.getJobDetail().getKey().getName()+"任务准备执行");
        }
    
        /** * Scheduler在JobDetail即将被执行，但又被TriggerListerner否决时会调用该方法 */
        @Override
        public void jobExecutionVetoed(JobExecutionContext context) {
            //log.info(context.getJobDetail().getKey().getName()+"任务准备执行时被触发器"+context.getTrigger().getKey().getName()+"否决了");
        }
    
        /** * Scheduler在JobDetail被执行之后调用这个方法 * 主要是回写数据 */
        @Override
        public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
            log.info(context.getJobDetail().getKey().getName()+"任务执行完毕");
            QaTaskService qaTaskService = **SpringUtil.getBean(QaTaskService.class);**
            String jobtype = context.getJobDetail().getJobDataMap().get("jobType").toString();
            String jobID = context.getJobDetail().getJobDataMap().getString("id");
            if("1".equals(jobtype)){
                qaTaskService.updateStatus(jobID, "1");
    
            }else if ("2".equals(jobtype)){
                qaTaskService.updateStatus(jobID, "5");
            }
    
        }
    }