首页 > TAG信息列表 > indexFile

根据消息key查询功能的实现: indexFile

三: indexFile 除了通过通常的指定Topic进行消息消费外,RocketMQ还提供了根据key进行消息查询的功能。 该查询是通过store目录中的index子目录中的indexFile进行索引实现的快速查询。 这个indexFile中的索引数据是在如果包含了key的消息被生产者发送到Broker时写入的。 如果消息中

rocketMq-消息存储-buildIndex

前言 上篇文章介绍了,在 dispatcherList 有两个 dispatcher ,其中一个就是buildIndex ,这个顾名思义就是建立索引,方便研发人员通过关键字查询消息,判断消息内容是否正确或者丢失,这个也是比kafka 的优势点。 原理 buildIndex 整体设计采用hashMap 数据结构设计的,即数据和链表,一

RocketMQ文件存储体系介绍

文章目录 1. RocketMQ的文件体系介绍2. CommitLog,ConsumeQueue, IndexFile 介绍2.1 CommitLog2.2 ConsumeQueue2.3 IndexFile2.4 存储方式 3. 页缓存与内存映射3.1 页缓存pageCache3.2 内存映射 1. RocketMQ的文件体系介绍  RocketMQ的消息存储是RocketMQ中最为复杂

RocketMQ源码解析之broker文件清理

原创不易,转载请注明出处 文章目录 1. broker 清理文件介绍1.1 哪些文件需要清理1.2 RocketMQ文件清理的机制 2.源码解析2.1 清理commitlog2.2 ConsumeQueue 与indexFile 清理 总结 1. broker 清理文件介绍 1.1 哪些文件需要清理 首先我们需要介绍下在RocketMQ中哪些