该文所涉及的 RocketMQ 源码版本为 4.9.3。 RocketMQ 消息发送存储流程 第一步:检查消息存储状态 org.apache.rocketmq.store.DefaultMessageStore#checkStoreStatus 1、检查 broker 是否可用 2、检查 broker 的角色 3、检查 messageStore 是否可写 4、检查 pageCache 第二步:检查消息 org.apache.rocketmq.store.