处理消息队列积压
當消費者出現異常,很容易引起隊列積壓,如果一秒鐘1000個消息,那么一個小時就是幾千萬的消息積壓,是非常可怕的事情,但是生產線上又有可能會出現;
當消息積壓來不及處理,rabbitMQ如果設置了消息過期時間,那么就有可能由于積壓無法及時處理而過期,這消息就被丟失了;
?
解決方法:
不建議在生產環境使用數據過期策略,一是數據是否丟失無法控制,二是一旦積壓就很有可能丟失;建議數據的處理都有代碼來控制;
當出現消息積壓時,做法就是臨時擴大consumer個數,讓消息快速消費,一般都是通過業務邏輯的手段來完成
?
?
?
?
總結