发表评论取消回复
相关阅读
相关 RocketMQ源码:broker存储文件组织和内存映射
1. 存储设计 `RocketMQ`存储文件主要包括:`CommitLog`文件、`ConsumerQueue`文件、`Index`文件 `CommitLog`文
相关 RocketMQ源码:broker文件清理
1. broker 清理文件介绍 1.1 哪些文件需要清理 首先我们需要介绍下在RocketMQ中哪些文件需要清理,其实可以想一想,在RocketMQ中哪些文件是一
相关 RocketMQ源码13- broker 文件刷盘机制
`RocketMQ`的存储与读写是基于`JDK NIO`的内存映射机制(`MappedByteBuffer`)的,消息存储时首先将消息追加到内存中,再根据配置的刷盘策略在不同时
相关 RocketMQ源码:broker 文件刷盘机制
`RocketMQ`的存储与读写是基于`JDK NIO`的内存映射机制(`MappedByteBuffer`)的,消息存储时首先将消息追加到内存中,再根据配置的刷盘策略在不同时
相关 RocketMQ 源码分析——Broker
文章目录 前言 Broker 启动流程 Broker 消息存储设计 存储文件设计 消息存储结构 Broker 消息写入流
相关 RocketMQ源码9- broker 启动流程
前面我们已经分析完了`NameServer`和`producer`,从本文开始,我们将分析`Broker`。 1. 启动入口 `broker`的启动类为`org.apa
相关 RocketMQ源码9- broker 启动流程
1. 启动入口 `broker`的启动类为`org.apache.rocketmq.broker.BrokerStartup`,代码如下: public cla
相关 RocketMQ源码解析之broker(FastFailure)
> 原创不易,转载请注明出处 文章目录 1.FastFailure 1.1 FastFailure是啥
相关 RocketMQ源码解析之broker(pullMessage)
> 原创不易,转载请注明出处 文章目录 前言 1.broker处理消费请求的流程 2.源码解析
还没有评论,来说两句吧...