IP属地：浙江
-
RocketMQ源码解析——Broker部分之Broker启动过程BrokerStartup(2)
@[toc] 前面说了Broker端的部分启动逻辑中的，启动前的准备部分。知道了启动类是BrokerStartup，其中启动前的准备逻辑主要是通...
-
RocketMQ源码解析——Broker部分之Broker启动过程BrokerStartup(1)
@[toc] 从启动脚本到启动类 我们知道RocketMQ的Broker端的启动方式为，进入到RocketMQ的bin目录下，运行对应的mqb...
-
RocketMQ源码解析——存储部分(8)操作消息相关日志的中介DefaultMessageStore
@[toc] 作用 前面介绍了RocketMQ的一些主要的日志文件，CommitLog[https://blog.csdn.net/szhlcy...
-
RocketMQ源码解析——存储部分(7)延迟消息的原理`ScheduleMessageService`
@[toc] 延迟消息描述介绍 RocketMQ的定时消息（延迟队列）是指消息发送到broker后，不会立即被消费，等待特定时间投递给真正的to...
-
RocketMQ源码解析——存储部分(6)RocketMQ主从同步原理相关的HAService和HAConnection
引导 前面介绍了RocketMQ的CommitLog文件相关的类分析CommitLog物理日志相关的CommitLog类[https://bl...
-
RocketMQ源码解析——存储部分(5)IndexFile消息索引日志文件相关的`IndexService`类
IndexFile文件讲解 之前说了RocketMQ的物理日志文件CommitLog和逻辑日志文件ConsumeQueue。现在说的是对应的消...
-
RocketMQ源码解析——存储部分(4)ConsumeQueue逻辑日志文件相关的`ConsumeQueue`类
ConsumeQueue文件讲解 概述 RocketMQ是基于主题topic的订阅模式，消息消费是针对主题进行的。多个Topic文件是共用一个...
-
RocketMQ源码解析——存储部分(3)CommitLog物理日志相关的`CommitLog`类
CommitLog文件讲解 概述 commitlog文件的存储地址：$HOME\store\commitlog${fileName}，每个文件...
-
RocketMQ源码解析——存储部分(2)对`MappedFile`进一步封装的`MappedFileQueue`
MappedFileQueue 前面已经介绍了RocketMQ跟存储交互的底层封装对象mappedFile[https://blog.csdn...