Rabbitmq如何解決消息積壓問題

這篇文章主要介紹了Rabbitmq如何解決消息積壓問題，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

上千萬條消息在mq里積壓了幾個小時了還沒解決

1）先修復consumer的問題，確保其恢復消費速度，然后將現有cnosumer都停掉

2）新建一個topic，partition是原來的10倍，臨時建立好原先10倍或者20倍的queue數量

3）然后寫一個臨時的分發數據的consumer程序，這個程序部署上去消費積壓的數據，

消費之后不做耗時的處理，直接均勻輪詢寫入臨時建立好的10倍數量的queue

4）接著臨時征用10倍的機器來部署consumer，每一批consumer消費一個臨時queue的數據

5）這種做法相當于是臨時將queue資源和consumer資源擴大10倍，以正常的10倍速度來消費數據

6）等快速消費完積壓數據之后，得恢復原先部署架構，重新用原先的consumer機器來消費消息

rabbitmq設置過期時間的，就是TTL

1. 如果消息在queue中積壓超過一定的時間就會被rabbitmq給清理掉，這個數據就沒了。

2. 那這就是第二個坑了。這就不是說數據會大量積壓在mq里，而是大量的數據會直接搞丟

解決

1. 丟了大量的消息。我們可以采取一個方案，就是批量重導，這個時候我們就開始寫程序，

2. 將丟失的那批數據，寫個臨時程序，一點一點的查出來，然后重新灌入mq里面去，把白天丟的數據給他補回來

RAM node 和 disk node 的區別？

RAM node 僅將 fabric（即 queue、exchange 和 binding等 RabbitMQ基礎構件）相關元數據保存到內存中，但 disk node 會在內存和磁盤中均進行存儲。RAM node 上唯一會存儲到磁盤上的元數據是 cluster 中使用的 disk node 的地址。要求在 RabbitMQ cluster 中至少存在一個 disk node 。

vhost 是什么？起什么作用？

vhost 可以理解為虛擬 broker ，即 mini-RabbitMQ server。其內部均含有獨立的 queue、exchange 和 binding 等，但最最重要的是，其擁有獨立的權限系統，可以做到 vhost 范圍的用戶控制。當然，從 RabbitMQ 的全局角度，vhost 可以作為不同權限隔離的手段（一個典型的例子就是不同的應用可以跑在不同的 vhost 中）。

感謝你能夠認真閱讀完這篇文章，希望小編分享的“Rabbitmq如何解決消息積壓問題”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!