如何處理消息堆積？

除了異步解耦功能，消息隊列還有擋住前端數據洪峰的重要功能，以此保證后端系統的穩定性。這要求消息隊列具有一定的消息堆積能力。消息隊列能支持 10 億級別的消息堆積，不會因為消息堆積導致性能明顯下降。

問題描述

在消息隊列控制臺的消費者狀態頁面，看到 Group ID 的實時消息堆積量的值高于預期，且性能明顯下降。

解決方法

面對消息堆積，且有明顯性能下降的情況，可采取以下措施處理：

1. 在消息隊列控制臺，通過 查看消費者狀態 獲取消息堆積的消費者實例所對應的宿主機 IP 地址，并登錄該宿主機或容器。

2. 執行以下任一命令查看進程 pid。

   • ps -ef |grep java

   • jps -lm

3. 執行 jstack -l pid > /tmp/pid.jstack 命令查看堆棧信息。

4. 執行 cat /tmp/pid.jstack|grep ConsumeMessageThread -A 10 --color 命令查看 ConsumeMessageThread 的信息，重點關注線程的狀態及堆棧。命令回顯如下圖所示。

   

線程狀態的解釋說明請參見 Java 官方文檔。

更多信息

如按以上操作還未解決因消息堆積而導致的性能下降問題，您可以 提交工單 獲得技術支持。提交時，請附帶以下信息：

• heap.bin 文件，該文件可通過執行 jmap -dump:format=b,file=heap.bin [pid] 命令獲取，再執行 gzip heap.bin 命令生成壓縮包。

  說明

  [pid] 是消息堆積處理第二步中找到的進程 pid。

• 發生消息堆積的消費者客戶端 sofamq.log 本地日志。

• 消費者客戶端的版本。