在rocketMq中核心組件有哪些

這篇文章主要介紹在rocketMq中核心組件有哪些，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

    在rocketMq的中核心4組件為namesrv、broker、consumer、producer。

    broker：消息存儲(chǔ)中心，主要用來(lái)存儲(chǔ)消息并通過(guò)namesrv對(duì)外提供服務(wù)。

    namesrv：無(wú)狀態(tài)的注冊(cè)中心，功能用來(lái)保存broker的相關(guān)的元信息并提供給producer在發(fā)送消息過(guò)程中和提供給consumer消費(fèi)消息過(guò)程中查找broker信息。

    producer：消息生產(chǎn)者，通過(guò)namesrv獲取broker的地址并發(fā)送消息。

    consumer：消息消費(fèi)者，通過(guò)namesrv獲取broker的地址并消費(fèi)消息。

rocketMq部署情況介紹

rocketMq部署圖

rocketMq的集群概念細(xì)分

說(shuō)明：

    rocketMq實(shí)際部署圖，每個(gè)組件都可以用集群形式出現(xiàn)。

    producer：通過(guò)producerGroup的名字來(lái)標(biāo)記自己是一個(gè)集群。

    consumer：通過(guò)consumerGroup的名字來(lái)標(biāo)記自己是一個(gè)集群。

    namesrv：相互之間無(wú)通信，通過(guò)部署多臺(tái)機(jī)器來(lái)標(biāo)記自己是一個(gè)偽集群。

    broker：通過(guò)clusterName來(lái)標(biāo)記集群，每個(gè)broker通過(guò)clusterName來(lái)表明cluster層面集群，通過(guò)brokerName來(lái)標(biāo)明broker層面集群，通過(guò)brokerId標(biāo)明主從身份。

rocketMq消息存儲(chǔ)介紹

rocketMq消息存儲(chǔ)

說(shuō)明：

    rocketMq的消息存儲(chǔ)通過(guò)二級(jí)索引來(lái)進(jìn)行，其中實(shí)際消息存儲(chǔ)在Commit Log的邏輯隊(duì)列中（磁盤(pán)文件消息順序?qū)懀?，consume queue保存著每個(gè)消息消費(fèi)隊(duì)列的待消費(fèi)的數(shù)據(jù)并且指向commit Log。

rocketMq線上配置介紹

rocketMq實(shí)際數(shù)據(jù)存儲(chǔ)

說(shuō)明：

    rocketMq線上環(huán)境的真實(shí)存儲(chǔ)，每個(gè)broker的存儲(chǔ)數(shù)據(jù)格式就是類似上圖。

    config目錄

        consumerFilter：保存consumer端的消息過(guò)濾配置，應(yīng)該是等消費(fèi)端配置了過(guò)濾規(guī)則就會(huì)在這個(gè)文件中增加記錄。

        consumerOffset：消費(fèi)進(jìn)度偏移量，以topic@consumerGroup作區(qū)別，0:125的0代表隊(duì)列，125代表消費(fèi)偏移量。

consumerOffset

delayOffset：延遲隊(duì)列消費(fèi)進(jìn)度，其中2代表延遲粒度，2000代表消費(fèi)進(jìn)度。

delayOffset

subscriptionGroup：表示訂閱消費(fèi)的消費(fèi)組。

subscriptionGroup

topic：rocketMq中topic的信息，可以理解topic為業(yè)務(wù)消息分組的粒度，一般一個(gè)topic為一類業(yè)務(wù)的邏輯消息集合。

topic 

commitlog目錄

    rocketMq實(shí)際存儲(chǔ)消息的位置。

consumequeue目錄

    %DLQ%@ConsumeGroupA：消費(fèi)分組的死信隊(duì)列，保存指向commit log的索引。

    %RETRY%@ConsumeGroupA：消費(fèi)分組的充實(shí)隊(duì)列，保存指向commit log的索引。

    SCHEDULE_TOPIC_XXXX：延遲消息隊(duì)列，保存指向commit log的索引。

    TOPICA：topic的消費(fèi)隊(duì)列存儲(chǔ)，保存指向commit log的索引。

以上是“在rocketMq中核心組件有哪些”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！