首页 > TAG信息列表 > DefaultMessageStore
RocketMQ 源码分析 —— Message 拉取与消费（上）
摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎转载，保留摘要，谢谢！1、概述2、ConsumeQueue 结构3、ConsumeQueue 存储4、Broker 提供[拉取消息]接口5、Broker 提供[更新消费进度]接口6、Broker 提供[发回消息]接口7、结尾阅读源码consumeQueue 和 indexFile 文件
broker 把消息写入 commitLog 后，还需要把消息的索引写入 consumeQueue 文件 和 indexFile 文件 // org.apache.rocketmq.store.DefaultMessageStore.ReputMessageService@Overridepublic void run() { DefaultMessageStore.log.info(this.getServiceName() + " service starte消息队列（五） ---RocketMQ-消息存储3
问题： consumeQueue 如何工作 刷盘机制如何工作 概述 该节我们将学习 consumeQueue 如何工作，先来看一下消息发送的大概过程。 而为什么需要 consumeQueue 的存在呢？我们只有一个 commitLog 文件，那么假如需要查找某个主题下的消息，那么我们不得不遍历整个commmitLog 来完成查询，cons