消息消费启动流程|学习笔记

简介: 快速学习消息消费启动流程

开发者学堂课程【RocketMQ 知识精讲与项目实战(第三阶段)消息消费启动流程】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/704/detail/12494


消息消费启动流程


消息消费启动流程

消费者的一个启动流程,在启动的时候它都做了哪些事情,以推模式作为讲解的例子,推模式应该找哪个类?它应该找的是DefaultMQPushConsumer这个类,启动要找 start 方法,在 start 方法当中启动逻辑是封装到了IMPL这么一个类当中,在这个类里面都做了哪些事?

image.png

首先它去检查一下消息消费的一个合法性,去做了一个消息消费的合法性的一个检查,检查一下这些必要的信息。然后去做了一个构建主题的订阅信息,通过这么一个方法去构建了订阅的主题。紧接着它就是构建了客户端与服务端进行交互的一个重要的类,通过这个类可以去请求 RocketMQ的服务端。紧接着下边构建了负载均衡实现的服务,把负载均衡实现的服务进行了一个对应的构建,这里设定了这个负载均衡的一个策略等等。然后下边是基于当前消息的模式去确定一下消息的进度存储的位置,如果是广播模式,那么这个消息的消费的进度存储到本地,如果是集群模式,它把这个消息的一个消费进度存储到远端,整个的都设置完了之后,紧接着创建了消息消费服务,把消费服务创建出来了。如果顺序消息,那么它就创建了consumer message orderly  service,如果是并发去消费就不存在顺序性,那么它就是consumer concurrently service,就会把消息服务去启动起来,启动起来之后消息的服务如果要去获得这个消息,就要通过 MQ 客户端去请求 boolean ,拿到消息之后把消息再去进行处理,所以要把消息的消费服务注册到客户端,把客户端也再去启动起来,以上就是整个消息消费在启动的时候所做的一些事情。

相关文章
|
4月前
|
JSON 算法 安全
淘宝商品详情API接口系列,json数据返回
淘宝开放平台提供了多种API接口用于获取商品详情信息,主要通过 淘宝开放平台(Taobao Open Platform, TOP) 的 taobao.tbk.item.info.get(淘宝客商品详情)或 taobao.item.get(标准商品API)等接口实现。以下是关键信息及JSON返回示例:
|
6月前
|
机器学习/深度学习 传感器 编解码
人机融合智能 | 脑机接口和脑机融合
脑机接口是一种在大脑与外部设备间建立直接信息交流的技术,能实现意念控制设备或对大脑进行调控。脑机融合则进一步将生物脑与机器智能结合,推动人机协同交互。本文介绍了脑机接口的技术框架、信号采集与解码方法,并探讨其在医疗康复、人机交互等领域的应用前景及挑战。
354 0
|
存储 搜索推荐 定位技术
布谷直播系统源码开发搭建更新计划-山东布谷科技
山东布谷科技不断更新迭代布谷直播app,根据当前市场需求不断研究新功能更新迭代直播软件计划,以保证布谷直播app是当前直播运营市场的第一选择!
Vue3卡片(Card)
这是一个基于Vue3的卡片组件库,提供多样化的卡片展示效果,包括不同尺寸、加载状态及自定义样式等。支持设置宽度、标题、边框等属性,并可通过`loading`参数显示加载占位符。
1067 1
Vue3卡片(Card)
|
数据采集 数据安全/隐私保护
下载m3u8视频,以及整合
下载m3u8视频,以及整合
|
关系型数据库 MySQL 数据库
MySQL8报错:Public Key Retrieval is not allowed
MySQL8报错:Public Key Retrieval is not allowed
7120 1
|
算法 前端开发 API
Gradio库的安装和使用教程
Gradio库的安装和使用教程
1995 0
|
消息中间件 Kafka
Cannot set the value of read-only property ‘additionalSourceDirs‘ for task ‘:jacocoRootReport‘ of
这个问题是gradle的build版本问题,我是在build kafka的老版本时报的错,这个问题我查了一遍网上的内容,发现很多博客忽略了IDEA settings关于gradle的build的一个配置。
741 0
Cannot set the value of read-only property ‘additionalSourceDirs‘ for task ‘:jacocoRootReport‘ of
|
网络架构
Cisco Packet Tracker教程:主机直接互联、DHCP配置互联
利用Cisco Packet Tracer实现了主机直接互联通信,通过路由器建立DHCP池分配给主机IP进行通信。
1669 1
Cisco Packet Tracker教程:主机直接互联、DHCP配置互联
|
机器学习/深度学习 数据采集 算法
数据挖掘实战:个人信贷违约预测(上)
大家好,我是东哥。本次分享一个数据挖掘实战项目:个人信贷违约预测,此项目对于想要学习信贷风控模型的同学非常有帮助,数据和源码在文末。
1082 0
数据挖掘实战:个人信贷违约预测(上)