上篇文章我们分析完RocketMQ发送消息的原理,得到结果客户端会通过RPC组件向Broker进行通信
上篇文章主要介绍消息中间件并以RocketMQ架构展开描述其核心组件以及MQ运行流程
在队列的基础上,加入生产者与消费者模型,使用队列作为载体就能够组成简单的消息队列,在队列中“运输”的数据被称为消息
org/apache/rocketmq/proxy/processor/MessagingProcessor.java
本文主要研究一下rocketmq5的PushConsumer与SimpleConsumer拉取消息的区别