• 2024-04-10RocketMQ---消息存储
    概述RocketMQ的消息存储在本地文件系统中,默认路径:$home/store下;abort 该文件在broker启动后自动创建,正常关闭broker,该文件会消失;若在未启动broker的情况下,发现该文件存在,说明broker的关闭是非正常关闭;checkpoint存储commit
  • 2023-01-08RocketMQ存储篇四:刷盘
    概览RocketMQ主从同步指的是消息发送到master的内存中,并且等到同步到slaver的内存才返回;刷盘则是将内存中的消息写入磁盘,同样分为同步刷盘和异步刷盘。同步刷盘指一条
  • 2023-01-04RocketMQ存储篇二:相关概念介绍(MappedFile)
    这篇文章介绍在RocketMQ存储中使用到的一些概念,包括和零拷贝相关的MappedFile看下MappedFile的类图结构,DefaultMappedFile实现了MappedFile接口,同时继承了ReferenceReso
  • 2023-01-01RocketMQ存储篇一:概览
    这篇文章记录RocketMQ大致的存储流程,源码为5.0.1-SNAPSHOT入口从Broker模块的SendMessageProcessor开始@SendMessageProcessor#sendMessage()5.0中将putmessage中的