RocketMQ使用排查指南是怎樣的

# RocketMQ使用排查指南是怎樣的

RocketMQ作為一款高性能分布式消息中間件，在實際使用中可能遇到消息堆積、消費延遲或發送失敗等問題。本文將提供常見問題的排查思路和解決方案。

## 一、消息發送失敗排查
1. **檢查NameServer連接**  
   - 確認生產者配置的NameServer地址正確（`namesrvAddr`）
   - 通過`telnet nameserver_ip 9876`測試網絡連通性

2. **Topic路由問題**  
   ```java
   // 代碼示例：手動創建Topic（需管理員權限）
   admin.createTopic("TOPIC_NAME", "BROKER_NAME", 8);

• 返回錯誤No route info時需檢查Topic是否存在

二、消息堆積處理

1. 監控關鍵指標

   # 查看堆積量
   sh mqadmin consumerProgress -n nameserver_ip:9876 -g CONSUMER_GROUP
   

   • 關注DIFF字段顯示未消費消息數

2. 解決方案

   • 擴容消費者實例數
   • 提高消費者線程數（consumeThreadMin/consumeThreadMax）
   • 檢查消費者邏輯是否阻塞（如數據庫慢查詢）

三、消費延遲問題

1. 線程堆棧分析

   # 獲取Java進程堆棧
   jstack pid > stack.log
   

   • 檢查消費者線程狀態（WTING/BLOCKED）

2. 配置優化

   • 調整pullBatchSize（默認32）
   • 關閉VIP通道（vipChannelEnabled=false）

四、Broker端問題

1. 磁盤空間檢查

   df -h /store_path
   

   • 建議保留至少20%空閑空間

2. 日志分析

   • 重點檢查storeerror.log和broker.log
   • 常見錯誤：No space left on device或Too many open files

五、網絡問題排查

1. 基礎檢查

   • 使用ping/traceroute檢查網絡延遲
   • 通過netstat -antp|grep 10911檢查端口狀態

2. 防火墻設置

   # 開放Broker端口
   iptables -I INPUT -p tcp --dport 10911 -j ACCEPT
   

提示：建議配合RocketMQ控制臺（Dashboard）進行可視化監控，可快速定位大部分運行時問題。遇到復雜場景時，可開啟DEBUG級別日志采集（rocketmq.client.logLevel=DEBUG）。 “`

（全文約450字，包含代碼示例和實用命令）