1.大量消息在mq里積壓 場景:幾千萬條數據在MQ里積壓了七八個小時,從下午4點多,積壓到了晚上很晚,10點多,11點多。線上故障了,這個時候要不然就是修復consumer的問題,讓他恢復消費速度,然后傻傻的等待幾個小時消費完畢。這個肯定不行。一個消費者一秒是1000條,一秒3個消費者是3000 ...
作者:jsbintask來源:簡書鏈接:https: www.jianshu.com p f b a 面試題剖析 你看這問法,其實本質針對的場景,都是說,可能你的消費端出了問題,不消費了 或者消費的速度極其慢。接着就坑爹了,可能你的消息隊列集群的磁盤都快寫滿了,都沒人消費,這個時候怎么辦 或者是這整個就積壓了幾個小時,你這個時候怎么辦 或者是你積壓的時間太長了,導致比如 RabbitMQ 設置了 ...
2019-12-17 10:57 0 1036 推薦指數:
1.大量消息在mq里積壓 場景:幾千萬條數據在MQ里積壓了七八個小時,從下午4點多,積壓到了晚上很晚,10點多,11點多。線上故障了,這個時候要不然就是修復consumer的問題,讓他恢復消費速度,然后傻傻的等待幾個小時消費完畢。這個肯定不行。一個消費者一秒是1000條,一秒3個消費者是3000 ...
1.大量消息在mq里積壓 場景:幾千萬條數據在MQ里積壓了七八個小時,從下午4點多,積壓到了晚上很晚,10點多,11點多。線上故障了,這個時候要不然就是修復consumer的問題,讓他恢復消費速度,然后傻傻的等待幾個小時消費完畢。這個肯定不行。一個消費者一秒是1000條,一秒3個消費者是3000 ...
MQ怎么解決消息堆積的問題 網上普通回答 修復consumer的問題,確保其恢復消費速度,然后將現有consumer都停止 臨時建立好原先10倍或者20倍的queue數量 然后寫一個臨時的分發數據的consumer程序,這個程序部署上去消費積壓的數據,消費 ...
MQ系列1:消息中間件執行原理 MQ系列2:消息中間件的技術選型 MQ系列3:RocketMQ 架構分析 MQ系列4:NameServer 原理解析 MQ系列5:RocketMQ消息的發送模式 MQ系列6:消息的消費 MQ系列7:消息通信,追求極致性能 MQ系列8:數據存儲,消息隊列的高可用保障 ...
RocketMQ消息堆積問題 RocketMQ消息堆積主要分為三個層次的問題: 其一是Producer生產速率過快,什么場景呢,比如Producer故障,比如DOS攻擊,比如業務高峰(超過企業預估的,例如12306訂票,雙十一下單,這些一開始的時候都有超過預期的情況)。 其二是Broker消息 ...
下游消費系統如果宕機了,導致幾百萬條消息在消息中間件里積壓,此時怎么處理?你們線上是否遇到過消息積壓的生產故障?如果沒遇到過,你考慮一下如何應對?首先要找到是什么原因導致的消息堆積,是Producer太多了,Consumer太少了導致的還是說其他情況,總之先定位問題。然后看下消息消費速度是否正常 ...
首先要找到原因,是producer太多了,還是說consumer太少了。定位問題,然后看下消息的消費速度是否正常,正常的話,可以通過臨時上線更多consumer解決問題。 如果consumer和queue不對等,上線了多台consumer也無法解決的話,可以 准備一個臨時 ...
原因: 有時可能因為消費者自身代碼問題,導致沒辦法正常消費消息,那么就會導致消息隊列中會堆積大量的消息; 或因為同一時間來了非常多的消息,消費者沒辦法及時消費,導致消息隊列中堆積了大量消息。 解決辦法: 1.去優化消費者代碼,提高消費能力。減少消費時間 2. ...