1.一文详解RocketMQ-Spring的配置配置源码解析与实战
2.从源码层面带你实现一个自动注入注解
3.Spring5源码分析之@Configuration注解的详解。希望读者能够耐着性子看完
4.「玩转SpringBoot」配置文件yml的文件文件正确打开姿势

一文详解RocketMQ-Spring的源码解析与实战

       火箭MQ与Spring Boot整合详解：源码解析与实战

       本文将带你深入理解在Spring Boot项目中如何运用rocketmq-spring SDK进行消息收发，同时剖析其设计逻辑。自动注入自动此SDK是源码开源项目Apache RocketMQ的Spring集成，旨在简化在Spring Boot中的分析消息传递操作。

       首先，生成怎么保存素材源码我们介绍rocketmq-spring-boot-starter的配置配置基本概念。它本质上是文件文件一个Spring Boot启动器，以“约定优于配置”的自动注入自动理念提供便捷的集成。通过在pom.xml中引入依赖并配置基本的源码配置文件，即可快速开始使用。分析

       配置rocketmq-spring-boot-starter时，生成需要关注以下两点：引入相关依赖和配置文件设置。配置配置生产者和消费者部分，文件文件我们将分别详细讲解操作步骤。自动注入自动

       对于生产者，仅需配置名字服务地址和生产者组，然后在需要发送消息的类中注入RocketMQTemplate，最后使用其提供的校时源码发送方法，如同步发送消息。模板类RocketMQTemplate封装了RocketMQ的API，简化了开发流程。

       消费者部分，同样在配置文件中配置，然后实现RocketMQListener，以便处理接收到的消息。源码分析显示，RocketMQAutoConfiguration负责启动消费者，其中DefaultRocketMQListenerContainer封装了RocketMQ的消费逻辑，确保支持多种参数类型。

       学习rocketmq-spring的最佳路径包括：首先通过示例代码掌握基本操作；其次理解模块结构和starter设计；接着深入理解自动配置文件和RocketMQ核心API的封装；最后，通过项目实践，扩展自己的知识，尝试自定义简单的Spring Boot启动器。

       通过这篇文章，希望你不仅能掌握rocketmq-spring在Spring Boot中的应用，还能提升对Spring Boot启动器和RocketMQ源码的源码 心理解。继续保持学习热情，探索更多技术细节！

从源码层面带你实现一个自动注入注解

       首先，需要了解到的是。SpringBean的生命周期

       在生命周期中。注入bean属性的位置是在以下代码：populateBean位置中

       那么我们在项目中使用注解产生一个bean的时候必定会经过以下代码进行一个bean的创建流程

/**省略代码**///开始初始化bean实例对象ObjectexposedObject=bean;try{ //<5>对bean进行填充，将各个属性值注入，其中，可能存在依赖于其他bean的属性populateBean(beanName,mbd,instanceWrapper);//<6>调用初始化方法exposedObject=initializeBean(beanName,exposedObject,mbd);}catch(Throwableex){ if(exinstanceofBeanCreationException&&beanName.equals(((BeanCreationException)ex).getBeanName())){ throw(BeanCreationException)ex;}else{ thrownewBeanCreationException(mbd.getResourceDescription(),beanName,"Initializationofbeanfailed",ex);}}/**省略代码**/

       在生命周期中populateBean进行填充bean数据。把其他依赖引入进来

       BeanPostProcessor是一个bean创建时候的一个钩子。

       以下代码是循环调用实现了BeanPostProcessor子类InstantiationAwareBeanPostProcessor#postProcessProperties方法

       Spring在以下代码中有自动注入的拓展点。关键就是实现InstantiationAwareBeanPostProcessor#postProcessProperties

/**省略代码**/for(BeanPostProcessorbp:getBeanPostProcessors()){ if(bpinstanceofInstantiationAwareBeanPostProcessor){ InstantiationAwareBeanPostProcessoribp=(InstantiationAwareBeanPostProcessor)bp;//对所有需要依赖检查的属性进行后处理PropertyValuespvsToUse=ibp.postProcessProperties(pvs,bw.getWrappedInstance(),beanName);if(pvsToUse==null){ //从bw对象中提取PropertyDescriptor结果集//PropertyDescriptor：可以通过一对存取方法提取一个属性if(filteredPds==null){ filteredPds=filterPropertyDescriptorsForDependencyCheck(bw,mbd.allowCaching);}pvsToUse=ibp.postProcessPropertyValues(pvs,filteredPds,bw.getWrappedInstance(),beanName);if(pvsToUse==null){ return;}}pvs=pvsToUse;}}/**省略代码**/

       我们展开来讲一下@Autowired的实现是怎么样的吧：

       实现类为AutowiredAnnotationBeanPostProcessor.java

       从上面可以得知，填充bean的时候。时调用了方法ibp.postProcessPropertyValues()

       那么AutowiredAnnotationBeanPostProcessor#postProcessPropertyValues()则会被调用

       调用findAutowiringMetadata获取class以及父类带有@Autowired或者@Value的属性或者方法：

/**省略代码**/publicPropertyValuespostProcessProperties(PropertyValuespvs,Objectbean,StringbeanName){ //获取所有可以注入的元数据InjectionMetadatametadata=findAutowiringMetadata(beanName,bean.getClass(),pvs);try{ //注入数据metadata.inject(bean,beanName,pvs);}catch(BeanCreationExceptionex){ throwex;}catch(Throwableex){ thrownewBeanCreationException(beanName,"Injectionofautowireddependenciesfailed",ex);}returnpvs;}privateInjectionMetadatafindAutowiringMetadata(StringbeanName,Class<?>clazz,@NullablePropertyValuespvs){ //缓存名字获取StringcacheKey=(StringUtils.hasLength(beanName)?beanName:clazz.getName());InjectionMetadatametadata=this.injectionMetadataCache.get(cacheKey);//获取是否已经读取过这个class类的InjectionMetadata有的话直接从缓存中获取出去if(InjectionMetadata.needsRefresh(metadata,clazz)){ synchronized(this.injectionMetadataCache){ //双重检查metadata=this.injectionMetadataCache.get(cacheKey);if(InjectionMetadata.needsRefresh(metadata,clazz)){ if(metadata!=null){ metadata.clear(pvs);}//构建自动注入的元数据metadata=buildAutowiringMetadata(clazz);this.injectionMetadataCache.put(cacheKey,metadata);}}}returnmetadata;}privateInjectionMetadatabuildAutowiringMetadata(finalClass<?>clazz){ if(!AnnotationUtils.isCandidateClass(clazz,this.autowiredAnnotationTypes)){ returnInjectionMetadata.EMPTY;}List<InjectionMetadata.InjectedElement>elements=newArrayList<>();Class<?>targetClass=clazz;do{ finalList<InjectionMetadata.InjectedElement>currElements=newArrayList<>();//循环targetClass的所有field并执FieldCallback逻辑（函数式编程接口，传入的是一个执行函数）ReflectionUtils.doWithLocalFields(targetClass,field->{ //获得字段上面的Annotation注解MergedAnnotation<?>ann=findAutowiredAnnotation(field);if(ann!=null){ //判断是否为静态属性如果是，则不进行注入if(Modifier.isStatic(field.getModifiers())){ if(logger.isInfoEnabled()){ logger.info("Autowiredannotationisnotsupportedonstaticfields:"+field);}return;}//注解是否为必须依赖项booleanrequired=determineRequiredStatus(ann);currElements.add(newAutowiredFieldElement(field,required));}});//循环targetClass的所有Method并执MethodCallback逻辑（函数式编程接口，传入的是一个执行函数）ReflectionUtils.doWithLocalMethods(targetClass,method->{ MethodbridgedMethod=BridgeMethodResolver.findBridgedMethod(method);if(!BridgeMethodResolver.isVisibilityBridgeMethodPair(method,bridgedMethod)){ return;}MergedAnnotation<?>ann=findAutowiredAnnotation(bridgedMethod);if(ann!=null&&method.equals(ClassUtils.getMostSpecificMethod(method,clazz))){ //判断是否为静态方法如果是，则不进行注入if(Modifier.isStatic(method.getModifiers())){ if(logger.isInfoEnabled()){ logger.info("Autowiredannotationisnotsupportedonstaticmethods:"+method);}return;}//判断静态方法参数是dedeapp源码否为0if(method.getParameterCount()==0){ if(logger.isInfoEnabled()){ logger.info("Autowiredannotationshouldonlybeusedonmethodswithparameters:"+method);}}booleanrequired=determineRequiredStatus(ann);PropertyDescriptorpd=BeanUtils.findPropertyForMethod(bridgedMethod,clazz);currElements.add(newAutowiredMethodElement(method,required,pd));}});//数据加到数组最前方父类的的注解都放在靠前的位置elements.addAll(0,currElements);//如果有父类则设置targetClass为父类。如此循环targetClass=targetClass.getSuperclass();}while(targetClass!=null&&targetClass!=Object.class);returnInjectionMetadata.forElements(elements,clazz);}/**省略代码**/

       真正注入数据的是metadata.inject(bean,beanName,pvs);

       调用的是InjectionMetadata#inject方法

publicvoidinject(Objecttarget,@NullableStringbeanName,@NullablePropertyValuespvs)throwsThrowable{ Collection<InjectedElement>checkedElements=this.checkedElements;//带有注解的方法或者属性列表Collection<InjectedElement>elementsToIterate=(checkedElements!=null?checkedElements:this.injectedElements);if(!elementsToIterate.isEmpty()){ for(InjectedElementelement:elementsToIterate){ element.inject(target,beanName,pvs);}}}

       循环调用之前加入的带有注解的方法或者属性构建的对象AutowiredFieldElement#inject，AutowiredMethodElement#inject

/***属性上有注解构建的处理对象*/privateclassAutowiredFieldElementextendsInjectionMetadata.InjectedElement{ privatefinalbooleanrequired;privatevolatilebooleancached;@NullableprivatevolatileObjectcachedFieldValue;publicAutowiredFieldElement(Fieldfield,booleanrequired){ super(field,null);this.required=required;}@Overrideprotectedvoidinject(Objectbean,@NullableStringbeanName,@NullablePropertyValuespvs)throwsThrowable{ //获取属性名Fieldfield=(Field)this.member;Objectvalue;//Bean不是单例的话，会重复进入注入的这个操作，if(this.cached){ try{ value=resolvedCachedArgument(beanName,this.cachedFieldValue);}catch(NoSuchBeanDefinitionExceptionex){ //Unexpectedremovaloftargetbeanforcachedargument->re-resolvevalue=resolveFieldValue(field,bean,beanName);}}else{ //首次创建的时候进入该方法value=resolveFieldValue(field,bean,beanName);}if(value!=null){ //属性如果不为public的话，则设置为可访问ReflectionUtils.makeAccessible(field);field.set(bean,value);}}@NullableprivateObjectresolveFieldValue(Fieldfield,Objectbean,@NullableStringbeanName){ //构建DependencyDescriptor对象DependencyDescriptordesc=newDependencyDescriptor(field,this.required);desc.setContainingClass(bean.getClass());//注入bean的数量。有可能字段上是一个ListSet<String>autowiredBeanNames=newLinkedHashSet<>(1);Assert.state(beanFactory!=null,"NoBeanFactoryavailable");//获得beanFactory类型转换类TypeConvertertypeConverter=beanFactory.getTypeConverter();Objectvalue;try{ //查找依赖关系value=beanFactory.resolveDependency(desc,beanName,autowiredBeanNames,typeConverter);}catch(BeansExceptionex){ thrownewUnsatisfiedDependencyException(null,beanName,newInjectionPoint(field),ex);}synchronized(this){ if(!this.cached){ ObjectcachedFieldValue=null;if(value!=null||this.required){ cachedFieldValue=desc;//填入依赖关系registerDependentBeans(beanName,autowiredBeanNames);//判断如果注入依赖是只有一个if(autowiredBeanNames.size()==1){ StringautowiredBeanName=autowiredBeanNames.iterator().next();if(beanFactory.containsBean(autowiredBeanName)&&beanFactory.isTypeMatch(autowiredBeanName,field.getType())){ cachedFieldValue=newShortcutDependencyDescriptor(desc,autowiredBeanName,field.getType());}}}this.cachedFieldValue=cachedFieldValue;this.cached=true;}}returnvalue;}}/***方法上有注解构建的处理对象*/privateclassAutowiredMethodElementextendsInjectionMetadata.InjectedElement{ privatefinalbooleanrequired;privatevolatilebooleancached;@NullableprivatevolatileObject[]cachedMethodArguments;publicAutowiredMethodElement(Methodmethod,booleanrequired,@NullablePropertyDescriptorpd){ super(method,pd);this.required=required;}@Overrideprotectedvoidinject(Objectbean,@NullableStringbeanName,@NullablePropertyValuespvs)throwsThrowable{ //检查属性是不会在之前就已经注入过了。如果主如果则不进行二次覆盖if(checkPropertySkipping(pvs)){ return;}Methodmethod=(Method)this.member;Object[]arguments;if(this.cached){ try{ arguments=resolveCachedArguments(beanName);}catch(NoSuchBeanDefinitionExceptionex){ //Unexpectedremovaloftargetbeanforcachedargument->re-resolvearguments=resolveMethodArguments(method,bean,beanName);}}else{ //首次创建的时候进入该方法arguments=resolveMethodArguments(method,bean,beanName);}if(arguments!=null){ try{ //属性如果不为public的话，则设置为可访问ReflectionUtils.makeAccessible(method);//调用方法并传入参数method.invoke(bean,arguments);}catch(InvocationTargetExceptionex){ throwex.getTargetException();}}}@NullableprivateObject[]resolveCachedArguments(@NullableStringbeanName){ Object[]cachedMethodArguments=this.cachedMethodArguments;if(cachedMethodArguments==null){ returnnull;}Object[]arguments=newObject[cachedMethodArguments.length];for(inti=0;i<arguments.length;i++){ arguments[i]=resolvedCachedArgument(beanName,cachedMethodArguments[i]);}returnarguments;}@NullableprivateObject[]resolveMethodArguments(Methodmethod,Objectbean,@NullableStringbeanName){ //获取方法上有几个参数intargumentCount=method.getParameterCount();Object[]arguments=newObject[argumentCount];DependencyDescriptor[]descriptors=newDependencyDescriptor[argumentCount];Set<String>autowiredBeans=newLinkedHashSet<>(argumentCount);Assert.state(beanFactory!=null,"NoBeanFactoryavailable");TypeConvertertypeConverter=beanFactory.getTypeConverter();for(inti=0;i<arguments.length;i++){ //方法参数，从方法参数中取出i构造MethodParameter对象MethodParametermethodParam=newMethodParameter(method,i);DependencyDescriptorcurrDesc=newDependencyDescriptor(methodParam,this.required);currDesc.setContainingClass(bean.getClass());descriptors[i]=currDesc;try{ //获取方法中i参数的内容Objectarg=beanFactory.resolveDependency(currDesc,beanName,autowiredBeans,typeConverter);if(arg==null&

Spring5源码分析之@Configuration注解的详解。希望读者能够耐着性子看完

       Spring5源码中@Configuration注解详解，让你理解无需XML的Bean创建。在Spring 3.0以后，@Configuration注解的出现，允许开发者在运行时动态创建和初始化Bean，无需依赖XML配置。它实际上标记了@Component元注解，被@ComponentScan扫描并纳入Spring容器管理。

       使用@Configuration时，暗堡源码Bean的默认名称与方法名称相同，可通过name属性指定。它不仅自身可以作为受管理的组件，还能通过@Autowired和@Inject注解注入其他Bean。例如，修改Demo，配置类可以作为服务组件被自动扫描。

       @Configuration不仅支持@ComponentScan，还能与@Controller、@Service、@Repository等注解配合，这些注解本质上都有@Component，适合不同场景的管理。此外，@Configuration可以同@Import和@Profile注解组合，实现更灵活的配置导入和环境条件控制。

       在配置类内部嵌套@Configuration，可以利用静态内部类简化@Import的使用。配置类的初始化可以通过@Lazy注解延迟，提供更细致的控制。配置类解析涉及@ConfigurationClassPostProcessor处理器，处理@Configuration类的@Bean、@ComponentScan和环境相关注解。

       最后，@Configuration类的Bean定义信息由ConfigurationClassBeanDefinitionReader处理并注册到Spring容器，整个过程包括解析@Configuration类、扫描相关注解和Bean定义的加载。

       理解@Configuration的解析流程，能帮助你更高效地利用Spring的动态配置能力。如果你对文章内容有所收获，别忘了分享和关注我们的更多内容。

「玩转SpringBoot」配置文件yml的正确打开姿势

       随着SpringBoot的崛起，配置文件迎来了新的变革。在SpringBoot中，配置文件不再使用XML，而是采用了yml格式。yml配置文件以其二维结构化、层次分明和清晰的特性，取代了传统的一维配置方式，成为了新时代的宠儿。

       yml配置文件格式多样，支持List、Map、嵌套List、嵌套Map等结构。每种新事物的流行，总是因为相较于旧事物有更好的特性。yml文件以其二维结构化的优势，层次分明，易于理解和维护，使得配置管理变得更加清晰和直观。

       在SpringBoot中，配置文件yml的内容最终会被存储在Environment中。由于yml文件的二维结构与Environment的一维非结构化存在差异，需要将yml中的嵌套结构转化为简单的关键值对形式，即使用点号（.）表示父子关系，中括号（[]）表示列表索引。这样可以将yml内容平铺化，便于存储和读取。

       读取yml配置文件的方式有两种：直接从Environment中读取和使用@Value注解。直接读取时，需要遵循yml中定义的关键值对形式；使用@Value注解时，可以更优雅地引用配置项，但只支持获取单个值，不支持直接获取列表或映射结构。

       为了更优雅地使用yml配置文件，SpringBoot提供了@ConfigurationProperties注解，将配置文件映射为Java Bean。通过这种方式，可以将复杂的yml配置转换为简单的Java属性，使得配置管理和代码编写更加统一和方便。同时，SpringBoot还提供了@EnableConfigurationProperties注解来引入配置属性类，使得配置类能够被Spring容器管理，从而实现自动注入。

       示例中，通过配置文件定义了一个游泳比赛的得分和奖品的配置，包括得分区间、奖品名称和数量。这些配置信息最终映射为Java Bean，使得开发者能够通过属性注入方式轻松获取和使用这些配置信息。

       SpringBoot框架内部的源码广泛采用这种方式来管理配置，这不仅简化了配置管理，还提升了代码的可读性和可维护性。虽然常规的bean定义注册方式也可以实现相同功能，但SpringBoot提供的方式更加优化和智能化，例如使用@Validated进行验证、@NestedConfigurationProperty注解嵌套字段等，能够提供更好的开发体验。

       总之，配置文件yml的正确打开姿势在于理解其结构、灵活应用读取方式、使用SpringBoot提供的注解进行映射和管理，从而实现高效、优雅的配置管理。通过这种方式，开发者可以充分利用SpringBoot的自动化特性，提升开发效率，同时保持代码的清晰和可维护性。