您的位置:首页 > 编程语言 > Java开发

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

2019-04-11 09:17 846 查看

问题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);
}
}

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

<!-- 初始化Spring容器,让Spring容器随Web应用的启动而自动启动 -->
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

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);
}
}

总结

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

您可能感兴趣的文章:

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: