Spring全家桶源码解析--2.3 Spring bean 的依赖注入--@Autowired@Value

news2024/11/25 10:36:00

文章目录

  • 前言
  • 一、@Autowired&@Value:
    • 1.1 @Autowired:
    • 1.2 @Value:
  • 二、依赖注入:
    • 2.1 注入点获取:
    • 2.2 通过 populateBean 入口依赖注入
      • 2.2.1 populateBean :主要通过 postProcessProperties 方法进行依赖注入
      • 2.2.2 postProcessProperties 方法对@Autowired@Value 填充
  • 三、扩展点
    • 3.1 @Primary
    • 3.2 @Qualifier
  • 总结:


前言

在bean完成实例化后之后,还需要对其属性值进行填充。本文介绍@Autowired&@Value 依赖注入


一、@Autowired&@Value:

1.1 @Autowired:

@Autowired是Spring框架提供的一种依赖注入(Dependency Injection)的注解。它可以用于标注在字段、setter方法、构造函数或方法参数上,用于自动装配依赖对象。

@Autowired注解的作用可以总结如下:

(1). 自动装配依赖对象:当使用@Autowired注解标注在一个字段、setter方法、构造函数或方法参数上时,它告诉Spring容器需要自动装配一个对应的依赖对象。

(2). 解决依赖对象冲突:当有多个符合类型的依赖对象可用时,@Autowired注解会尝试根据类型来自动装配对应的依赖对象。如果出现依赖对象冲突,可以使用@Qualifier注解配合@Autowired注解来指定具体要注入的依赖对象。

(3). 支持按照类型匹配和名称匹配:当没有使用@Qualifier注解时,@Autowired注解会首先按照字段类型、方法参数类型或构造函数参数类型进行匹配,如果找到多个符合条件的依赖对象,会再根据字段名、方法名或构造函数参数名称进行匹配。

(4). 方便的依赖注入:使用@Autowired注解可以省去动配置依赖对象的步骤,Spring容器会自动帮助我们解析并装配所需的依赖对象。

需要注意的是,@Autowired解通常与Spring容器中的ApplicationContext一起使用。容器可以根据注解信息自动解析依赖关系,并将对应的依赖对象自动注入到被注解标注的字段、setter方法、构造函数或方法参数中。

1.2 @Value:

@Value是Spring框架提供的一种属性注入的注解。它可以用于标注在字段、setter方法、构造函数或方法参数上,用于注入属性值。

@Value注解的作用可以总结如下:

(1). 注入属性值:当使用@Value注解标注在一个字段、setter方法、构造函数或方法参数上时,它告诉Spring容器需要注入一个指定的属性值。

(2). 从配置文件中读取属性:@Value注解可以用于读取配置文件中的属性值。可以通过${}占位符来引用配置文件中的属性值,并将其注入到被注解标注的字段、setter方法、构造函数或方法参数中。

(3). 注入SpEL表达式值:@Value注解可以用于注入SpEL(Spring Expression Language)表达式值。可以在#{}内使用SpEL表达式,并将计算结果注入到被注解标注的字段、setter方法、构造函数或方法参数中。

(4). 简化配置:使用@Value注解可以省去手动配置属性值的过程,Spring容器会根据注解信息自动将属性值注入到对应的位置。

需要注意的是,@Value注解通常与Spring容器中的ApplicationContext一起使用。容器可以根据注解信息自动解析属性值,并将其注入到注解标注的字段、setter方法、构造函数或方法参数中。另外,@Value注解也支持注入外部化配置属性值,需要配置对应的PropertySourcesPlaceholderConfigurer来解析配置文件中的属性值。

二、依赖注入:

2.1 注入点获取:

通过AutowiredAnnotationBeanPostProcessor的 postProcessMergedBeanDefinition 处理 @Autowired@Value的注入点,在封装后放入到集合中;

public void postProcessMergedBeanDefinition(RootBeanDefinition beanDefinition, Class<?> beanType, String beanName) {
// 获取到@Autowired 和@Value 注解的属性和方法的注入点
// 放入到 map 缓存中 private final Map<String, InjectionMetadata> injectionMetadataCache = new ConcurrentHashMap(256);
    InjectionMetadata metadata = this.findAutowiringMetadata(beanName, beanType, (PropertyValues)null);
    metadata.checkConfigMembers(beanDefinition);
}

findAutowiringMetadata 注入点获取:

private InjectionMetadata findAutowiringMetadata(String beanName, Class<?> clazz, @Nullable PropertyValues pvs) {
    String cacheKey = StringUtils.hasLength(beanName) ? beanName : clazz.getName();
    InjectionMetadata metadata = (InjectionMetadata)this.injectionMetadataCache.get(cacheKey);
    if (InjectionMetadata.needsRefresh(metadata, clazz)) {
        synchronized(this.injectionMetadataCache) {
            metadata = (InjectionMetadata)this.injectionMetadataCache.get(cacheKey);
            if (InjectionMetadata.needsRefresh(metadata, clazz)) {
                if (metadata != null) {
                    metadata.clear(pvs);
                }
				// 获取@Autowired 和@Value 注解的属性,然后包装成类记录属性注入点
                metadata = this.buildAutowiringMetadata(clazz);
                this.injectionMetadataCache.put(cacheKey, metadata);
            }
        }
    }

    return metadata;
}

buildAutowiringMetadata 注入点获取:
注解判断:寻找注入点 加了@Autowired 和@Value 注解的属性和方法

private InjectionMetadata buildAutowiringMetadata(Class<?> clazz) {
    // 如果这个类是基本类 以java. 开头 直接进行返回
   if (!AnnotationUtils.isCandidateClass(clazz, this.autowiredAnnotationTypes)) {
       return InjectionMetadata.EMPTY;
   } else {
       List<InjectionMetadata.InjectedElement> elements = new ArrayList();
       Class<?> targetClass = clazz;

       do {
           List<InjectionMetadata.InjectedElement> fieldElements = new ArrayList();
           // 属性的遍历
           ReflectionUtils.doWithLocalFields(targetClass, (field) -> {
               // 获取到注解
               MergedAnnotation<?> ann = this.findAutowiredAnnotation(field);
               if (ann != null) {
                   if (Modifier.isStatic(field.getModifiers())) {
                      // 注解 的属性是static 直接返回 遍历下一个filed; static 修饰的 是属于类的
                       if (this.logger.isInfoEnabled()) {
                           this.logger.info("Autowired annotation is not supported on static fields: " + field);
                       }

                       return;
                   }
                   // required 属性获取
                   boolean required = this.determineRequiredStatus(ann);
                   fieldElements.add(new AutowiredFieldElement(field, required));
               }

           });

           List<InjectionMetadata.InjectedElement> methodElements = new ArrayList();
              // 方法的遍历 ,遍历处理@Autowired 和@Value 注解的方法
           ReflectionUtils.doWithLocalMethods(targetClass, (method) -> {
              // 如果是桥接方法,则找到被桥接的方法
               Method bridgedMethod = BridgeMethodResolver.findBridgedMethod(method);
               if (BridgeMethodResolver.isVisibilityBridgeMethodPair(method, bridgedMethod)) {
				
                   MergedAnnotation<?> ann = this.findAutowiredAnnotation(bridgedMethod);
                   if (ann != null && method.equals(ClassUtils.getMostSpecificMethod(method, clazz))) {

                       if (Modifier.isStatic(method.getModifiers())) {
                           if (this.logger.isInfoEnabled()) {
                               this.logger.info("Autowired annotation is not supported on static methods: " + method);
                           }

                           return;
                       }

                       if (method.getParameterCount() == 0 && this.logger.isInfoEnabled()) {
                           this.logger.info("Autowired annotation should only be used on methods with parameters: " + method);
                       }

                       boolean required = this.determineRequiredStatus(ann);
                       PropertyDescriptor pd = BeanUtils.findPropertyForMethod(bridgedMethod, clazz);
                       methodElements.add(new AutowiredMethodElement(method, required, pd));
                   }

               }
           });
           elements.addAll(0, this.sortMethodElements(methodElements, targetClass));
           elements.addAll(0, fieldElements);
           targetClass = targetClass.getSuperclass();
           // 子类遍历完毕,然后遍历父类
       } while(targetClass != null && targetClass != Object.class);
          // 封装对象并返回
       return InjectionMetadata.forElements(elements, clazz);
   }
}

2.2 通过 populateBean 入口依赖注入

2.2.1 populateBean :主要通过 postProcessProperties 方法进行依赖注入

protected void populateBean(String beanName, RootBeanDefinition mbd, @Nullable BeanWrapper bw) {
    if (bw == null) {
        if (mbd.hasPropertyValues()) {
            throw new BeanCreationException(mbd.getResourceDescription(), beanName, "Cannot apply property values to null instance");
        }
    } else {
        if (!mbd.isSynthetic() && this.hasInstantiationAwareBeanPostProcessors()) {
            Iterator var4 = this.getBeanPostProcessorCache().instantiationAware.iterator();

            while(var4.hasNext()) {
                InstantiationAwareBeanPostProcessor bp = (InstantiationAwareBeanPostProcessor)var4.next();
                // 先执行bean 的实例化之后方法
                if (!bp.postProcessAfterInstantiation(bw.getWrappedInstance(), beanName)) {
                    return;
                }
            }
        }
  
        PropertyValues pvs = mbd.hasPropertyValues() ? mbd.getPropertyValues() : null;
        int resolvedAutowireMode = mbd.getResolvedAutowireMode();
        if (resolvedAutowireMode == 1 || resolvedAutowireMode == 2) {
            MutablePropertyValues newPvs = new MutablePropertyValues((PropertyValues)pvs);
            if (resolvedAutowireMode == 1) {
                this.autowireByName(beanName, mbd, bw, newPvs);
            }

            if (resolvedAutowireMode == 2) {
                this.autowireByType(beanName, mbd, bw, newPvs);
            }

            pvs = newPvs;
        }

        boolean hasInstAwareBpps = this.hasInstantiationAwareBeanPostProcessors();
        boolean needsDepCheck = mbd.getDependencyCheck() != 0;
        PropertyDescriptor[] filteredPds = null;
        if (hasInstAwareBpps) {
            if (pvs == null) {
                pvs = mbd.getPropertyValues();
            }

            PropertyValues pvsToUse;
            for(Iterator var9 = this.getBeanPostProcessorCache().instantiationAware.iterator(); var9.hasNext(); pvs = pvsToUse) {
                InstantiationAwareBeanPostProcessor bp = (InstantiationAwareBeanPostProcessor)var9.next();
				// @Autowired@Value, @Resource 注解的进行属性注入
                pvsToUse = bp.postProcessProperties((PropertyValues)pvs, bw.getWrappedInstance(), beanName);
                if (pvsToUse == null) {
                    if (filteredPds == null) {
                        filteredPds = this.filterPropertyDescriptorsForDependencyCheck(bw, mbd.allowCaching);
                    }

                    pvsToUse = bp.postProcessPropertyValues((PropertyValues)pvs, filteredPds, bw.getWrappedInstance(), beanName);
                    if (pvsToUse == null) {
                        return;
                    }
                }
            }
        }

        if (needsDepCheck) {
            if (filteredPds == null) {
                filteredPds = this.filterPropertyDescriptorsForDependencyCheck(bw, mbd.allowCaching);
            }

            this.checkDependencies(beanName, mbd, filteredPds, (PropertyValues)pvs);
        }

        if (pvs != null) {
        	// 如果在BeanDefinition 中定义了 bean 的value 进行value 值的填充
            this.applyPropertyValues(beanName, mbd, bw, (PropertyValues)pvs);
        }

    }
}

2.2.2 postProcessProperties 方法对@Autowired@Value 填充

在这里插入图片描述

populateBean 方法中 postProcessProperties 进行依赖注入:通过AutowiredAnnotationBeanPostProcessor 下postProcessProperties进行属性值的填充:

public PropertyValues postProcessProperties(PropertyValues pvs, Object bean, String beanName) {
     // 获取缓存的注入点
    InjectionMetadata metadata = this.findAutowiringMetadata(beanName, bean.getClass(), pvs);

    try {
        // 给注入点 ,设置值
        metadata.inject(bean, beanName, pvs);
        return pvs;
    } catch (BeanCreationException var6) {
        throw var6;
    } catch (Throwable var7) {
        throw new BeanCreationException(beanName, "Injection of autowired dependencies failed", var7);
    }
}

inject 遍历进行赋值:

public void inject(Object target, @Nullable String beanName, @Nullable PropertyValues pvs) throws Throwable {
    Collection<InjectedElement> checkedElements = this.checkedElements;
    Collection<InjectedElement> elementsToIterate = checkedElements != null ? checkedElements : this.injectedElements;
    if (!((Collection)elementsToIterate).isEmpty()) {
        Iterator var6 = ((Collection)elementsToIterate).iterator();

        while(var6.hasNext()) {
            InjectedElement element = (InjectedElement)var6.next();
           //  属性或者方法进行赋值
            element.inject(target, beanName, pvs);
        }
    }

}

filed 属性的注入 AutowiredFieldElement

protected void inject(Object bean, @Nullable String beanName, @Nullable PropertyValues pvs) throws Throwable {
    Field field = (Field)this.member;
    Object value;
    if (this.cached) {
        try {
            value = AutowiredAnnotationBeanPostProcessor.this.resolveCachedArgument(beanName, this.cachedFieldValue);
        } catch (BeansException var7) {
            this.cached = false;
            AutowiredAnnotationBeanPostProcessor.this.logger.debug("Failed to resolve cached argument", var7);
            value = this.resolveFieldValue(field, bean, beanName);
        }
    } else {
			// 获取value
        value = this.resolveFieldValue(field, bean, beanName);
    }

    if (value != null) {
        ReflectionUtils.makeAccessible(field);
		// 反射设置value
        field.set(bean, value);
    }

}

resolveFieldValue 获取value:

private Object resolveFieldValue(Field field, Object bean, @Nullable String beanName) {
	// 获取字段依赖描述 @Autowired 的 required 属性获取
    DependencyDescriptor desc = new DependencyDescriptor(field, this.required);
    desc.setContainingClass(bean.getClass());
    Set<String> autowiredBeanNames = new LinkedHashSet(2);
    Assert.state(AutowiredAnnotationBeanPostProcessor.this.beanFactory != null, "No BeanFactory available");
    // bean 的类型转换器获取
    TypeConverter typeConverter = AutowiredAnnotationBeanPostProcessor.this.beanFactory.getTypeConverter();

    Object value;
    try {
       // 通过spring 容器获取bean
        value = AutowiredAnnotationBeanPostProcessor.this.beanFactory.resolveDependency(desc, beanName, autowiredBeanNames, typeConverter);
    } catch (BeansException 	ar12) {
        throw new UnsatisfiedDependencyException((String)null, beanName, new InjectionPoint(field), var12);
    }

    synchronized(this) {
        if (!this.cached) {
            if (value == null && !this.required) {
                this.cachedFieldValue = null;
            } else {
                Object cachedFieldValue = desc;
                AutowiredAnnotationBeanPostProcessor.this.registerDependentBeans(beanName, autowiredBeanNames);
                if (value != null && autowiredBeanNames.size() == 1) {
                    String autowiredBeanName = (String)autowiredBeanNames.iterator().next();
                    if (AutowiredAnnotationBeanPostProcessor.this.beanFactory.containsBean(autowiredBeanName) && AutowiredAnnotationBeanPostProcessor.this.beanFactory.isTypeMatch(autowiredBeanName, field.getType())) {
                        cachedFieldValue = new ShortcutDependencyDescriptor(desc, autowiredBeanName);
                    }
                }

                this.cachedFieldValue = cachedFieldValue;
                this.cached = true;
            }
        }

        return value;
    }
}

method 方法的注入 AutowiredMethodElement

protected void inject(Object bean, @Nullable String beanName, @Nullable PropertyValues pvs) throws Throwable {
    if (!this.checkPropertySkipping(pvs)) {
		// 没有在beandefintion 中为其设置 值,则进入
        Method method = (Method)this.member;
        Object[] arguments;
        if (this.cached) {
            try {
                arguments = this.resolveCachedArguments(beanName, this.cachedMethodArguments);
            } catch (BeansException var8) {
                this.cached = false;
                AutowiredAnnotationBeanPostProcessor.this.logger.debug("Failed to resolve cached argument", var8);
                arguments = this.resolveMethodArguments(method, bean, beanName);
            }
        } else {
           // 获取多个参数的的bean
            arguments = this.resolveMethodArguments(method, bean, beanName);
        }

        if (arguments != null) {
            try {
                ReflectionUtils.makeAccessible(method);
                // 反射执行
                method.invoke(bean, arguments);
            } catch (InvocationTargetException var7) {
                throw var7.getTargetException();
            }
        }

    }
}

resolveMethodArguments 获取方法的参数值:

@Nullable
private Object[] resolveMethodArguments(Method method, Object bean, @Nullable String beanName) {
	// 这个方法有几个参数
    int argumentCount = method.getParameterCount();
    // 存放对应参数的结果bean
    Object[] arguments = new Object[argumentCount];
    DependencyDescriptor[] descriptors = new DependencyDescriptor[argumentCount];
    Set<String> autowiredBeanNames = new LinkedHashSet(argumentCount * 2);
    Assert.state(AutowiredAnnotationBeanPostProcessor.this.beanFactory != null, "No BeanFactory available");
    TypeConverter typeConverter = AutowiredAnnotationBeanPostProcessor.this.beanFactory.getTypeConverter();
     // 遍历入参
    for(int ix = 0; ix < arguments.length; ++ix) {
         // 封装方法参数占位符
        MethodParameter methodParam = new MethodParameter(method, ix);
       // 方法参数依赖描述
        DependencyDescriptor currDesc = new DependencyDescriptor(methodParam, this.required);
        currDesc.setContainingClass(bean.getClass());
        descriptors[ix] = currDesc;

        try {
              // 向spring 容器获取bean
            Object arg = AutowiredAnnotationBeanPostProcessor.this.beanFactory.resolveDependency(currDesc, beanName, autowiredBeanNames, typeConverter);
            if (arg == null && !this.required) {
                arguments = null;
                break;
            }

            arguments[ix] = arg;
        } catch (BeansException var17) {
            throw new UnsatisfiedDependencyException((String)null, beanName, new InjectionPoint(methodParam), var17);
        }
    }

    synchronized(this) {
        if (!this.cached) {
            if (arguments != null) {
                DependencyDescriptor[] cachedMethodArguments = (DependencyDescriptor[])Arrays.copyOf(descriptors, argumentCount);
                AutowiredAnnotationBeanPostProcessor.this.registerDependentBeans(beanName, autowiredBeanNames);
                if (autowiredBeanNames.size() == argumentCount) {
                    Iterator<String> it = autowiredBeanNames.iterator();
                    Class<?>[] paramTypes = method.getParameterTypes();

                    for(int i = 0; i < paramTypes.length; ++i) {
                        String autowiredBeanName = (String)it.next();
                        if (arguments[i] != null && AutowiredAnnotationBeanPostProcessor.this.beanFactory.containsBean(autowiredBeanName) && AutowiredAnnotationBeanPostProcessor.this.beanFactory.isTypeMatch(autowiredBeanName, paramTypes[i])) {
                            cachedMethodArguments[i] = new ShortcutDependencyDescriptor(descriptors[i], autowiredBeanName);
                        }
                    }
                }

                this.cachedMethodArguments = cachedMethodArguments;
                this.cached = true;
            } else {
                this.cachedMethodArguments = null;
            }
        }

        return arguments;
    }
}
}

resolveDependency 最终都通过改方法获取bean:

@Nullable
public Object resolveDependency(DependencyDescriptor descriptor, @Nullable String requestingBeanName, @Nullable Set<String> autowiredBeanNames, @Nullable TypeConverter typeConverter) throws BeansException {
   // 初始化 方法参数/属性 名称的 发现其
    descriptor.initParameterNameDiscovery(this.getParameterNameDiscoverer());
    if (Optional.class == descriptor.getDependencyType()) {
        return this.createOptionalDependency(descriptor, requestingBeanName);
    } else if (ObjectFactory.class != descriptor.getDependencyType() && ObjectProvider.class != descriptor.getDependencyType()) {
        if (javaxInjectProviderClass == descriptor.getDependencyType()) {
            return (new Jsr330Factory()).createDependencyProvider(descriptor, requestingBeanName);
        } else {
             // 如果有lazy 注解 则返回一个代理对象,没有lazy 注解则返回null
            Object result = this.getAutowireCandidateResolver().getLazyResolutionProxyIfNecessary(descriptor, requestingBeanName);
            if (result == null) {
                 // 非lazy的依赖注入
                result = this.doResolveDependency(descriptor, requestingBeanName, autowiredBeanNames, typeConverter);
            }

            return result;
        }
    } else {
        return new DependencyObjectProvider(descriptor, requestingBeanName);
    }
}

getLazyResolutionProxyIfNecessary :
ContextAnnotationAutowireCandidateResolver 下的getLazyResolutionProxyIfNecessary 如过被@Lazy 注解标注,返回一个代理对象,等到改对象真正被使用的时候才去获取到真正的bean

@Nullable
public Object getLazyResolutionProxyIfNecessary(DependencyDescriptor descriptor, @Nullable String beanName) {
		// 有lazy 注解 通过buildLazyResolutionProxy获取一个代理对象,没有返回null
       //  有lazy 注解 当真正使用的时候 在从spring 容器中获取到对应的bean 然后使用
    return this.isLazy(descriptor) ? this.buildLazyResolutionProxy(descriptor, beanName) : null;
}

isLazy 判断是否懒加载:

protected boolean isLazy(DependencyDescriptor descriptor) {
    Annotation[] var2 = descriptor.getAnnotations();
    int var3 = var2.length;

    for(int var4 = 0; var4 < var3; ++var4) {
        Annotation ann = var2[var4];
        Lazy lazy = (Lazy)AnnotationUtils.getAnnotation(ann, Lazy.class);
        if (lazy != null && lazy.value()) {
            return true;
        }
    }

    MethodParameter methodParam = descriptor.getMethodParameter();
    if (methodParam != null) {
        Method method = methodParam.getMethod();
        if (method == null || Void.TYPE == method.getReturnType()) {
            Lazy lazy = (Lazy)AnnotationUtils.getAnnotation(methodParam.getAnnotatedElement(), Lazy.class);
            if (lazy != null && lazy.value()) {
                return true;
            }
        }
    }

    return false;
}

doResolveDependency 处理非懒加载的bean进行注入:

@Nullable
public Object doResolveDependency(DependencyDescriptor descriptor, @Nullable String beanName, @Nullable Set<String> autowiredBeanNames, @Nullable TypeConverter typeConverter) throws BeansException {
    InjectionPoint previousInjectionPoint = ConstructorResolver.setCurrentInjectionPoint(descriptor);

    Object var23;
    try {
        Object shortcut = descriptor.resolveShortcut(this);
        if (shortcut != null) {
            Object var20 = shortcut;
            return var20;
        }

        Class<?> type = descriptor.getDependencyType();
		// 获取@Value 注解的值
        Object value = this.getAutowireCandidateResolver().getSuggestedValue(descriptor);
        Object var11;
        if (value == null) {
			//  根据bean 的类型和名字获取bean
			// 如果使用 Map<String,UserSerivce> 或者List <UserService>则会 拿到UserService 类型的多个bean
			// 注意Map 的key 必须是String 因为key 为bean 的名称
			// List的泛型为Object 会拿到所有的bean ,如果是<T> 则拿不到bean
			// bean name 获取的筛选责任链:
			// 1 SimpleAutowireCandidateResolver检查BeanDefinition的autowireCandidate属性,为true表示通过筛选
			// 2 GenericTypeAwareAutowireCandidateResolver检查BeanDefinition的beanClass属性和当前注入点的type是否匹配,
			// 匹配则通过筛选
			// 3 QualifierAnnotationAutowireCandidateResolvel检查BeanDefinition的qualifier属性
			// 和当前注入点的qualifier属性是否匹配,匹配则通过筛选
            Object multipleBeans = this.resolveMultipleBeans(descriptor, beanName, autowiredBeanNames, typeConverter);
			// 如果不是Map /List /Array 则multipleBeans 为null, 为普通的对象注入
            if (multipleBeans != null) {
				// 如果获取到了bean 则直接返回
                var23 = multipleBeans;
                return var23;
            }
             // 根据类型获取得到多个bean key 为bean 的名称,value 为bean对象或者bean 的class
            Map<String, Object> matchingBeans = this.findAutowireCandidates(beanName, type, descriptor);
            if (matchingBeans.isEmpty()) {
                 // 根据类型没有获取到bean 并且required 为true 则报错
                if (this.isRequired(descriptor)) {
                    this.raiseNoMatchingBeanFound(type, descriptor.getResolvableType(), descriptor);
                }

                var11 = null;
                return var11;
            }

            Object instanceCandidate;
            Object result;
            String autowiredBeanName;
            if (matchingBeans.size() > 1) {
               //根据类型获取到多个bean ,需要根据名称再次进行过滤
                autowiredBeanName = this.determineAutowireCandidate(matchingBeans, descriptor);
                if (autowiredBeanName == null) {
                      // 如果按照名称没有找到,它的required 是true 则报错
                    if (!this.isRequired(descriptor) && this.indicatesMultipleBeans(type)) {
                        result = null;
                        return result;
                    }

                    result = descriptor.resolveNotUnique(descriptor.getResolvableType(), matchingBeans);
                    return result;
                }
                 // 根据bean 的名称获取到bean
                instanceCandidate = matchingBeans.get(autowiredBeanName);
            } else {
                Map.Entry<String, Object> entry = (Map.Entry)matchingBeans.entrySet().iterator().next();
                autowiredBeanName = (String)entry.getKey();
                instanceCandidate = entry.getValue();
            }

            if (autowiredBeanNames != null) {
                autowiredBeanNames.add(autowiredBeanName);
            }
             // 如果现在的bean 还只是class 则创建这个bean
            if (instanceCandidate instanceof Class) {
                instanceCandidate = descriptor.resolveCandidate(autowiredBeanName, type, this);
            }

            result = instanceCandidate;
            if (instanceCandidate instanceof NullBean) {
                if (this.isRequired(descriptor)) {
                    this.raiseNoMatchingBeanFound(type, descriptor.getResolvableType(), descriptor);
                }

                result = null;
            }

            if (!ClassUtils.isAssignableValue(type, result)) {
                throw new BeanNotOfRequiredTypeException(autowiredBeanName, type, instanceCandidate.getClass());
            }

            Object var14 = result;
            return var14;
        }

        if (value instanceof String) {
              // value 占位符 @Value("${xxx.test}")   获取key 为xxx.test 的value值
             // 如果是@Value("#{userService}") # 的表达式 返回#{userService}"
            String strVal = this.resolveEmbeddedValue((String)value);
            BeanDefinition bd = beanName != null && this.containsBean(beanName) ? this.getMergedBeanDefinition(beanName) : null;
             // 表达式解析 向spring获取 userService 的bean
            value = this.evaluateBeanDefinitionString(strVal, bd);
        }

        TypeConverter converter = typeConverter != null ? typeConverter : this.getTypeConverter();

        try {
             // 如果类型转换器,则使用转换器 对value 进行转换
            var23 = converter.convertIfNecessary(value, type, descriptor.getTypeDescriptor());
        } catch (UnsupportedOperationException var18) {
            var11 = descriptor.getField() != null ? converter.convertIfNecessary(value, type, descriptor.getField()) : converter.convertIfNecessary(value, type, descriptor.getMethodParameter());
            return var11;
        }
    } finally {
        ConstructorResolver.setCurrentInjectionPoint(previousInjectionPoint);
    }

    return var23;
}

determineAutowireCandidate 多个相同类型的bean 进行名称的过滤:


@Nullable
protected String determineAutowireCandidate(Map<String, Object> candidates, DependencyDescriptor descriptor) {
    Class<?> requiredType = descriptor.getDependencyType();
    // 先看下这些bean 有没有被@Primary 注解标识,标注多个报错
    String primaryCandidate = this.determinePrimaryCandidate(candidates, requiredType);
    if (primaryCandidate != null) {
        return primaryCandidate;
    } else {
         // 获取优先级最高的bean   通过@Priority 类的注解 多个@Priority  值一样则报错
        String priorityCandidate = this.determineHighestPriorityCandidate(candidates, requiredType);
        if (priorityCandidate != null) {
            return priorityCandidate;
        } else {
              // 按照bean的名称 获取一个并返回
            Iterator var6 = candidates.entrySet().iterator();

            String candidateName;
            Object beanInstance;
            do {
                if (!var6.hasNext()) {
                    return null;
                }

                Map.Entry<String, Object> entry = (Map.Entry)var6.next();
                candidateName = (String)entry.getKey();
                beanInstance = entry.getValue();
            } while((beanInstance == null || !this.resolvableDependencies.containsValue(beanInstance)) && !this.matchesBeanName(candidateName, descriptor.getDependencyName()));

            return candidateName;
        }
    }
}

三、扩展点

3.1 @Primary

@Primary 是 Spring 框架中的一个注解,用于指定在存在多个候选者时首选的 bean 实例。

当存在多个相同类型的 bean 实例需要被注入时,使用 @Primary 注解标注的 bean 实例将被视为首选的实例,优先被注入。

使用方法:

  1. 定义多个相同类型的 bean 实例,并在其中一个实例上添加 @Primary 注解。
@Component
@Primary
public class PrimaryBean implements MyBean {
    // ...
}

@Component
public class AnotherBean implements MyBean {
    // ...
}
  1. 在需要注入的地方使用对应的类型进行注入。
@Component
public class MyComponent {
    @Autowired
    private MyBean bean;
    
    // ...
}

在上面的示例中,PrimaryBean 类上使用了 @Primary 注解,意味着它是首选的 bean 实例。当需要注入 MyBean 类型的实例时,会优先选择注入 PrimaryBean 实例。这样就可以通过 @Primary 注解指定首选的 bean 实例,解决多个候选者的注入歧义。

3.2 @Qualifier

@Qualifier 是 Spring 框架中的一个注解,用于解决依赖注入时的歧义性问题。当存在多个类型一致的 bean 实例可供选择时,可以通过 @Qualifier 注解进行标识,以明确指定要注入的 bean 实例。

通常情况下,@Qualifier 注解与其他注解(如 @Autowired@Resource)共同使用,用于指定具体要注入的 bean例。

使用方法:

  1. 定义多个相同类型的 bean 实例,并添加对应的 @Qualifier 注解标识符,可以是类名首字母小写的形式。
@Component
@Qualifier("beanA")
public class BeanA implements MyBean {
    // ...
}

@Component
@Qualifier("beanB")
public class BeanB implements MyBean {
    // ...
}
  1. 在需要注入的地方使用 @Qualifier 注解指定要注入的具体 bean 实例。
@Component
public class MyComponent {
    @Autowired
    @Qualifier("beanA")
    private MyBean bean;
    
    // ...
}

在上面的示例中,通过 @Qualifier("beanA") 指定要注入的 bean 实例为标识符为 “beanA” 的 BeanA 类。这样就可以解决依赖注入时的歧义性问题,确保正确注入指定的 bean 实例。

总结:

在bean 实例化之后 通过populateBean 对属性和方法的入参进行依赖注入,首先扫描记录哪些属性和方法需要进行依赖注入,AutowiredAnnotationBeanPostProcessor 的 postProcessMergedBeanDefinition @Autowired 和@Value 注解的属性和方法的注入点;
然后遍历完成注入,通过AutowiredAnnotationBeanPostProcessor 进行完成@Autowired 和@Value的依赖注入;

@Autowired 和@Value 依赖注入: AutowiredFieldElement 和AutowiredMethodElement 分别对属性和方法的入参进行依赖注入

DefaultListableBeanFactory.doResolveDependency 方法中首先对@Value 进行处理:

  • 如果使用@Value(" x x x " ) 使用 {xxx}") 使用 xxx")使用 符号则解析到xxx 对应的value 值,然后判断是否有类型转换器,有的话则进行转换在赋值,没有直接赋值,如果类型错误则报错;
  • 如果使用@Value(“#{xxx}”) 使用$ 符号则解析到xxx 对应的value 值,然后在容器中寻找对应xxx 的bean ,找到后进行赋值,找不到则报错;

@Value 处理之后,获取到该类型的所以bean,获取的过程:

  • SimpleAutowireCandidateResolver检查BeanDefinition的autowireCandidate属性,为true表示通过筛选;可以通过在bean的@Autowired注解中设置required属性来控制,默认情况下,required属性的值为true,表示该bean是必需进行自动装配的。如果没有找到匹配的依赖项,则会抛出NoSuchBeanDefinitionException异常。要将required属性设置为false,表示该依赖项是可选的,如果找不到匹配的依赖项,Spring会将该字段设置为null,而不会抛出异常 ;
  • GenericTypeAwareAutowireCandidateResolver检查BeanDefinition的beanClass和当前注入点的type是否匹配,匹配则通过筛选;
  • QualifierAnnotationAutowireCandidateResolver检查BeanDefinition的qualifier属性值和当前注入点的qualifier属性值是否匹配,匹配则通过筛选
  • 把筛选之后的bean添加到一个Map中key为beanName,value为bean对象,如果Map中有多个Bean,继续进行筛选;
  • 从多个Bean中获取被@Primary注解标注的Bean;
  • 从多个Bean中获取优先级最高的Bean;
  • 从多个Bean中获取注入点name对应的bean;
  • 通过反射进行属性赋值或方法调用;

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1206655.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Android WebView专题

WebView 专题 第一个WebView程序&#xff1a;加载远程网址 Layout添加WebView组件&#xff1b; <WebViewandroid:id"id/webView_first"android:layout_width"match_parent"android:layout_height"match_parent"/>初始化组件&#xff0c;加…

新闻发稿有什么用?新闻发稿怎么做?

随着互联网的普及和信息传播速度的加快&#xff0c;新闻发稿成为越来越多企业和个人宣传自身形象、扩大品牌知名度和影响力的有效手段。本文将探讨新闻发稿的作用和如何进行新闻发稿。 一、新闻发稿的作用 1.提高品牌知名度 通过新闻发稿&#xff0c;企业或个人可以在媒体上展…

谁输了,就往衣服里面倒水,欲望秀场与亲密的操控,当一位女博士生成为主播

在澎湃新闻上&#xff0c;读到香港大学博士生王怡霖的一篇自述文章。 为了研究秀场直播&#xff0c;她跟一家公会签约&#xff0c;当了秀场主播。 感谢王怡霖&#xff0c;愿意做这样的研究&#xff0c;为我们提供了解社会现实的一个观察视角。 三年主播体验观察下来&#xff0c…

【SpringBoot篇】使用Spring Cache高效处理缓存数据

文章目录 &#x1f339;简述Spring Cache&#x1f3f3;️‍&#x1f308;常用注解&#x1f33a;使用SpringCache&#x1f6f8;Cacheable注解⭐测试 &#x1f6f8;CacheEvict&#x1f38d;一次清理一条数据&#x1f38d;一次删除多条数据 Spring Cache是一个框架,只要简单加一个…

电脑监控软件不联网是不是就没事?

电脑监控软件不联网是不是就没事&#xff1f; 回答&#xff1a;不是&#xff0c;不联网仍旧会正常工作。 虽然电脑监控软件在不联网的情况下无法通过网络进行数据传输&#xff0c;但并不意味着它完全失效。 有些监控软件在安装时可能分为管理端、服务器端和员工端&#xff0c…

基于 Lua 写一个爬虫程序

你想要基于 Lua 写一个爬虫程序来爬取的内容。我可以给你一个基本的框架&#xff0c;但是请注意这只是一个示例&#xff0c;并且你可能需要根据实际情况进行调整。 -- 首先&#xff0c;我们需要引入一些必要的模块 local http require "socket.http" local json r…

【Python基础篇】变量

博主&#xff1a;&#x1f44d;不许代码码上红 欢迎&#xff1a;&#x1f40b;点赞、收藏、关注、评论。 格言&#xff1a; 大鹏一日同风起&#xff0c;扶摇直上九万里。 文章目录 一 Python中变量的定义二 Python中变量的使用三 Python中变量的类型四 Python中变量的删除五 …

什么是稳定扩散中的采样步骤?

在线工具推荐&#xff1a; Three.js AI纹理开发包 - YOLO合成数据生成器 - GLTF/GLB在线编辑 - 3D模型格式在线转换 - 3D数字孪生场景编辑器 本指南将深入探讨采样步骤的基础知识、它们对图像生成的影响&#xff0c;以及优化这些步骤以获得最佳结果的技巧。 了解稳定扩散中…

锅鸡unity和unityHub泼姐

链接在下面 支持pj所有国际版本的Unity和UnityHub。 自从 Unity2022.2.0 及以上版本重构了License逻辑&#xff0c;目前无法pj。问题跳转&#xff1a;#78 下载地址 Unity国际版 官方下载地址&#xff08;需要配置代理&#xff0c;代理没配置好可能会下载的国内版&#xff09…

应用亚马逊云科技,Share Creators1个月内上线生成式AI生图模块

随着生成式AI在全球范围爆火&#xff0c;如何充分利用生成式AI自动生成内容提高创作效率已成为设计领域创新的关键突破口。对于设计行业和游戏行业的众多企业和团队而言&#xff0c;管理数字资产的能力是其实现高效创作最大的挑战之一&#xff0c;也是在降本增效的流程中非常容…

服务器CPU高居不下,JAVA线程占用如何排查

1. 查看占用cpu占用过高进程的pid 使用 top名称查看 这里可以看的出来进程是20943 2. 查看该进程中哪个线程占用大量 CPU ps -mp 20943 -o THREAD,tid,time | grep $(ps -mp 20943 -o THREAD,tid,time |awk NR>2 {print $2}|sort -nr|head -1)|head -1 root 1.0 1…

Fourier分析导论——第5章——实数据R上的Fourier变换(E.M. Stein R. Shakarchi)

第5章 实数域ℝ上的Fourier变换 The theory of Fourier series and integrals has always had major difficulties and necessitated a large math- ematical apparatus in dealing with questions of con- vergence. It engendered the development of methods of summa…

arcgis--浮点型栅格数据转整型

利用【Spatial Analyst工具】-【数学】-【转为整型】工具&#xff0c;将浮点型数据转为整型。如下&#xff1a; 【转为整型】对话框参数设计如下&#xff1a; 转换结果如下&#xff1a;

聚焦车用AI算力,奕行智能EVAS完成超亿元Pre-A+轮融资并即将推出端侧算力芯片产品

近日&#xff0c;奕行智能科技&#xff08;广州&#xff09;有限公司&#xff08;以下简称&#xff1a;“奕行智能”&#xff09;完成超亿元人民币Pre-A轮融资。本轮融资由广州南沙科金控股集团有限公司下属广州南沙区南金基金管理有限公司作为领投方&#xff0c;东南亚最大的金…

【反编译系列】二、反编译 .pyc 文件(uncompyle6)

文章目录 【反编译系列】二、反编译 .pyc 文件&#xff08;uncompyle6&#xff09;1. 介绍2. 反编译Reference 【反编译系列】二、反编译 .pyc 文件&#xff08;uncompyle6&#xff09; 1. 介绍 .pyc 文件是 Python 将 .py 源代码编译后生成的字节码文件,主要有以下几个特点和…

【java进阶】Java中线程的实现方式

&#x1f308;键盘敲烂&#xff0c;年薪30万&#x1f308; 线程的四种实现方式&#xff1a; 1. 继承Thread类 2. 实现Runnable接口 3. 实现Collable接口 4. 线程池获取线程 1. 继承Thread类 &#x1f4a7;优点&#xff1a; 简单易懂&#xff0c;适用于简单的线程需求。直接…

Python开源项目VQFR——人脸重建(Face Restoration),模糊清晰、划痕修复及黑白上色的实践

Python Anaconda 的安装等请参阅&#xff1a; Python开源项目CodeFormer——人脸重建&#xff08;Face Restoration&#xff09;&#xff0c;模糊清晰、划痕修复及黑白上色的实践https://blog.csdn.net/beijinghorn/article/details/134334021 VQFR也是 腾讯 LAB 的作品&…

无代码:解决非程序员的开发难题

最近&#xff0c;有个小型企业的负责人找上我&#xff0c;说他公司需要一个内部管理系统&#xff0c;来提高工作和协作效率&#xff0c;但他没有编程经验&#xff0c;也不打算花费大量时间和金钱雇佣专业的开发团队&#xff0c;他问我有没有什么解决方案。 针对这个问题&#…

臀部筋膜炎怎么治疗最有效

臀部筋膜炎的主要症状包括以下几点&#xff1a; 一、筋膜炎发生时会导致臀部疼痛以及局部红肿的情况。 二、可能会引起臀部活动受限。 三、可能会导致患者不能取坐位&#xff0c;因为坐位时可能由于局部压迫而引起筋膜炎疼痛症状加重&#xff0c;而引起患者不能取坐位的情况…

酷开科技丨酷开系统,带你进入惊喜不断的影视世界!

随着科技的迅速发展&#xff0c;智能电视已经成为家庭娱乐的重要组成部分。而要说到智能电视&#xff0c;就不得不提到酷开系统&#xff0c;作为一款智能电视操作系统&#xff0c;酷开系统以其独特的功能和出色的使用体验&#xff0c;让观众们看到了到惊喜不断的影视世界。 如…