从源码层级深入探索 Spring AMQP 如何在 Spring Boot 中实现 RabbitMQ 集成—

从源码层级深入探索 Spring AMQP 如何在 Spring Boot 中实现 RabbitMQ 集成——消费者如何进行消费

本章节主要从底层源码探索Spring Boot中RabbitMQ如何进行消费，至于RabbitMQ是如何使用如何生产消息，本章不做过多介绍，感兴趣的小伙伴可以参考：从源码层级深入探索 Spring AMQP 如何在 Spring Boot 中实现 RabbitMQ 集成——生产者如何将消息发送到 RabbitMQ Exchange-CSDN博客文章浏览阅读14次。RabbitAutoConfiguration，RabbitAdmin，RabbitTemplate，declareExchanges，convertAndSendhttps://blog.csdn.net/qq_26733517/article/details/144511012?spm=1001.2014.3001.5501

1.Spring Boot中RabbitMQ如何消费

Spring Boot中RabbitMQ的消费使用非常简单，一般使用@RabbitListener或者@RabbitListener+@RabbitHandler，前者使用在方法上，一个消费者只有一个方法，消息来了就是目标方法执行，不管参数类型跟消息类型是否匹配。后者使用在类上，一个消费者包含多个候选处理方法，根据消息的类型进行选择执行。具体使用如下图：

那么为什么使用一个简单的注解@RabbitListener就可以实现消费呢，它的底层是如何运转实现的呢？

2.@RabbitListener注解底层如何实现消费的

其是这还是离不开Spring Boot自动装配引入的RabbitAutoConfiguration配置类，再该类中帮我们引入了一系列配置类，如下：RabbitAutoConfiguration->RabbitAnnotationDrivenConfiguration->EnableRabbitConfiguration（该配置类中某个bean对象存在@EnableRabbit注解）->
RabbitListenerConfigurationSelector（@EnableRabbit注解引入）->RabbitBootstrapConfiguration->
RabbitListenerAnnotationBeanPostProcessor、RabbitListenerEndpointRegistry。消费实现的核心就是这两个配置类，接下来我们进行逐一研究。

1.RabbitListenerAnnotationBeanPostProcessor

该配置类实现了BeanPostProcessor+SmartInitializingSingleton接口，再所有的bean对象初始化前后均会调用BeanPostProcessor接口的前置、后置方法。再所有的bean对象初始化完成后（所有的bean对象已经生成）会调用SmartInitializingSingleton接口的afterSingletonsInstantiated方法。其主要作用是用来解析@RabbitListener，具体如下：

接着分别看一下processAmqpListener和processMultiMethodListeners两个方法，如下图：

从上面两个图中可以看出，二者底层均是调用了processListener方法，该方法具体如下：

接着看一下registerEndpoint方法，如下：

至此整个BeanPostProcessor接口的后置方法就已经完成，其作用就是将解析的@RabbitListener注解的信息封装成一个个AmqpListenerEndpointDescriptor里面封装了AbstractRabbitListenerEndpoint，然后放入到了RabbitListenerEndpointRegistrar.endpointDescriptors属性集合中。

执行完BeanPostProcessor接口后，等ioc容器的所有bean对象初始化完成后会继续调用该方法的afterSingletonsInstantiated方法，具体如下：

接着看一下this.registrar.afterPropertiesSet()方法，具体如下：

接着看一下registerListenerContainer方法，具体如下：

至此SmartInitializingSingleton接口的方法afterSingletonsInstantiated，将每一个@RabbitListener注解的信息封装成了SimpleMessageListenerContainer，然后封装到了RabbitListenerEndpointRegistry中的listenerContainers属性集合中，该类是不是有点眼熟，就是我们开始时说的两个核心类之一，接下来我们便研究一下它。