解析RocketMQ的消息索引文件consumequeue

CommitLog的文件结构 下图展示了CommitLog的文件结构，可以看到，包含了topic、queueId、消息体等核心信息。 同Kafka一样，消息是变长的，顺序写入。 如下图所示： ConsumeQueue的文件结构 ConsumeQueue中并不需要存储消息的内容，而存储的是消息在CommitLog中的offset。也就是说，ConsumeQueue其实是CommitLog的一个索引文

>>阅读原文<<