当前位置 博文首页 > 龚厂长的博客:RocketMQ-DefaultMQPushConsumer消费消息原理详解

    龚厂长的博客:RocketMQ-DefaultMQPushConsumer消费消息原理详解

    作者:[db:作者] 时间:2021-07-26 20:55

    本文基于RocketMQ 4.7.1版本

    在上一篇文章介绍了如何创建消费者,本文来分析一下DefaultMQPushConsumer是如何消费消息的。
    本文首先介绍DefaultMQPushConsumer的启动流程,之后介绍它是如何从broker拉取消息,最后介绍broker如何根据消费者的请求从消息文件中取出消息并发送。

    文章目录

    • 一、启动DefaultMQPushConsumer
      • 1、检查配置
      • 2、PullAPIWrapper
      • 3、ConsumeMessageConcurrentlyService
    • 二、消费消息
    • 三、broker处理消息拉取请求
    cs