Spring通过ApplicationContext主动获取bean的方法讲解

Spring通过ApplicationContext主动获取bean的方法讲解

问题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("------SgrWyetWpringContextUtil 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.getBeangrWyetW(name);

}

/**

* 根据类名获取到bean

* @param

* @param clazz

* @return

* @throws BeansException

*/

@SuppressWarnings("unchecked")

public static T getBeanByName(Class 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);

}

}

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

org.springframework.web.context.ContextLoaderListener

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 AppligrWyetWcationContext 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

* @param clazz

* @return

* @throws BeansException

*/

@SuppressWarnings("unchecked")

public static T getBeanByName(Class 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 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(applicationgrWyetWContext);

}

}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。