溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Spring通過ApplicationContext主動(dòng)獲取bean的示例分析

發(fā)布時(shí)間:2021-05-22 11:42:02 來源:億速云 閱讀:317 作者:小新 欄目:編程語言

這篇文章給大家分享的是有關(guān)Spring通過ApplicationContext主動(dòng)獲取bean的示例分析的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,一起跟隨小編過來看看吧。

問題1:

有個(gè)異步線程Runnable里面需要用到dao,無法通過AutoWired和compoment注解傳遞進(jìn)來。

于是希望通過Spring context主動(dòng)去獲取bean。

問題2:

getBean(name)獲取失敗。

解決:

默認(rèn)的dao的name=類名(首字母小寫)

例如:

接口名稱:TemplateDao 則getName(“templateDao”)即可

通用的SpringContextUtil獲取Bean

1.實(shí)現(xiàn)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默認(rèn) = 類名(首字母小寫)
   * 例如: A8sClusterDao = getBean("k8sClusterDao")
   * @param name
   * @return
   * @throws BeansException
   */
  public static Object getBean(String name) throws BeansException {
    return applicationContext.getBean(name);
  }
  /**
   * 根據(jù)類名獲取到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項(xiàng)目中的web.xml中配置加載Spring容器的Listener

<!-- 初始化Spring容器,讓Spring容器隨Web應(yīng)用的啟動(dòng)而自動(dòng)啟動(dòng) --> 
  <listener> 
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 
  </listener>

getBeanByName(Class clazz)

這個(gè)方法更好使用,不過需要注意Dao和service的impl里面需要配置好名稱為@Service(“myService”)

規(guī)則為接口Service的類名首字母小寫。

第二種方式:

目前又做了個(gè)系統(tǒng)初始化的東東SystemInit,然后發(fā)現(xiàn)上面的getBean()用不了了??戳讼掳l(fā)現(xiàn)是因?yàn)樵谙到y(tǒng)初始化的時(shí)候SpringContextUtil還沒有初始化,導(dǎo)致在SystemInit類里面的東西getBean()失敗。

于是小改造了下,把ApplicationContextAware放在SystemInit類,然后注入到SpringContextUtil,這樣就保證了在執(zhí)行系統(tǒng)初始化方法之前,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默認(rèn) = 類名(首字母小寫)
   * 例如: A8sClusterDao = getBean("k8sClusterDao")
   * @param name
   * @return
   * @throws BeansException
   */
  public static Object getBean(String name) throws BeansException {
    return applicationContext.getBean(name);
  }
  /**
   * 根據(jù)類名獲取到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: 系統(tǒng)初始化
 * @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("--------------系統(tǒng)初始化中-------------------");
    initClusterCache();//初始化集群數(shù)據(jù) 必須最開始完成
    initRefreshAppStatusTask();
    initUpdateAppStatusToDB();
    initUpdateSession();
    logger.info("--------------系統(tǒng)初始化完成-------------------");
  }
  /**
   * 1.初始化集群數(shù)據(jù)
   */
  private void initClusterCache(){
    logger.info("1.初始化集群信息到緩存中:ClusterCache開始");
    //查詢數(shù)據(jù)庫所有的集群數(shù)據(jù)
    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() + "條數(shù)據(jù)");
  }
  /**
   * 2.初始化異步任務(wù):刷新所有應(yīng)用狀態(tài)
   */
  private void initRefreshAppStatusTask() {
    logger.info("2.初始化任務(wù):RefreshAllAppStatusTask 刷新應(yīng)用下的k8s的pod狀態(tài)并存入待更新隊(duì)列");
    RefreshAppStatusExcutor.init();
    logger.info("2.初始化任務(wù):RefreshAllAppStatusTask 完成");
  }
  /**
   * 3.初始化異步任務(wù):更新狀態(tài)到數(shù)據(jù)庫
   */
  private void initUpdateAppStatusToDB() {
    logger.info("3.初始化任務(wù):RefreshToDBTask 從待更新Appinstance隊(duì)列取出數(shù)據(jù)并更新數(shù)據(jù)庫");
    UpdateAppStatusToDBExcutor.init();
    logger.info("3.初始化任務(wù):RefreshToDBTask 完成");
  }
  /**
   * 4. 初始化異步任務(wù): 更新用戶的所有session
   */
  private void initUpdateSession() {
    logger.info("4.初始化任務(wù):更新session開始");
    UserSessionUpdateExcutor.init();
    logger.info("4.初始化任務(wù):更新session結(jié)束");
  }
  ////////////////////////////////////////////////////////////////
  //此方法一定不要寫成static
  @Override
  public void setApplicationContext(ApplicationContext applicationContext) 
                        throws BeansException {
    //實(shí)際上是把a(bǔ)pplicationContext傳入到了SpringContextUtil里面
    SpringContextUtil.setApplicationContext(applicationContext);
  }
}

感謝各位的閱讀!關(guān)于“Spring通過ApplicationContext主動(dòng)獲取bean的示例分析”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到吧!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI