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

相关文章:

  • 2021-08-07
  • 2021-08-28
  • 2021-12-29
  • 2021-08-09
  • 2021-06-09
  • 2022-02-23
  • 2021-11-01
猜你喜欢
  • 2021-08-04
  • 2022-12-23
  • 2018-03-23
  • 2018-12-10
  • 2021-10-03
  • 2021-05-12
相关资源
相似解决方案