RocketMQ概念整理

消息的存储和提取。

相对重要的两个方法：

消息存储

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，新建、获取、删除mapedFile将消息写入文件