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

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

开发者学堂课程【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 ,拿到消息之后把消息再去进行处理,所以要把消息的消费服务注册到客户端,把客户端也再去启动起来,以上就是整个消息消费在启动的时候所做的一些事情。

相关文章
|
消息中间件 存储 负载均衡
5 张图带你理解 RocketMQ 消费者启动过程
5 张图带你理解 RocketMQ 消费者启动过程
246 0
5 张图带你理解 RocketMQ 消费者启动过程
|
2月前
|
消息中间件 缓存 Java
RabbitMQ在项目中做什么用?怎么消费消息?具体怎么使用的?
RabbitMQ在项目中做什么用?怎么消费消息?具体怎么使用的?
|
消息中间件 存储 算法
RocketMQ消费者启动流程
问题 消费者启动的时候,去哪拿的消息呢?
153 0
RocketMQ消费者启动流程
|
消息中间件 存储 负载均衡
【消息中间件】默认的RocketMQ消息消费者是如何启动的?(下)
在当下的分布式服务中,消息队列中间件是一个解决服务之间耦合的利器,今天我们来瞧一瞧开源的RocketMQ消息中间件,他的消费端是如何启动的,以及在使用他的过程中有哪些配置。
|
消息中间件 负载均衡 算法
【消息中间件】默认的RocketMQ消息消费者是如何启动的?(上)
在当下的分布式服务中,消息队列中间件是一个解决服务之间耦合的利器,今天我们来瞧一瞧开源的RocketMQ消息中间件,他的消费端是如何启动的,以及在使用他的过程中有哪些配置。
|
消息中间件 存储 前端开发
同步异步调用,并谈谈消息队列mq;RocketMQ发送消息和消费消息测试类
同步调用优点: 时效性强,打电话、直播,很快可以得到结果 同步调用的问题:
536 1
|
消息中间件 Java RocketMQ
消息消费要注意的细节|学习笔记
快速学习消息消费要注意的细节
72 0
消息消费要注意的细节|学习笔记
|
消息中间件 缓存 Java
生产者启动流程|学习笔记
快速学习生产者启动流程
190 0
生产者启动流程|学习笔记
|
消息中间件 RocketMQ 开发者
消息消费方准备工作|学习笔记
快速学习消息消费方准备工作
79 0
消息消费方准备工作|学习笔记
|
消息中间件 RocketMQ 开发者
消息消费初探|学习笔记
快速学习消息消费初探
71 0
消息消费初探|学习笔记

热门文章

最新文章