热门标签
更多>
搜索结果
查询Tags标签: MappedFile,共有 3条记录-
全站最硬核 百万字强肝RocketMq源码 火热更新中~(九十五)延时队列
同时,还会将消息原来要发送到的目标Topic和队列信息存储到消息的属性中。相关源码如下所示: org.apache.rocketmq.store.CommitLog#asyncPutMessage public CompletableFuture<PutMessageResult> asyncPutMessage(final MessageExtBrokerInner msg) {// Set the s…
2022/1/31 11:05:00 人评论 次浏览 -
RocketMQ-broker存储机制-ConsumeQueue
前面讲解到对于consumequeue的文件恢复和过期文件删除,和flush的过程这边就不再重点阐述,实际上consumequeue中的存储单元是一个20个字节的数据,前8个字节存储消息在commitlog上的物理点位,接着是4字节的消息size,最后是8字节的tag的hash值。可以看做消息在consumequ…
2021/8/24 6:07:21 人评论 次浏览 -
RocketMQ-broker存储机制-ConsumeQueue
前面讲解到对于consumequeue的文件恢复和过期文件删除,和flush的过程这边就不再重点阐述,实际上consumequeue中的存储单元是一个20个字节的数据,前8个字节存储消息在commitlog上的物理点位,接着是4字节的消息size,最后是8字节的tag的hash值。可以看做消息在consumequ…
2021/8/24 6:07:21 人评论 次浏览