RocketMQ架构原理解析(一):整体架构 RocketMQ架构原理解析(二):消息存储(CommitLog) RocketMQ架构原理解析(三):消息索引(ConsumeQueue & IndexFile) RocketMQ架构原理解析(四):消息生产端(Producer) 一、概述 ...
RocketMQ架构原理解析 一 :整体架构 RocketMQ架构原理解析 二 :消息存储 CommitLog RocketMQ架构原理解析 三 :消息索引 ConsumeQueue amp IndexFile RocketMQ架构原理解析 四 :消息生产端 Producer 一 概述 索引 一种数据结构,帮助我们快速定位 查询数据 前文我们梳理了消息在Commit Log文件的存储过程,讨论了消 ...
2021-12-10 14:56 4 1638 推荐指数:
RocketMQ架构原理解析(一):整体架构 RocketMQ架构原理解析(二):消息存储(CommitLog) RocketMQ架构原理解析(三):消息索引(ConsumeQueue & IndexFile) RocketMQ架构原理解析(四):消息生产端(Producer) 一、概述 ...
RocketMQ架构原理解析(一):整体架构 RocketMQ架构原理解析(二):消息存储(CommitLog) RocketMQ架构原理解析(三):消息索引(ConsumeQueue & IndexFile) RocketMQ架构原理解析(四):消息生产端(Producer) 一、概述 ...
RocketMQ架构原理解析(一):整体架构 RocketMQ架构原理解析(二):消息存储(CommitLog) RocketMQ架构原理解析(三):消息索引(ConsumeQueue & IndexFile) RocketMQ架构原理解析(四):消息生产端(Producer) 一、概述 ...
如果一个broker正常退出,是会删除abort文件的。那么启动broker的时候发现abort文件还存在,那么说明上次是异常终止,会进入到commit-log的recoverAbnormally逻辑 ...
三: indexFile 除了通过通常的指定Topic进行消息消费外,RocketMQ还提供了根据key进行消息查询的功能。 该查询是通过store目录中的index子目录中的indexFile进行索引实现的快速查询。 这个indexFile中的索引数据是在如果包含了key的消息被生产者 ...
目录 1.MappedFile类属性说明 1.1.MappedFile类属性如下 1.2.MappedFile构造器说明 2.MappedF ...
CommitLog消息内容原文的存储文件,同Kafka一样,消息是变长的,顺序写入,生成规则:每个文件的默认1G =1024 * 1024 * 1024,commitlog的文件名fileName,名字长度为20位,左边补零,剩余为起始偏移量;比如00000000000000000000代表 ...
CommitLog 消息内容原文的存储文件,同Kafka一样,消息是变长的,顺序写入 生成规则: 每个文件的默认1G =1024 * 1024 * 1024,commitlog的文件名fileName,名字长度为20位,左边补零,剩余为起始偏移量 ...