建议收藏!利用Spring解决循环依赖,深入源码给你讲明白!

只有单例模式下的bean会通过三级缓存提前暴露来解决循环依赖的问题。而非单例的bean每次获取都会重新创建,并不会放入三级缓存,所以多实例的bean循环依赖问题不能解决。

首先需要明白处于各个阶段的bean被放在哪里。在DefaultSingletonBeanRegistry类中

/** 一级缓存,存放经历完整生命周期的bean*/ private final Map<String, Object> singletonObjects = new ConcurrentHashMap<String, Object>(256); /** 三级缓存,存放FactoryBean */ private final Map<String, ObjectFactory<?>> singletonFactories = new HashMap<String, ObjectFactory<?>>(16); /** 二级缓存,存放刚刚创建出来还未进行属性赋值的bean */ private final Map<String, Object> earlySingletonObjects = new HashMap<String, Object>(16); 测试代码 public class ServiceAA { public ServiceAA() { System.out.println("AA已经创建"); } private ServiceBB serviceBB; public ServiceBB getServiceBB() { return serviceBB; } public void setServiceBB(ServiceBB serviceBB) { this.serviceBB = serviceBB; } } public class ServiceBB { public ServiceBB() { System.out.println("BB已经创建"); } private ServiceAA serviceAA; public ServiceAA getServiceAA() { return serviceAA; } public void setServiceAA(ServiceAA serviceAA) { this.serviceAA = serviceAA; } } <bean > <property ref="serviceBB"/> </bean> <bean> <property ref="serviceAA"/> </bean> 流程

在上述代码中,ServiceAA 依赖于ServiceBB,同时ServiceBB也依赖于ServiceAA ,各个bean相互依赖,最终形成了闭环,那么spring是如何解决此问题的呢?

可以简单理解为spring创建bean分为两个步骤,第一步是创建原始bean,第二步就是对属性进行赋值和初始化等操作。

每次创建bean之前都会去缓存中查找是否有当前bean,因为是单例,只能有一个

当创建bean serviceAA后,会将其加入三级缓存中,然后需要填充bean的属性了

这时候发现需要依赖于bean serviceBB,接下来又去创建serviceBB。重复1-3的流程

这时候发现需要依赖于bean serviceAA,发现三级缓存中存在bean serviceAA,所以不需要重复创建。把bean serviceAA注入bean serviceBB

这个时候bean serviceBB创建好了,递归继续去为bean serviceAA进行属性赋值。闭环完成

源码 public void refresh() throws BeansException, IllegalStateException { synchronized (this.startupShutdownMonitor) { try { //初始化剩下的单实例bean finishBeanFactoryInitialization(beanFactory); } catch (BeansException ex) { if (logger.isWarnEnabled()) { logger.warn("Exception encountered during context initialization - " + "cancelling refresh attempt: " + ex); } // Destroy already created singletons to avoid dangling resources. destroyBeans(); // Reset 'active' flag. cancelRefresh(ex); // Propagate exception to caller. throw ex; } finally { // Reset common introspection caches in Spring's core, since we // might not ever need metadata for singleton beans anymore... resetCommonCaches(); } } } protected void finishBeanFactoryInitialization(ConfigurableListableBeanFactory beanFactory) { //实例化单实例bean beanFactory.preInstantiateSingletons(); } @Override public void preInstantiateSingletons() throws BeansException { getBean(beanName); } public Object getBean(String name) throws BeansException { return doGetBean(name, null, null, false); } protected <T> T doGetBean( final String name, final Class<T> requiredType, final Object[] args, boolean typeCheckOnly) throws BeansException { final String beanName = transformedBeanName(name); Object bean; //首先查询缓存中是否存在bean,当前为null Object sharedInstance = getSingleton(beanName); final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName); if (mbd.isSingleton()) { sharedInstance = getSingleton(beanName, new ObjectFactory<Object>() { @Override public Object getObject() throws BeansException { try { //创建bean return createBean(beanName, mbd, args); } catch (BeansException ex) { destroySingleton(beanName); throw ex; } } }); bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); } } protected Object getSingleton(String beanName, boolean allowEarlyReference) { //一级缓存中是否存在当前bean(serviceAA),此时为null //isSingletonCurrentlyInCreation(beanName),当前bean是否被标记为 //正在创建,返回false,所以后续不执行,直接返回null Object singletonObject = this.singletonObjects.get(beanName); if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) { synchronized (this.singletonObjects) { singletonObject = this.earlySingletonObjects.get(beanName); if (singletonObject == null && allowEarlyReference) { ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName); if (singletonFactory != null) { singletonObject = singletonFactory.getObject(); this.earlySingletonObjects.put(beanName, singletonObject); this.singletonFactories.remove(beanName); } } } } return (singletonObject != NULL_OBJECT ? singletonObject : null); } public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) { beforeSingletonCreation(beanName); singletonObject = singletonFactory.getObject(); addSingleton(beanName, singletonObject); return (singletonObject != NULL_OBJECT ? singletonObject : null); } protected void beforeSingletonCreation(String beanName) { //将当前正在创建的bean serviceAA 标记为正在创建中,添加到集合singletonsCurrentlyInCreation中 if (!this.inCreationCheckExclusions.contains(beanName) && !this.singletonsCurrentlyInCreation.add(beanName)) { throw new BeanCurrentlyInCreationException(beanName); } } protected Object createBean(String beanName, RootBeanDefinition mbd, Object[] args) throws BeanCreationException { //开始真正的创建bean service AA Object beanInstance = doCreateBean(beanName, mbdToUse, args); return beanInstance; } protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final Object[] args) throws BeanCreationException { BeanWrapper instanceWrapper = null; //用反射创建初始bean serviceAA,源码部分略过 instanceWrapper = createBeanInstance(beanName, mbd, args); //当前为true boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences &&isSingletonCurrentlyInCreation(beanName)); if (earlySingletonExposure) { //如果一级缓存中没有当前bean,就将当前bean放入三级缓存 addSingletonFactory(beanName, new ObjectFactory<Object>() { @Override public Object getObject() throws BeansException { return getEarlyBeanReference(beanName, mbd, bean); } }); } // 初始化bean Object exposedObject = bean; //为当前bean serviceAA赋值 populateBean(beanName, mbd, instanceWrapper); if (earlySingletonExposure) { Object earlySingletonReference = getSingleton(beanName, false); } return exposedObject; } protected void addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) { Assert.notNull(singletonFactory, "Singleton factory must not be null"); //将当前bean serviceAA放入三级缓存,key为beanname value为创建该bean的工厂 synchronized (this.singletonObjects) { if (!this.singletonObjects.containsKey(beanName)) { this.singletonFactories.put(beanName, singletonFactory); this.earlySingletonObjects.remove(beanName); this.registeredSingletons.add(beanName); } } } protected void populateBean(String beanName, RootBeanDefinition mbd, BeanWrapper bw) { //获取当前bean sercieAA所有的属性 PropertyValues pvs = mbd.getPropertyValues(); //......对属性的解析等操作略过 //开始注入属性 applyPropertyValues(beanName, mbd, bw, pvs); } protected void applyPropertyValues(String beanName, BeanDefinition mbd, BeanWrapper bw, PropertyValues pvs) { //封装所有属性的集合,略过 List<PropertyValue> original; for (PropertyValue pv : original) { String propertyName = pv.getName(); Object originalValue = pv.getValue(); //解析引用类型的属性 Object resolvedValue = valueResolver.resolveValueIfNecessary(pv, originalValue); } //应用属性过程略过 } public Object resolveValueIfNecessary(Object argName, Object value) { //判断是否是运行时bean引用 if (value instanceof RuntimeBeanReference) { RuntimeBeanReference ref = (RuntimeBeanReference) value; //解析此引用 service BB return resolveReference(argName, ref); } private Object resolveReference(Object argName, RuntimeBeanReference ref) { String refName = ref.getBeanName(); refName = String.valueOf(doEvaluate(refName)); //开始递归调用getbean方法,当前bean为serviceBB Object bean = this.beanFactory.getBean(refName); }

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpjgys.html