IP屬地：浙江
-
RocketMQ源碼解析——Broker部分之Broker啟動過程BrokerStartup(2)
@[toc]?前面說了Broker端的部分啟動邏輯中的，啟動前的準(zhǔn)備部分。知道了啟動類是BrokerStartup，其中啟動前的準(zhǔn)備邏輯主要是通...
-
RocketMQ源碼解析——Broker部分之Broker啟動過程BrokerStartup(1)
@[toc] 從啟動腳本到啟動類 ?我們知道RocketMQ的Broker端的啟動方式為，進(jìn)入到RocketMQ的bin目錄下，運(yùn)行對應(yīng)的mqb...
-
RocketMQ源碼解析——存儲部分(8)操作消息相關(guān)日志的中介DefaultMessageStore
@[toc] 作用 前面介紹了RocketMQ的一些主要的日志文件，CommitLog[https://blog.csdn.net/szhlcy...
-
RocketMQ源碼解析——存儲部分(7)延遲消息的原理`ScheduleMessageService`
@[toc] 延遲消息描述介紹 RocketMQ的定時(shí)消息（延遲隊(duì)列）是指消息發(fā)送到broker后，不會立即被消費(fèi)，等待特定時(shí)間投遞給真正的to...
-
RocketMQ源碼解析——存儲部分(6)RocketMQ主從同步原理相關(guān)的HAService和HAConnection
引導(dǎo) ?前面介紹了RocketMQ的CommitLog文件相關(guān)的類分析CommitLog物理日志相關(guān)的CommitLog類[https://bl...
-
RocketMQ源碼解析——存儲部分(5)IndexFile消息索引日志文件相關(guān)的`IndexService`類
IndexFile文件講解 ?之前說了RocketMQ的物理日志文件CommitLog和邏輯日志文件ConsumeQueue?，F(xiàn)在說的是對應(yīng)的消...
-
RocketMQ源碼解析——存儲部分(4)ConsumeQueue邏輯日志文件相關(guān)的`ConsumeQueue`類
ConsumeQueue文件講解 概述 ?RocketMQ是基于主題topic的訂閱模式，消息消費(fèi)是針對主題進(jìn)行的。多個(gè)Topic文件是共用一個(gè)...
-
RocketMQ源碼解析——存儲部分(3)CommitLog物理日志相關(guān)的`CommitLog`類
CommitLog文件講解 概述 ?commitlog文件的存儲地址：$HOME\store\commitlog${fileName}，每個(gè)文件...
-
RocketMQ源碼解析——存儲部分(2)對`MappedFile`進(jìn)一步封裝的`MappedFileQueue`
MappedFileQueue ?前面已經(jīng)介紹了RocketMQ跟存儲交互的底層封裝對象mappedFile[https://blog.csdn...