幾個基本概念先說下消息的消費有兩種模式:集群模式和廣播模式集群模式,一條消息只允許被一個消費者消費。廣播模式,一條消息會發(fā)送給所有訂閱該topic的用戶消費。 RocketM...
幾個基本概念先說下消息的消費有兩種模式:集群模式和廣播模式集群模式,一條消息只允許被一個消費者消費。廣播模式,一條消息會發(fā)送給所有訂閱該topic的用戶消費。 RocketM...
RocketMQ存儲的文件主要包括Comitlog 文件、 ConsumeQueue 文件、 IndexFile 文件。 CommitLog :消息存儲文件,所有消息主題的消...
消息發(fā)送的主要步驟為:驗證消息,查找路由,消息發(fā)送(包含異常機制處理) 我們以DefaultMQProducer#send為切入口: 以下代碼為驗證消息 經(jīng)過一些嵌套,我們發(fā)...
RocketMQ 支持 3 種消息發(fā)送方式 :同 步(sync )、異步(async)、單向(oneway )。這些大家應(yīng)該都比較了解了,我們從生產(chǎn)者的啟動開始聊起。Defa...
namesrv,相當于RocketMQ的服務(wù)注冊中心(路由發(fā)現(xiàn)),大家通過結(jié)構(gòu)圖就可以看的明白: 我們先從啟動類NamesrvStartup說起,在其中的main0方法里,它...
首先,你得有源碼,這個網(wǎng)上都可以找到,各個版本大差不差;但是由于RocketMQ并入了Apache基金會,所以沒了中文注釋,看起來會有些費勁。 我這邊用的是RocketMQ4...
結(jié)論先放前面:“進程是資源分配的最小單位,線程是CPU調(diào)度的最小單位” 首先,我們要知道,CPU是有單核和多核的區(qū)分。同一時間段,一個核只能運行一個進程。但是我們平時使用的過...