温馨提示：如果上面在安装过程中发生了错误，大家可以查看{user_home}为用户主 目录。 该目录下会有众多的日志文件，如果一开始对这些文件的含义不了解也没关系，大家可 以通过 ls -l 命令，逐一查看文件大小不为０的文件，从而寻找错误日志，便于快速解决 问题。 RocketMQ 提供了众多的运维命令来查看 RocketMQ 集群的运行状态，在这里我先 简单使用 clusterList 命令来查看集群的状态，用于验证一下集群的状态。 maxOffsetPy 与 maxPhyOffsetPulling 之间的间隔，getMessage 通常用于消息消 费时，即这个间隔可以理解为目前未处理的消息总大小。 代码@2：获取 RocketMQ 消息存储在 PageCache 中的总大小，如果当 RocketMQ 容量超过该阔值，将会将被置换出内存，如果要访问不在 PageCache 中的消 息，则需要从磁盘读取。  StoreUtil RocketMQ 消息能映射到内存中最大值为 40% * (机器物理内存)。 代码@3：设置下次拉起是否从从拉取标记，触发下次从从服务器拉取的条件为：当前 所有可用消息数据(所有 commitlog)文件的大小已经超过了其阔值，默认为物理内存的 40%。 那 GetResult 的 suggestPullingFromSlave 属性在哪里使用呢？ 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。

consume queue 中存储单元是一个 20 字节定长的数据，是顺序写顺序读 （1） commitLogOffset 是指这条消息在 commitLog 文件实际偏移量 （2） size 就是指消息大小 （3） 消息 tag 的哈希值 ConsumeQueue 文件组织： (1) topic queueId 来组织的，比如 TopicA 配了读写队列 0, 1,那么 TopicA 文件地址：${user.home} \store\${commitlog}\${fileName} 一个消息存储单元长度是不定的，顺序写但是随机读 消息存储结构： = 4 //4 个字节代表这个消息的大小 + 4 //四个字节的 MAGICCODE = daa320a7 + 4 // 消息体 BODY CRC 当 broker 重启 recover 时会校验 个字节存放消息体大小值， 后 bodylength 大小 空间存储了消息体内容 + 1 + topicLength //一个字节存放 topic 名称能容大小， 后存放了 topic 的 内容 + 2 + propertiesLength // 2 个 字 节 （ short ） 存 放 属 性 值 大 小 ， 后 存 放 propertiesLength 大小的属性数据

产生了消息重复性问 题。 4.10 Broker 的 Buffer 满了怎么办？ Broker 的 Buffer 通常挃的是 Broker 中一个队列的内存 Buffer 大小，返类 Buffer 通常大小有限，如果 Buffer 满 了以后怎举办？ 下面是 CORBA Notification 规范中处理方式： (1). RejectNewEvents 拒绝新来的消息，吐 Buffer，一旦超过内存 Buffer，可以根据一定的丢弃策略来丢弃消息，如 CORBA Notification 规范中描述。适合能容忍丢弃消息的业务，返种情冴消息的堆积能力主要在亍内存 Buffer 大小，而丏消息 堆积后，性能下降丌会太大，因为内存中数据多少对亍对外提供的访问能力影响有限。 (2). 消息堆积到持丽化存储系统中，例如 DB，KV 存储，文件记彔形式。 当消息丌能在内存 Cache IO，读 IO 的吞吏量直接决定了 消息堆积后的访问能力。 评估消息堆积能力主要有以下四点： (1). 消息能堆积多少条，多少字节？即消息的堆积容量。 (2). 消息堆积后，収消息的吞吏量大小，是否会叐堆积影响？ 项目开源主页：https://github.com/alibaba/RocketMQ 9 (3). 消息堆积后，正常消费的 Consumer 是否会叐影响？ (4)

int # abort 存储路径 abortFile=/Users/gitsilence/JavaTools/rocketmq/data/store-a/abort # commitLog每个文件的大小 默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue每个文件默认存30w条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 int # abort 存储路径 abortFile=/Users/gitsilence/JavaTools/rocketmq/data/store-b/abort # commitLog每个文件的大小 默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue每个文件默认存30w条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 q/data/store-a/checkpoint # abort 存储路径 abortFile=/root/rocketmq/data/store-a/abort # commitLog每个文件的大小 默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue每个文件默认存30w条，根据业务情况调整 mapedFileSizeConsumeQueue=300000