溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹了RocketMQ內(nèi)存?zhèn)鬏敿?.7消費線程參數(shù)設置的示例分析，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。
一、transferMsgByHeap誤解
transferMsgByHeap設置為false時，通過堆外內(nèi)存?zhèn)鬏敂?shù)據(jù)，相比堆內(nèi)存?zhèn)鬏敎p少了數(shù)據(jù)拷貝、零字節(jié)拷貝、效率更高，所以關(guān)閉transferMsgByHeap應該成為我們的優(yōu)先選擇，但是實踐來看，你或許會改變想法，下面是transferMsgByHeap=false，客戶端大量超時錯誤時的日志截圖。
小結(jié)：你看到這里會發(fā)現(xiàn)，在關(guān)閉transferMsgByHeap時，可能造成堆外內(nèi)存分配不夠，觸發(fā)系統(tǒng)內(nèi)存回收和落盤操作。此時CPU會有一個陡坡，具體客戶端表現(xiàn)為發(fā)送大量超時。解決方式開啟transferMsgByHeap即可，讓運行更加平穩(wěn)。
二、消費的最小線程數(shù)
我們在使用rocketmq消費時，有兩個參數(shù)consumeThreadMin和consumeThreadMax。在以往的版本中，我們只需要設置consumeThreadMin即可，例如consumeThreadMin=64。在rocket-client4.7版本中，如果設置consumeThreadMin=64會導致消費失敗，下面看下原因。
org.apache.rocketmq.client.exception.MQClientException: consumeThreadMin (64) is larger than consumeThreadMax (20)
在rocketmq-client新版本中，增加了consumeThreadMax的判斷。當consumeThreadMin大于20時需要同時設置consumeThreadMax，所以單獨設置consumeThreadMin=64會拋出錯誤導致消費失敗。
感謝你能夠認真閱讀完這篇文章，希望小編分享的“RocketMQ內(nèi)存?zhèn)鬏敿?.7消費線程參數(shù)設置的示例分析”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學習!
免責聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。
億速云公眾號
手機網(wǎng)站二維碼
