基于Apache APISIX 与RocketMQ 构建云原生一体化架构
消息体小且存储结构面向单 条消息,导致提升吞吐困难 • 在进行状态存储时,无 KV 语义支撑 挑战 • Commitlog 格式存储, 统一复制算法 • 不借助外部依赖,提供 状态存储能力 • 单一数据文件,支持面向流的索引及面向 批的索引 • 批量发,批量存,批量读,吞吐提升十倍 • 统一消息,KV 语义,统一 API,提供 状态存储能力 • 流表二象性支持 W r i t e h e0 码力 | 22 页 | 2.26 MB | 1 年前3RocketMQ v3.2.4 开发指南
值(每个索引项保存了 key 的 hash 值),过滤掉 hash 值丌相等的项。第二种,hash 值相等但 key 丌等, 出亍性能的考虑冲突的检测放到客户端处理(key 的原始值是存储在消息文件中的,避免对数据文件的解析), 客户端比较一次消息体的 key 是否相同。 5. 存储;为了节省空间索引项中存储的时间是时间差值(存储时间-开始时间,开始时间存储在索引文件头中), 整个索引文件是定长的,结构也是固定的。索引文件存储结构参见图0 码力 | 52 页 | 1.61 MB | 1 年前3
共 2 条
- 1