编写一个可动态注入Spring 容器的工具类

朱雀 2022-09-02 14:59 122阅读 0赞

> **导语**  
>   在有些使用场景下，我们使用Bean的时候发现它并没有那么必要在这个类中注入对应的对象引用。就有一个需求，就是再需要的地方将指定的类注入到容器中，这样这个类就可以动态的使用到原本已经在容器中的依赖关系，方便我们的开发。那么如何实现这个需求呢？

首先我们知道Spring 容器作为Spring的核心应用，所有的对象依赖关系都是在这个容器中进行的，而对于容器中比较重要的一点就是工厂设计模式与上下文机制，这里我选择了是ConfigurableListableBeanFactory工厂 和 ApplicationContext 上下文环境，当然，我们这个实现的比较简单所以选择的是底层工厂，如果需要其他复杂的操作，则可以使用更加抽象的工厂类操作。

## 定义工具类 ##

import org.springframework.aop.framework.AopContext;
    import org.springframework.beans.BeansException;
    import org.springframework.beans.factory.NoSuchBeanDefinitionException;
    import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
    import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    import com.ruoyi.common.utils.StringUtils;
    
    /** * spring工具类 方便在非spring管理环境中获取bean * * @author ruoyi */
    @Component
    public final class SpringUtils implements BeanFactoryPostProcessor, ApplicationContextAware 
    { 
        /** Spring应用上下文环境 */
        private static ConfigurableListableBeanFactory beanFactory;
    
        private static ApplicationContext applicationContext;
    
        @Override
        public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException 
        { 
            SpringUtils.beanFactory = beanFactory;
        }
    
        @Override
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException 
        { 
            SpringUtils.applicationContext = applicationContext;
        }
    
        /** * 获取对象 * * @param name * @return Object 一个以所给名字注册的bean的实例 * @throws org.springframework.beans.BeansException * */
        @SuppressWarnings("unchecked")
        public static <T> T getBean(String name) throws BeansException
        { 
            return (T) beanFactory.getBean(name);
        }
    
        /** * 获取类型为requiredType的对象 * * @param clz * @return * @throws org.springframework.beans.BeansException * */
        public static <T> T getBean(Class<T> clz) throws BeansException
        { 
            T result = (T) beanFactory.getBean(clz);
            return result;
        }
    
        /** * 如果BeanFactory包含一个与所给名称匹配的bean定义，则返回true * * @param name * @return boolean */
        public static boolean containsBean(String name)
        { 
            return beanFactory.containsBean(name);
        }
    
        /** * 判断以给定名字注册的bean定义是一个singleton还是一个prototype。 如果与给定名字相应的bean定义没有被找到，将会抛出一个异常（NoSuchBeanDefinitionException） * * @param name * @return boolean * @throws org.springframework.beans.factory.NoSuchBeanDefinitionException * */
        public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException
        { 
            return beanFactory.isSingleton(name);
        }
    
        /** * @param name * @return Class 注册对象的类型 * @throws org.springframework.beans.factory.NoSuchBeanDefinitionException * */
        public static Class<?> getType(String name) throws NoSuchBeanDefinitionException
        { 
            return beanFactory.getType(name);
        }
    
        /** * 如果给定的bean名字在bean定义中有别名，则返回这些别名 * * @param name * @return * @throws org.springframework.beans.factory.NoSuchBeanDefinitionException * */
        public static String[] getAliases(String name) throws NoSuchBeanDefinitionException
        { 
            return beanFactory.getAliases(name);
        }
    
        /** * 获取aop代理对象 * * @param invoker * @return */
        @SuppressWarnings("unchecked")
        public static <T> T getAopProxy(T invoker)
        { 
            return (T) AopContext.currentProxy();
        }
    
        /** * 获取当前的环境配置，无配置返回null * * @return 当前的环境配置 */
        public static String[] getActiveProfiles()
        { 
            return applicationContext.getEnvironment().getActiveProfiles();
        }
    
        /** * 获取当前的环境配置，当有多个环境配置时，只获取第一个 * * @return 当前的环境配置 */
        public static String getActiveProfile()
        { 
            final String[] activeProfiles = getActiveProfiles();
            return StringUtils.isNotEmpty(activeProfiles) ? activeProfiles[0] : null;
        }
    }

## 使用工具类 ##

/** * 查询所有角色 * * @return 角色列表 */
        @Override
        public List<SysRole> selectRoleAll()
        { 
            return SpringUtils.getAopProxy(this).selectRoleList(new SysRole());
        }

/** * 清空字典缓存 */
        public static void clearDictCache()
        { 
            Collection<String> keys = SpringUtils.getBean(RedisCache.class).keys(Constants.SYS_DICT_KEY + "*");
            SpringUtils.getBean(RedisCache.class).deleteObject(keys);
        }