一、Rocketmq 文件
消息存储结构.png
- 存储文件
数据、索引相分离的存储结构- CommitLog
- 消息主体
- 元数据
- ConsumeQueue
- $HOME/store/consumequeue/{topic}/{queueId}/{fileName}
基于topic的commitlog索引文件 - 每一个条目共20个字节，分别为8字节的commitlog物理偏移量、4字节的消息长度、8字节tag hashcode
- $HOME/store/consumequeue/{topic}/{queueId}/{fileName}
- IndexFile
- IndexFile的底层存储设计为在文件系统中实现HashMap结构
提供了一种可以通过key或时间区间来查询消息的方法
- IndexFile的底层存储设计为在文件系统中实现HashMap结构
- CommitLog
二、kafka 文件
Kafka的partition对应于RocketMQ的queue
kafka消息存储.png
