rocketmq-send-store


文档摘要

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


发布者: 作者: 转发
评论区 (0)
U