RocketMq之消费者消费流程

文章预览

探索RocketMq消息中间件的奥秘：深入源码剖析消费者消费流程与存储架构。本文从RocketMq消息存储的精细设计出发，揭秘CommitLog与ConsumerQueue如何携手实现高效存储与快速消费，旨在为读者搭建起通往RocketMq核心原理的桥梁，激发进一步探索的兴趣。 我的疑问 在看源码之前，我对RocketMq中间件的实现方式有以下几个疑问： 消息的存储架构是如何的？ 消费者是怎么拉取消息的？ RocketMq是怎么做负载均衡策略的？ 源码学习 ▐    RocketMq存储架构 RocketMq存储架构中的实现通过两个核心的文件，分别是 CommitLog 文件和 ConsumerQueue 文件。CommitLog存储消息主体，消费者发送的消息会顺序的写入到CommitLog文件中，通过顺序写保障了写入的效率。 为了提高消费者消费消息的速度，引入了ConsumerQueue文件，文件位置位于$HOME/store/consumequeue/{topic}/{queueId}/{fileName}，每条记 ………………………………