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字，包含代码示例和实用命令）