消息中间件RocketMQ原理解析 - 斩秋
IndexService 线程 ................................................................................. 43 6.3:构建索引服务 ........................................................................................... 根据 topic key 时间跨度来查询消息 倒叙遍历所有索引文件 每一个 indexfile 存储了第一个消息和最后一个消息的存储时间,根据传入时间范围来判 断索引是否落在此索引文件 6.3:构建索引服务 分 发 消 息 索 引 服 务 将 消 息 位 置 分 发 到 ConsumeQueue 中 后 , 加 入 IndexService 的 LinkedBlockingQueue0 码力 | 57 页 | 2.39 MB | 1 年前3RocketMQ v3.2.4 开发指南
............................................................................................ 14 6.3 数据存储结构 .......................................................................................... http://blog.donghao.org/2013/03/20/%E4%BF%AE%E5%A4%8Dext4%E6%97%A5%E5%BF%97%EF%BC %88jbd2%EF%BC%89bug/ 6.3 数据存储结构 Producer Consumer topic、queueId、message Commit Log 消费队列服务 (存储消息在CommitLog中的Offset 信息)0 码力 | 52 页 | 1.61 MB | 1 年前3
共 2 条
- 1