1. rocketmq源碼安裝參考官方文檔：http://rocketmq.apache.org/docs/quick-start/安裝好jdk和maven rocketmq安裝包：https://pan.baidu.com/s/1I3CqWaxFnxtUX1kJpIJkcQ 密碼: vu5m ...

轉載：消息隊列消息積壓了怎么辦？ 作者： 以夢為碼 　　Q:剛開始是對這個疑問抱有質疑態度的，因為使用消息隊列的其中目的就是削峰填谷，來避免高流量時，對下游服務的沖擊，所以使用消息隊列進行緩沖，下游根據自己的消費能力去消費， 我感覺這就是消息積壓本就是使用消息隊列的功能，怎么會是問題 ...

在日常工作中使用RabbitMQ偶爾會遇不可預料的情況導致的消息積壓，一般出現消息積壓基本上分為幾種情況： 消費者消費消息的速度趕不上生產速度，這總問題主要是業務邏輯沒設計好消費者和生產者之間的平衡，需要改業務流程或邏輯已保證消費度跟上生產消息的速，譬如增加消費者的數量 ...

大量消息在 mq 里積壓了幾個小時了還沒解決 幾千萬條數據在 MQ 里積壓了七八個小時，從下午 4 點多，積壓到了晚上 11 點多。這個是我們真實遇到過的一個場景，確實是線上故障了，這個時候要不然就是修復 consumer 的問題，讓它恢復消費速度，然后傻傻的等待幾個小時消費完畢。這個肯定不能在 ...

...

消息丟失 1、只要訂單完成我們就會發送一條消息給MQ，這個途中突然MQ服務器網絡中斷，導致消息無法抵達 做好容錯方法需要在消息發送前加上異常處理 還可以將消息存入數據庫，把失敗的消息定期重新再發一遍 2、當消息發送給MQ，通過Brock通過交換機抵達隊列，MQ關機了，只有抵達隊列 ...

除了消息的丟失，另一個消息隊列常見的問題就是消息積壓了。我們都知道，消息之所以會擠壓是由於消費端的性能除了問題，導致消息的消費速度較低來不及處理上游發送的消息。這一章我們就來看一下，如果優化代碼的性能，避免出現消息積壓。 在使用消息隊列的系統中，對於性能的優化，主要體現在 ...

消費端出了問題，導致消息隊列消息積壓了很多或者集群的磁盤都快寫滿了。 解決思路有兩個： 1、MQ動態擴容，將MQ容量增大，讓其能容納更多的消息 2、消費端加大消費能力，迅速處理掉積壓。 第一個例子： 如果你積壓了幾百萬到上千萬的數據，即使消費者恢復了，也需要大概1小時 ...