RocketMQ源碼解析Broker#消息存儲ConsumeQueue

1.首先介紹下RocketMq消息存儲的目錄結構json Broker在收到消息後,經過MessageStore將消息存儲到commitLog中,可是consumer在消費消息的時候是按照topic+queue的維度來拉取消息的。爲了方便讀取,MessageStore將CommitLog中消息的offset按照topic+queueId劃分後,存儲到不一樣的文件中,這就是ConsumeQueue數
相關文章
相關標籤/搜索