RocketMQ Broker 快速失敗機制

版本：4.2.0，原始碼：class檔案

broker的快速失敗機制是為了防止請求過載，導致broker處理請求效率變低，從而影響訊息的消費

broker啟動的時候會初始化broke***stfailure

this.broke***stfailure = new broke***stfailure(this);

this.broke***stfailure.start();

public void start() 

​       }
}, 1000l, 10l, timeunit.milliseconds);
}

private void cleanexpiredrequest() 

}} catch (throwable var3) 
}// 清理過期的producer請求
this.cleanexpiredrequestinqueue(this.brokercontroller.getsendthreadpoolqueue(), this.brokercontroller.getbrokerconfig().getwaittimemillsinsendqueue());
// 清理過期的consumer請求
this.cleanexpiredrequestinqueue(this.brokercontroller.getpullthreadpoolqueue(), this.brokercontroller.getbrokerconfig().getwaittimemillsinpullqueue());
return;
}}

void cleanexpiredrequestinqueue(blockingqueueblockingqueue, long maxwaittimemillsinqueue) 

continue;}}
}}
​            return;
} catch (throwable var8) 
}}

RocketMQ Broker的最佳實踐

翻譯自rocket官方文件 broker的方式有非同步主，同步主，或者從。如果不能容忍訊息丟失，建議以同步主從方式部署。如果對丟失沒那麼嚴格，但是希望高可用，可以部署為非同步主從，如果你想更簡單，可以使用非同步主而不需要從機。非同步刷盤是推薦的方式,因為同步刷盤太多的消耗而且造成大量的效能丟失，如果...

rocketmq broker 訊息分發流程分析

文章基於rocket mq4.0 分析 server接收到訊息後，會將訊息分發到對應的consumequeue中，等待client端拉取消費。核心類 org.apache.rocketmq.store.defaultmessagestore.reputmessageservice類圖 該類繼承 se...

Rocketmq broker寫入能力檢視

如何證明 rocketmq 集群本身沒有問題呢？其實也很簡單，我們通常乙個常用的技巧是檢視 rocketmq 訊息寫入的效能，執行如下命令 cd logs rocketmqlogs grep pagecachert store.log more 其輸出的結果如下圖所示 在 rocketmq brok...