RocketMQ源碼分析——消息的存儲

消息的存儲是重點也是難點，MQ爲了保證消息不丟失作了持久化。爲了提高將消息寫入文件的速度，MQ採用了順序寫，利用頁緩存和內存映射，將全部的消息順序寫入 CommitLog 文件，寫滿了就建立另外一個文件，文件大小固定爲1G。 因消息的消費基於主題，所以MQ爲每一個主題建立了多個消費隊列，每一個消費隊列對應一個 ConsumeQueue 文件，這個文件能夠快速找到須要消費的消息在 CommitLog

>>阅读原文<<