![240](https://cdn2.jianshu.io/assets/default_avatar/4-3397163ecdb3855a0a4139c34a695885.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
幾個(gè)基本概念先說下消息的消費(fèi)有兩種模式:集群模式和廣播模式集群模式煤伟,一條消息只允許被一個(gè)消費(fèi)者消費(fèi)巡李。廣播模式怎披,一條消息會(huì)發(fā)送給所有訂閱該topi...
RocketMQ存儲(chǔ)的文件主要包括Comitlog 文件斩启、 ConsumeQueue 文件米死、 IndexFile 文件铡俐。 CommitLog :...
消息發(fā)送的主要步驟為:驗(yàn)證消息结蟋,查找路由,消息發(fā)送(包含異常機(jī)制處理) 我們以DefaultMQProducer#send為切入口: 以下代碼為...
RocketMQ 支持 3 種消息發(fā)送方式 :同 步(sync )探孝、異步(async)、單向(oneway )誉裆。這些大家應(yīng)該都比較了解了顿颅,我們從...
namesrv,相當(dāng)于RocketMQ的服務(wù)注冊中心(路由發(fā)現(xiàn))足丢,大家通過結(jié)構(gòu)圖就可以看的明白: 我們先從啟動(dòng)類NamesrvStartup說起...
首先粱腻,你得有源碼,這個(gè)網(wǎng)上都可以找到斩跌,各個(gè)版本大差不差绍些;但是由于RocketMQ并入了Apache基金會(huì),所以沒了中文注釋耀鸦,看起來會(huì)有些費(fèi)勁柬批。 ...
結(jié)論先放前面:“進(jìn)程是資源分配的最小單位啸澡,線程是CPU調(diào)度的最小單位” 首先,我們要知道氮帐,CPU是有單核和多核的區(qū)分嗅虏。同一時(shí)間段,一個(gè)核只能運(yùn)行...