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将消息写入文件