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