为什么升职的总是别人？

为什么需要命令行测试MQ？

命令行工具是运维工程师和开发者验证消息队列（MQ）核心功能的直接方式，具有以下优势：

• 快速诊断：无需编码即可验证MQ服务状态
• 故障定位：精准识别连接、发送/接收问题
• 环境验证：在服务器或容器内直接操作生产/测试环境

主流MQ命令行测试方法

RabbitMQ测试

必备工具：rabbitmqadmin (需启用管理插件)

# 下载管理工具
curl -O http://localhost:15672/cli/rabbitmqadmin
chmod +x rabbitmqadmin

关键测试命令：

# 检查服务状态
rabbitmqctl status
# 测试消息发布（将消息发送到my_queue）
./rabbitmqadmin publish exchange=amq.default routing_key=my_queue payload="hello,world"
# 测试消息消费（从my_queue读取1条消息）
./rabbitmqadmin get queue=my_queue count=1
# 查看队列列表（验证队列是否存在）
./rabbitmqadmin list queues

Apache Kafka测试

使用内置命令行客户端：

# 创建测试主题
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test_topic --partitions 1 --replication-factor 1
# 发送测试消息
echo "test_message" | kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic
# 消费消息（实时监听）
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning
# 查看主题详情
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test_topic

RocketMQ测试

通过内置工具测试：

# 发送测试消息
tools.sh org.apache.rocketmq.example.quickstart.Producer
# 消费消息（需另起终端）
tools.sh org.apache.rocketmq.example.quickstart.Consumer
# 查看集群状态
mqadmin clusterList -n localhost:9876

通用测试场景及命令

场景1：验证MQ服务连通性

# RabbitMQ
telnet localhost 5672  # AMQP默认端口
# Kafka
nc -zv localhost 9092  # 检查Broker端口
# RocketMQ
telnet localhost 9876  # NameServer端口

场景2：监控消息积压

# RabbitMQ（查看ready消息数）
rabbitmqctl list_queues name messages_ready
# Kafka（查看Lag）
kafka-consumer-groups.sh --describe --group my_group --bootstrap-server localhost:9092

场景3：压力测试（使用内置工具）

# Kafka生产者压测
kafka-producer-perf-test.sh --topic test_topic --num-records 100000 --record-size 1000 --throughput -1 --producer-props bootstrap.servers=localhost:9092
# RabbitMQ（需安装perf-test插件）
rabbitmq-perf-test -x 1 -y 2 -u "test_queue" -a --id "test1"

故障排查命令

# 查看MQ日志（通用）
tail -f /var/log/rabbitmq/rabbit@localhost.log  # RabbitMQ示例
tail -f /opt/kafka/logs/server.log             # Kafka示例
# 检测网络延迟（生产者->MQ）
tcpping mq-server 5672  # 需要安装tcptraceroute
# 检查资源瓶颈
top -p $(pgrep -f rabbitmq-server)  # 替换为对应进程名

安全注意事项

1. 生产环境慎用：测试后及时删除测试队列/主题
2. 权限最小化：使用专用测试账号而非管理员账号
3. 防火墙规则：测试后关闭临时开放的端口
4. 敏感信息过滤：避免在日志中打印消息内容（可通过--property print.key=false在Kafka中禁用）

专业建议

• 自动化测试：将关键命令集成到CI/CD流水线（如Jenkins）
• 指标监控：配合Prometheus + Grafana可视化MQ状态
• TLS加密测试：openssl s_client -connect mq-host:5671（验证SSL证书）

引用说明：本文命令参考自官方文档

• RabbitMQ: https://www.rabbitmq.com/cli.html
• Kafka: https://kafka.apache.org/documentation/#basic_ops
• RocketMQ: https://rocketmq.apache.org/docs/cli-admin-tool/
  测试前请确保已阅读对应版本文档，命令可能随版本更新变化。