深入浅出：消息队列的核心——存储（第二部分）

深入浅出消息队列----【核心之存储（2）】

• 核心之存储（2）
  • • ConsumeQueue 究竟存储了哪些内容？

  • 消费者偏移量

  • 消息索引

本内容仅为文章笔记，归纳了原文中的关键知识点，并记录了个人的理解与见解
原文出处：编程导航-鱼皮【yes哥深入浅出消息队列专栏】

核心之存储（2）

RocketMQ 中包含一个名为 ConsumeQueue 的消费队列，当消息被写入 commitlog 后，意味着生产者已经成功发送了该消息，并且消息已被存储至硬盘中完成持久化操作。此时可以启动一个定时任务，将新写入 commitlog 的消息传输至 ConsumeQueue，从而满足多队列的应用需求。

通过图表信息可知，各类主题的消息均被保存在 commitlog 中，并按照预定时间间隔传输至各自对应主题的 ConsumeQueue 中，消费者可直接从 ConsumeQueue 获取所需消息。