store-a/consumeque e # 消息索引存储路径 storePathIndex=/Users/gitsilence/JavaTools/rocketmq/data/store-a/index # checkpoint 文件存储路径 storeCheckpoint=/Users/gitsilence/JavaTools/rocketmq/data/store-a/checkpoint # store-b/consumeque e # 消息索引存储路径 storePathIndex=/Users/gitsilence/JavaTools/rocketmq/data/store-b/index # checkpoint 文件存储路径 storeCheckpoint=/Users/gitsilence/JavaTools/rocketmq/data/store-b/checkpoint # e=/root/rocketmq/data/store-a/consumequeue # 消息索引存储路径 storePathIndex=/root/rocketmq/data/store-a/index # checkpoint 文件存储路径 storeCheckpoint=/root/rocketmq/data/store-a/checkpoint # abort 存储路径 abortFile

Offset Timestamp Next Index Offset 8 Byte 4 Byte 4 Byte Key Hash 4 Byte 0 1 3 2 ... ... ... ... ... ... ... ... Slot Table Index Linked List 500W Header Slot Table Index Linked List 40B 4 * com/alibaba/RocketMQ 37 storePathConsumeQueue $HOME/store/consumequeue 消费队列存储路径 storePathIndex $HOME/store/index 消息索引存储路径 storeCheckpoint $HOME/store/checkpoint checkpoint 文件存储路径 abortFile $HOME/store/abort

ConsumerOffsetManager "offsetTable":{ "TopicTest@consumer-g1":{0:0,1:21,2:0}, ... } index ⾼高效存储 Disk （commitLog/consumeQueue/indexFile） NIO MappedByteBuffer 堆外内存 零拷⻉贝 mmap(内存映射) store/

PageCache的毛刺内核源码分析 Entity Inode i_mapping i_data address_space radix_tree_root nrpages writeback_index inode(host) tree_lock radix_tree_root gfp_mask rnode count=2 tags tree_node count=2 tags

PageCache的毛刺内核源码分析 Entity Inode i_mapping i_data address_space radix_tree_root nrpages writeback_index inode(host) tree_lock radix_tree_root gfp_mask rnode count=2 tags tree_node count=2 tags

类型数据 计算消息的对应的 slotPos=Math.abs(keyHash)%hashSlotNum 消息在 IndexFile 中的偏移量 absSlotPos = IndexHeader.INDEX_HEADER_SIZE + slotPos * HASH_SLOT_SIZE Slot 存储的值为消息个数索引 消息的索引内容是 20 位定长内容的数据 8B 8B 8B 8B