一、Namesrv 端
nameSrv 程序入口
org.apache.rocketmq.namesrv.NamesrvStartup
二、Broker 端
broker 程序入口
org.apache.rocketmq.broker.BrokerStartup
三、索引文件
org.apache.rocketmq.store.index.IndexFile
索引文件由索引文件头（header）、槽位（slot）、消息的索引内容三部分组成。
1.1.索引文件头
beginTimestamp 8位 long 类型，索引文件构建第一个索引的消息落在broker 的时间。
endTimestamp 8位 long 类型，索引文件构建最后一个索引的消息落在broker 的时间。
beginPhyOffset 8位 long 类型，索引文件构建第一个索引的消息 commitLog 偏移量。
endPhyOffset 8位 long 类型，索引文件构建最后一个索引的消息 commitLog 偏移量。
hashSlotCount 4 位 int 类型，构建索引占用的槽位数。
indexCount 4 位 int 类型，索引文件中构建的索引个数。
8+8+8+8+4+4=40
1.2.槽位
默认每个索引文件的slot个数是500 万个，每个 slot 是4位的int 类型 数据计算消息的对应消息在 IndexFile 中的偏移量（位于那个槽位上），偏移量的计算公式为 slotPos = Math.abs(keyHash) % hasSlotNum。
hasSlotNum为500w
1.3.消息的索引内容
消息的索引内容长度是20位定长内容的数据
4位int 值， 存储的是key的hash 值
8位long 值，存储的是消息在 commitlog 的物理偏移量 phyOffset
4位int 值，存储了当前消息跟索引文件中第一个消息在 broker 落地的时间差
4位int 值，如果存在hash冲突，存储的是删一个消息的索引地址。
1.4.索引文件的使用
当通过 Key 查找消息时，系统会首先计算 Key 的哈希值，并对 500万（槽位总数）取模，计算出目标槽位的位置。然后，从该槽位读取出最新索引的序号，并顺着链表向前遍历所有冲突的索引条目，通过比对 Key 的哈希值来找到目标消息
四、持久化
刷盘
org.apache.rocketmq.broker.processor.SendMessageProcessor#sendMessage>org.apache.rocketmq.store.MessageStore#putMessage>org.apache.rocketmq.store.DefaultMessageStore#putMessage>org.apache.rocketmq.store.DefaultMessageStore#asyncPutMessage>org.apache.rocketmq.store.CommitLog#asyncPutMessage>org.apache.rocketmq.store.MappedFile#appendMessage(org.apache.rocketmq.store.MessageExtBrokerInner, org.apache.rocketmq.store.AppendMessageCallback, org.apache.rocketmq.store.CommitLog.PutMessageContext)>org.apache.rocketmq.store.CommitLog#submitFlushRequest # 刷盘位置
本文来自博客园，作者：TheLifelongLearner，转载请注明原文链接：https://www.cnblogs.com/The-Lifelong-Learner/p/20296427