........................ 41 六：索引服务 ......................................................................................................................... 42 6.1 索引结构 ............................ ................................. 42 6.2：索引服务 IndexService 线程 ................................................................................. 43 6.3：构建索引服务 ........................................ 针对事物消息的处理，消息的第 20 位开始的八位记录是的消息在逻辑队列 中的 queueoffset， 但是针对事物消息为 preparedType 和 rollbackType 的存储的是事物状态 表的索引偏移量 2.2.2 分发事物消息： 分发消息位置信息到 ConsumeQueue : 事物状态为 preparedType 和 rollbackType 的消息 不会将请求分发到 ConsumeQueue

Consumer topic、queueId、message Commit Log 消费队列服务 （存储消息在CommitLog中的Offset 信息） Offset、Size、TagsCode 消息索引服务 （存储消息Key与消息在CommitLog 中的Offset对应关系） 事务状态服务 （存储每条事务消息的状态） 定时消息服务 （管理需要定时投递的消息） Offset、Key 20 * 2000W 图表 7-3 索引的逻辑结构，类似 HashMap 实现 1. 根据查询的 key 的 hashcode%slotNum 得到具体的槽的位置（slotNum 是一个索引文件里面包含的最大槽的数目， 例如图中所示 slotNum=5000000）。 2. 根据 slotValue（slot 位置对应的值）查找到索引项列表的最后一项（倒序排列，slotValue ue 总是挃吐最新的一个 项目开源主页：https://github.com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key

消费队列存储路径 storePathConsumerQueue=/Users/gitsilence/JavaTools/rocketmq/data/store-a/consumeque e # 消息索引存储路径 storePathIndex=/Users/gitsilence/JavaTools/rocketmq/data/store-a/index # checkpoint 文件存储路径 sto 原文链接：rocketmq 服务部署 storePathConsumerQueue=/Users/gitsilence/JavaTools/rocketmq/data/store-b/consumeque e # 消息索引存储路径 storePathIndex=/Users/gitsilence/JavaTools/rocketmq/data/store-b/index # checkpoint 文件存储路径 sto a/store-a/commitlog # 消费队列存储路径 storePathConsumerQueue=/root/rocketmq/data/store-a/consumequeue # 消息索引存储路径 storePathIndex=/root/rocketmq/data/store-a/index # checkpoint 文件存储路径 storeCheckpoint=/root/roc

逻辑队列：秒级无损弹性扩缩，无数据复制，流量精准调度 消息与流融合索引支持 核心问题 • 消息体小且存储结构面向单 条消息，导致提升吞吐困难 • 在进行状态存储时，无 KV 语义支撑 挑战 • Commitlog 格式存储， 统一复制算法 • 不借助外部依赖，提供 状态存储能力 • 单一数据文件，支持面向流的索引及面向 批的索引 • 批量发，批量存，批量读，吞吐提升十倍 • 统一消息，KV

为什么性能高效，到底运用了什么“厉害”的技术？  RocketMQ 如何实现刷盘（可以类比一下数据库方面的刷盘、redo、undo 日志）？  RocketMQ 文件存储设计理念、基于文件的 Hash 索引是怎么实现的?  定时消息、消息过滤等实现原理。  如何进行网络编程（Netty 实战）？ 下定决心后便开始了我的源码分析 RocketMQ 之旅，大概在 4 个多月的时间中连续 发表了 rocketmq-console 做了兼容，先将传入的 msgId 用 queryMsgById 该命令去查，如果报错，则当成 uniqID(全局 ID)去查，首先全局 id 会存储在消息的属性 中，并会创建 Hash 索引，即可用通过 indexFile 快速定位到该条消息。 rocketmq-console 消息查找消息列表中的 id 又是什么呢？ 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 商业行为。 1.16 RocketMQ 消息轨迹-设计篇 < 152  topic 消息主题。  msgId 消息唯一 ID。  tags 消息 tag。  keys 消息索引 key，根据该 key 可快速检索消息。  storeHost 跟踪类型为 PUB 时为存储该消息的 Broker 服务器 IP；跟踪类型为 subBefore、 subAfter 时为消费者