RocketMQ存儲

RocketMQ中的消息數據存儲，采用了零拷貝技術（使用 mmap + write 方式），文件系統采用 Linux Ext4 文件系統進行存儲。

消息數據的存儲

在RocketMQ中，消息數據是保存在磁盤文件中，為了保證寫入的性能，RocketMQ盡可能保證順序寫入，順序寫入的效率比隨機寫入的效率高很多。

RocketMQ消息的存儲是由ConsumeQueue和CommitLog配合完成的，CommitLog是真正存儲數據的文件，ConsumeQueue是索引文件，存儲數據指向到物理文件的配置。

如上圖所示：

消息主體以及元數據都存儲在CommitLog當中
Consume Queue相當于kafka中的partition，是一個邏輯隊列，存儲了這個Queue在CommiLog中的起始offset，log大小和MessageTag的hashCode。
每次讀取消息隊列先讀取consumerQueue,然后再通過consumerQueue去commitLog中拿到消息主體。

文件位置：

?

總結

以上是生活随笔為你收集整理的RocketMQ的存储之消息的存储分析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。