网站首页 站内搜索

搜索结果

查询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 人评论 次浏览
扫一扫关注最新编程教程