RocketMQ源码分析——消息的存储

消息的存储是重点也是难点，MQ为了保证消息不丢失作了持久化。为了提高将消息写入文件的速度，MQ采用了顺序写，利用页缓存和内存映射，将全部的消息顺序写入 CommitLog 文件，写满了就建立另外一个文件，文件大小固定为1G。 因消息的消费基于主题，所以MQ为每一个主题建立了多个消费队列，每一个消费队列对应一个 ConsumeQueue 文件，这个文件能够快速找到须要消费的消息在 CommitLog

>>阅读原文<<