RocketMQ概念整理

DefaultMessageStore

消息的存储和提取。

相对重要的两个方法：

消息存储

PutMessageResult putMessage(MessageExtBrokerInner msg)

消息获取

GetMessageResult getMessage(final String group, final String topic, final int queueId, final long offset, final int maxMsgNums,
                                   final SubscriptionData subscriptionData)

 

MapedFile

和文件一对一关系

 

MapedFileQueue

管理mapedFile，新建、获取、删除mapedFile将消息写入文件