您好,登錄后才能下訂單哦!
這篇文章將為大家詳細(xì)講解有關(guān)RocketMQ中Client端架構(gòu)是怎么樣的,小編覺得挺實(shí)用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
RocketMQ的producer/consumer相關(guān)功能都由client包提供,client包的底層功能提供了對網(wǎng)絡(luò)通信、topic路由信息獲取等能力的封裝。client核心類如下圖:
NettyRemotingClient類封裝了基礎(chǔ)的網(wǎng)絡(luò)通訊能力,向外提供了三種不同的通訊方式:
同步調(diào)用invokeSync,調(diào)用方會阻塞一直等到響應(yīng)返回或超時
異步調(diào)用invokeAsync,調(diào)用方立即返回,當(dāng)獲得響應(yīng)結(jié)果后在一個線程池中調(diào)用callback
單向調(diào)用invokeOneway,發(fā)送請求后不關(guān)心response
MQClientAPIImpl類在RemotingClient的基礎(chǔ)上,封裝了rocketmq client端所有用到的request command組裝以及reponse解析邏輯。
MQClientInstance是整個rocketmq client端的中樞,對于同一個client(clientid相同)只維護(hù)一個MQClientInstance實(shí)例。它了維護(hù)該client上啟動的所有producer、consumer的信息,以及涉及到的topic的路由信息。
MQClientInstance會啟動后臺任務(wù),周期性地執(zhí)行從nameserver更新topic的路由信息,向broker發(fā)送心跳,剔除失聯(lián)的broker,持久化消費(fèi)者offset等工作。
MQClientInstance還會啟動PullMessageService,用于調(diào)用consumer從broker上拉取message消費(fèi);啟動RebalanceService,周期性重新分配topic下的message queue和consumer之間的訂閱關(guān)系。
關(guān)于“RocketMQ中Client端架構(gòu)是怎么樣的”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,使各位可以學(xué)到更多知識,如果覺得文章不錯,請把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。