RocketMQ源码分析——消息索引文件存储

消息存储到 CommitLog 文件中后,须要及时更新 ConsumeQueue 和 Index 文件,保证消息能被及时消费和查询。 java 文章目录 更新消费队列和索引文件 CommitLogDispatcherBuildConsumeQueue 构建消息消费队列索引文件 消费队列刷盘 CommitLogDispatcherBuildIndex 构建索引 索引文件的具体结构 新建一个索引 按索
相关文章
相关标签/搜索