当前位置 博文首页 > 龚厂长的博客:RocketMQ-DefaultMQPushConsumer消费消息原理详解
本文基于RocketMQ 4.7.1版本
在上一篇文章介绍了如何创建消费者,本文来分析一下DefaultMQPushConsumer是如何消费消息的。 本文首先介绍DefaultMQPushConsumer的启动流程,之后介绍它是如何从broker拉取消息,最后介绍broker如何根据消费者的请求从消息文件中取出消息并发送。