RocketMQ中Broker的启动源码分析（一）
在RocketMQ中，使用BrokerStartup作为启动类，相较于NameServer的启动，Broker作为RocketMQ的核心可复杂得多 【RocketMQ中NameServer的启动源码分析】 主函数作为其启动的入口 ...
原文：RocketMQ中Broker的刷盘源码分析
上一篇博客的最后简单提了下CommitLog的刷盘 RocketMQ中Broker的消息存储源码分析 这篇博客和上一篇有很大的联系 Broker的CommitLog刷盘会启动一个线程，不停地将缓冲区的内容写入磁盘 CommitLog文件 中，主要分为异步刷盘和同步刷盘 异步刷盘又可以分为两种方式： 缓存到mappedByteBuffer gt 写入磁盘 包括同步刷盘 缓存到writeBuffer ...
2019-08-07 00:35 0 376 推荐指数：
相关推荐
RocketMQ中Broker的消息存储源码分析
Broker和前面分析过的NameServer类似，需要在Pipeline责任链上通过NettyServerHandler来处理消息 【RocketMQ中NameServer的启动源码分析】 实际上就通过前面提到的SendMessageProcessor ...
rocketmq源码分析2-broker的消息接收
broker消息接收，假设接收的是一个普通消息(即没有事务)，此处分析也只分析master上动作逻辑，不涉及ha。 1. 如何找到消息接收处理入口 可以通过broker的监听端口10911顺藤摸瓜式的找到 NettyClientConfig.setListenPort--> ...
rocketmq刷盘过程
本文基于rocketmq4.0版本，结合CommitlLog的刷盘过程，对消息队列的刷盘过程源码进行分析，进而对RocketMQ的刷盘原理和过程进行了解。 rocketmq 4.0版本中刷盘类型和以前的版本一样有两种： public enum ...
RocketMq刷盘机制
RocketMq刷盘机制 handleDiskFlush ①同步刷盘使用GroupCommitService ②异步刷盘 且开启了transientStorePoolEnable且不是从服务器，使用CommitLogService 否则使用FlushCommitLogService刷盘 ...
RocketMQ源码分析 broker启动，commitlog、consumequeue、indexfile、MappedFileQueue、MappedFile之间的关系以及位置说明
目录 1.MappedFile类属性说明 1.1.MappedFile类属性如下 1.2.MappedFile构造器说明 2.MappedF ...
RocketMQ中Producer消息的发送源码分析
上篇博客介绍过Producer的启动，这里涉及到相关内容就不再累赘了 【RocketMQ中Producer的启动源码分析】 Producer发送消息，首先需要生成Message实例： 其中properties中存放需要配置的属性，由MessageConst规定其key ...
RocketMQ中Producer的启动源码分析
RocketMQ中通过DefaultMQProducer创建Producer DefaultMQProducer定义如下： 其中defaultMQProducerImpl成员是Producer的具体实现，其余的一些成员是对一些参数的设置：createTopicKey：是一个 ...