溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

RocketMQ集群生產(chǎn)環(huán)境master節(jié)點(diǎn)節(jié)點(diǎn)優(yōu)雅下線

發(fā)布時(shí)間：2020-07-17 20:20:00 來源：網(wǎng)絡(luò) 閱讀：838 作者：sqtce 欄目：系統(tǒng)運(yùn)維

1，現(xiàn)狀描述

由于某些原因，導(dǎo)致rocketmq集群中某個(gè)master節(jié)點(diǎn)不能正常服務(wù)，需要為master節(jié)點(diǎn)做流量遷移動(dòng)作，已確保消息不丟失配置策略為：

    • 異步刷盤

    • 主從異步復(fù)制

如果直接下線該master，由于主從異步復(fù)制，可能導(dǎo)致部分消息來不及復(fù)制到slave造成消息丟失。所以該方案不可行。
另一種方案選擇：關(guān)閉該broker的寫入權(quán)限，待該broker不再有寫入和消費(fèi)時(shí)，再下線該節(jié)點(diǎn)。

2.關(guān)閉broker寫權(quán)限


2表示只寫權(quán)限，4表示只讀權(quán)限，6表示讀寫權(quán)限

#bin/mqadmin?updateBrokerConfig?-b?broker:port?-n?nameserver:prot?-k?brokerPermission?-v?4

3.觀察節(jié)點(diǎn)流量

#bin/mqadmin?clusterList?-n?nameserver:prot

RocketMQ集群生產(chǎn)環(huán)境master節(jié)點(diǎn)節(jié)點(diǎn)優(yōu)雅下線觀察InTPS和OutTPS，理想情況都為零時(shí)，并不再變化時(shí)，則該節(jié)點(diǎn)可下線了。
然而，在實(shí)際過程中并沒有出現(xiàn)為零的情況，InTPS和OutTPS總是有值，有時(shí)個(gè)位數(shù)字有時(shí)是兩位數(shù)字，大部分時(shí)間在20多的值。此刻要分析下broker目前的消費(fèi)狀態(tài)。

4.觀察broker消費(fèi)狀態(tài)

#sh?bin/mqadmin?brokerConsumeStats?-b?broker:prot?-n?nameserver:prot?>>?brokerConsumeStats.tmp

查看brokerConsumeStats.tmp，主要查看#LastTime和#Diff。發(fā)現(xiàn)%RETRY%重試類隊(duì)列#Diff有很微?。?或者3）的數(shù)據(jù)，而其他topic均為0. LastTime時(shí)間最新也是發(fā)生在%RETRY%隊(duì)列中。此時(shí)可以讓該節(jié)點(diǎn)下線操作。RocketMQ集群生產(chǎn)環(huán)境master節(jié)點(diǎn)節(jié)點(diǎn)優(yōu)雅下線

5.borker讀寫權(quán)限恢復(fù)

#bin/mqadmin?updateBrokerConfig?-b?broker:port?-n?nameserver:prot?-k?brokerPermission?-v?6

觀察各節(jié)點(diǎn)流量是否正常

#bin/mqadmin?clusterList?-n?nameserver:prot

RocketMQ集群生產(chǎn)環(huán)境master節(jié)點(diǎn)節(jié)點(diǎn)優(yōu)雅下線






向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手