Spring通过ApplicationContext主动获取bean

ゞ浴缸里的玫瑰 2022-06-14 06:27 309阅读 0赞

原文地址:

http://blog.csdn.net/jinzhencs/article/details/51673782

问题1:   
有个异步线程Runnable里面需要用到dao，无法通过AutoWired和compoment注解传递进来。   
于是希望通过[spring][] context主动去获取bean。

问题2：   
getBean(name)获取失败。   
解决:   
默认的dao的name=类名(首字母小写)   
例如:   
接口名称:TemplateDao 则getName(“templateDao”)即可

--------------------

# 通用的SpringContextUtil获取Bean #

*  1.实现ApplicationContextAware接口

/** * spring上下文配置 * @author Mingchenchen * */
    @Component
    public class SpringContextUtil implements ApplicationContextAware { 
        private static Logger logger = Logger.getLogger(SpringContextUtil.class);
        private static ApplicationContext applicationContext = null;
    
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
        {
            logger.info("------SpringContextUtil setApplicationContext-------");
            SpringContextUtil.applicationContext = applicationContext;
        }
    
        public static ApplicationContext getApplicationContext() {
            return applicationContext;
        }
    
        /** * 注意 bean name默认 = 类名(首字母小写) * 例如: A8sClusterDao = getBean("k8sClusterDao") * @param name * @return * @throws BeansException */
        public static Object getBean(String name) throws BeansException {
            return applicationContext.getBean(name);
        }
    
        /** * 根据类名获取到bean * @param <T> * @param clazz * @return * @throws BeansException */
        @SuppressWarnings("unchecked")
        public static <T> T getBeanByName(Class<T> clazz) throws BeansException {
            try {
                char[] cs=clazz.getSimpleName().toCharArray();
                cs[0] += 32;//首字母大写到小写
                return (T) applicationContext.getBean(String.valueOf(cs));
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            } 
        }
    
        public static boolean containsBean(String name) {
            return applicationContext.containsBean(name);
        }
    
        public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException {
            return applicationContext.isSingleton(name);
        }
    
    }

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34
 *  35
 *  36
 *  37
 *  38
 *  39
 *  40
 *  41
 *  42
 *  43
 *  44
 *  45
 *  46
 *  47
 *  48
 *  49
 *  50
 *  51
 *  52
 *  53
 *  54
 *  55
 *  56
 *  57
 *  58
 *  59
 *  60

*  2.在web项目中的web.xml中配置加载Spring容器的Listener

<listener>  
            <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>  
        </listener>

*  1
 *  2
 *  3
 *  4

--------------------

getBeanByName(Class clazz)   
这个方法更好使用,不过需要注意Dao和service的impl里面需要配置好名称为@Service(“myService”)   
规则为接口Service的类名首字母小写。

--------------------

# 第二种方式: #

目前又做了个系统初始化的东东SystemInit，然后发现上面的getBean()用不了了。看了下发现是因为在系统初始化的时候SpringContextUtil还没有初始化，导致在SystemInit类里面的东西getBean()失败。   
于是小改造了下，把ApplicationContextAware放在SystemInit类，然后注入到SpringContextUtil，这样就保证了在执行系统初始化方法之前，applicationContext一定不是null。

/** * spring上下文配置 * @author Mingchenchen * */
    public class SpringContextUtil { 
        private static Logger logger = Logger.getLogger(SpringContextUtil.class);
    
        //@Autowired 沿用springTest的这种方法 是否会更好？
        //ApplicationContext ctx;
        private static ApplicationContext applicationContext = null;
    
        public static void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
            logger.info("------SpringContextUtil setApplicationContext-------");
            SpringContextUtil.applicationContext = applicationContext;
        }
    
        //注意此处变成了static
        public static ApplicationContext getApplicationContext() {
            return applicationContext;
        }
    
        /** * 注意 bean name默认 = 类名(首字母小写) * 例如: A8sClusterDao = getBean("k8sClusterDao") * @param name * @return * @throws BeansException */
        public static Object getBean(String name) throws BeansException {
            return applicationContext.getBean(name);
        }
    
        /** * 根据类名获取到bean * @param <T> * @param clazz * @return * @throws BeansException */
        @SuppressWarnings("unchecked")
        public static <T> T getBeanByName(Class<T> clazz) throws BeansException {
            try {
                char[] cs=clazz.getSimpleName().toCharArray();
                cs[0] += 32;//首字母大写到小写
                return (T) applicationContext.getBean(String.valueOf(cs));
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            } 
        }
    
        public static boolean containsBean(String name) {
            return applicationContext.containsBean(name);
        }
    
        public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException {
            return applicationContext.isSingleton(name);
        }
    
    }

/** * Descripties: 系统初始化 * @author wangkaiping * 2016年5月23日 上午11:58:09 */
    @Component
    public class SystemInit implements InitializingBean,ApplicationContextAware{ 
        private static Logger logger = Logger.getLogger(SystemInit.class);
        @Autowired
        private ClusterDao clusterDao;
    
        @Override
        public void afterPropertiesSet() throws Exception {
            logger.info("--------------系统初始化中-------------------");
            initClusterCache();//初始化集群数据 必须最开始完成
            initRefreshAppStatusTask();
            initUpdateAppStatusToDB();
            initUpdateSession();
            logger.info("--------------系统初始化完成-------------------");
        }
    
        /** * 1.初始化集群数据 */
        private void initClusterCache(){
            logger.info("1.初始化集群信息到缓存中:ClusterCache开始");
            //查询数据库所有的集群数据
            List<ClusterEntity> allClusterInfoList = clusterDao.selectAll(ClusterEntity.class, "delete_flag=0");
            for (ClusterEntity k8sClusterEntity : allClusterInfoList) {
                ClusterCache.put(k8sClusterEntity.getUuid() , k8sClusterEntity);//存入缓存
            }
            logger.info("1.初始化集群信息到缓存中:ClusterCache完成,总共" + allClusterInfoList.size() + "条数据");
        }
    
        /** * 2.初始化异步任务:刷新所有应用状态 */
        private void initRefreshAppStatusTask() {
            logger.info("2.初始化任务:RefreshAllAppStatusTask 刷新应用下的k8s的pod状态并存入待更新队列");
            RefreshAppStatusExcutor.init();
            logger.info("2.初始化任务:RefreshAllAppStatusTask 完成");
        }
    
        /** * 3.初始化异步任务:更新状态到数据库 */
        private void initUpdateAppStatusToDB() {
            logger.info("3.初始化任务:RefreshToDBTask 从待更新Appinstance队列取出数据并更新数据库");
            UpdateAppStatusToDBExcutor.init();
            logger.info("3.初始化任务:RefreshToDBTask 完成");
        }
    
        /** * 4. 初始化异步任务： 更新用户的所有session */
        private void initUpdateSession() {
            logger.info("4.初始化任务：更新session开始");
            UserSessionUpdateExcutor.init();
            logger.info("4.初始化任务：更新session结束");
        }
    
        
    
        //此方法一定不要写成static
        @Override
        public void setApplicationContext(ApplicationContext applicationContext) 
                                                    throws BeansException {
            //实际上是把applicationContext传入到了SpringContextUtil里面
            SpringContextUtil.setApplicationContext(applicationContext);
        }}

[spring]: http://lib.csdn.net/base/javaee