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

ops/2024/12/23 17:19:44/

  本章节主要从底层源码探索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属性集合中,该类是不是有点眼熟,就是我们开始时说的两个核心类之一,接下来我们便研究一下它。

2.RabbitListenerEndpointRegistry

  RabbitListenerEndpointRegistry实现了lifecyle接口,再spring容器刷新的最后一步会调用该类的start方法,处理上面解析的@RabbitListener注解信息,具体如下:

  接着看一下startIfNecessary方法,调用每一个MessageListenerContainer(SimpleMessageListenerContainer)的start方法,如下:

  调用的为AbstractMessageListenerContainer(父类)中的start方法,如下:

  紧接着看一下SimpleMessageListenerContainer中的doStart()方法,如下:

  接着看一下AsyncMessageProcessingConsumer的run() ,如下:

  初始化的过程此处就不再介绍了,主要看一下事件如何处理的,即mainLoop方法,具体如下:

  receiveAndExecute方法底层调用了doReceiveAndExecute方法,具体如下:

  目标方法的执行涉及的东西比较多,包括处理在@RabbitListener注解中使用errorHandler和returnExceptions等属性,比较复杂,本篇暂不做过多介绍。我们看一下Spring Boot的假的‘自动确认’吧,即commitIfNecessary方法,如下:

  所以说Spring Boot提供所谓自动确认并不是真正的自动确认,只是Spring Boot再执行完目标方法后帮我们进行了确认,所以对开发者来说感知上是自动确认。

  如果您希望更深入地学习SpringBoot源码,我强烈推荐您访问以下项目链接:https://gitee.com/chengyadong555/spring-boot.git。在这个项目中,您将发现对SpringBoot源码的逐行分析,作者不仅提供了丰富的注释,还融入了自己独到的理解和见解。


http://www.ppmy.cn/ops/144341.html

相关文章

探究大模型为何因数据增多而效果更佳及其优势

一、数据增多为何能提升大模型效果 数据是大模型的“粮食”,是其学习与成长的基石。数据量的增加对于大模型效果的提升,主要得益于以下几个方面的因素: 模型训练的充分性: 大模型通常拥有数百万甚至数十亿个参数,这些…

数位dp-acwing(数字游戏)

题目:数字游戏 1082. 数字游戏 - AcWing题库 分析: 前缀和思想: dp(m) - dp(n-1) 用树的角度分析。 比最高位小的, 左分支讨论,等于最高位的进入右分支,(同时进入右分支有条件,就是当前位最…

SMMU软件指南SMMU编程之命令队列

安全之安全(security)博客目录导读 SMMU通过内存中的循环命令队列进行控制。例如,当软件更改STE或翻译时,需要在SMMU中失效相关缓存。这可以通过向命令队列发出相应的失效命令来实现。有关命令类型的详细信息,请参见“命令”部分。 在SMMUv3…

游戏关卡分析:荒野大镖客2雪山终战

1、相关剧情 主角约翰一家在农场过着悠闲的日子,突然平静被打破, 女枪手来报信,在某小镇找到了迈卡的消息。 于是激发了约翰的满腔怒气,不顾妻子的反对,坚决要出战, 要彻底歼灭迈卡,为亚瑟…

MVVM、MVC、MVP 的区别

MVVM(Model-View-ViewModel)、MVC(Model-View-Controller)和MVP(Model-View-Presenter)是三种常见的软件架构模式,它们在客户端应用开发中被广泛使用。每种模式都有其特定的设计理念和应用场景&…

几个常见的Jmeter压测问题

🍅 点击文末小卡片,免费获取软件测试全套资料,资料在手,涨薪更快 根据在之前的压测过程碰到的问题,今天稍微总结总结,以后方便自己查找。 一、单台Mac进行压测时候,压测客户端Jmeter启动超过20…

【Elasticsearch03】企业级日志分析系统ELK之Elasticsearch访问与优化

Elasticsearch 访问 Shell 命令 查看 ES 集群状态 访问 ES #查看支持的指令 curl http://127.0.0.1:9200/_cat #查看es集群状态 集群存活少于半数,无法执行 curl http://127.0.0.1:9200/_cat/health url http://127.0.0.1:9200/_cat/health?v #查看集群分健康…

php各个版本的特性以及绕过方式

一.php各个版本的特性 二.绕过正则匹配的常见方式 1.绕过空格 a.空变量$ l$s b.环境变量IFS&#xff08;默认情况下IFS为空格、制表符和换行符&#xff09; l${IFS}s c.重定向符&#xff08;<,>&#xff09; cat < file.txt //把file.txt的内容给cat命令&…