Debian环境下进行RabbitMQ性能测试
一 环境准备与连通性验证
- 安装与启动
- 安装 RabbitMQ（Debian 可使用官方 APT 仓库或系统包管理器），启动服务：sudo systemctl start rabbitmq-server
- 启用管理插件并访问控制台：sudo rabbitmq-plugins enable rabbitmq_management，浏览器打开 http://localhost:15672（默认账号密码在首次安装后设置）
- 连通性自检
- 查看节点状态：rabbitmqctl status
- 列出队列：rabbitmqctl list_queues
- 直连 AMQP 端口：telnet localhost 5672（出现 AMQP 协议握手信息即正常）
- 简单收发验证
- 使用 rabbitmqadmin 声明队列、发消息、取消息，确认基础消息路径可用（适合作为压测前的冒烟测试）
二 核心工具与选择
- rabbitmq-perf-test（推荐）
- 官方提供的 Java 压测工具，覆盖吞吐量、确认模式、消息大小、持久化、运行时长、预填充队列等场景，支持多队列与指标输出，适合系统化压测与瓶颈定位
- JMeter + AMQP 插件
- 图形化场景编排能力强，适合与业务行为模型结合（定时、思考时间、事务/断言），便于做端到端性能回归与报表展示
三 使用 rabbitmq-perf-test 进行压测
- 安装与运行
- 方式一（推荐）：直接下载官方可执行 JAR（perf-test.jar），在 Debian 上确保已安装 OpenJDK 8+，运行：java -jar perf-test.jar --help
- 方式二：使用源码脚本 runjava 执行（同属官方工具链）
- 常用命令模板
- 基础吞吐（1P/2C、自动确认、无速率限制）
java -jar perf-test.jar --uri amqp://localhost:5672 -x 1 -y 2 -u q1 -a --id “baseline”
- 调整消息体为 4KB
java -jar perf-test.jar --uri amqp://localhost:5672 -x 1 -y 2 -u q1 -a -s 4000 --id “4k”
- 持久化队列与消息（队列与消息均持久化，注意对性能影响）
java -jar perf-test.jar --uri amqp://localhost:5672 -x 1 -y 2 -u q1 -f persistent --id “persist”
- 固定压测时长 60 秒
java -jar perf-test.jar --uri amqp://localhost:5672 -x 1 -y 2 -u q1 -a -z 60 --id “60s”
- 预填充队列（无消费者，写入 1000000 条、每条 1KB 的持久化消息，用于后续消费测试）
java -jar perf-test.jar --uri amqp://localhost:5672 -y 0 -p -u q1 -s 1000 -C 1000000 -f persistent --id “prepop”
- 多队列与高并发（10 个队列、100P/100C）
java -jar perf-test.jar --uri amqp://localhost:5672 --queue-pattern ‘perf-%d’ --queue-pattern-from 1 --queue-pattern-to 10 --producers 100 --consumers 100
- 指标与监控（开启 Prometheus 指标端口 8090）
java -jar perf-test.jar --metrics-help
java -jar perf-test.jar --uri amqp://localhost:5672 --metrics-port 8090
- 关键参数速查
- -x/-y：生产者/消费者数量；-u：队列名；-a：自动确认；-s：消息大小（字节）
- -f：消息/队列标志（如 persistent）；-z：运行时长（秒）；-C：发布消息总数
- -D：消费消息总数；-p：允许使用预声明对象；–queue-pattern：多队列模式
四 使用 JMeter 进行压测
- 安装与插件
- 安装 Java 8+ 与 Apache JMeter，通过 JMeter 插件管理器或手动将 JMeter-Rabbit-AMQP 插件 JAR 放入 JMeter 的 lib 目录，重启 JMeter
- 测试计划要点
- 添加线程组，配置并发线程数与循环
- 添加 AMQP Publisher/Consumer 取样器，填写 Host/Port/VHost/User/Password、交换机与队列、路由键、消息内容/属性
- 可结合定时器、断言、监听器（查看结果树、聚合报告、Summary Report）形成闭环
- 运行与报告
- 命令行执行：jmeter -n -t test_plan.jmx -l result.jtl
- 在 Grafana/Prometheus 中结合队列监控与 JMeter 报告进行瓶颈分析与回归
五 监控指标与结果判读
- 观测维度
- 吞吐与稳定性：每秒发布/确认速率、平均/最大/分位延迟、错误率
- 资源与队列：节点 CPU/内存/磁盘 I/O、队列长度（ready/acked/unacked）、网络
- 持久化影响：开启 publisher confirms 与 持久化 会显著降低吞吐，需单独对比基线
- 快速判读
- 吞吐随并发线性增长后趋于平缓，常见瓶颈为磁盘 I/O、网络、消费者处理能力或 prefetch 设置不当
- 消费延迟高且队列持续增长，优先检查消费者并发度、手动确认与预取（prefetch count）配置
- 可观测性增强
- 使用 rabbitmq-perf-test 的 –metrics-port 8090 暴露 Prometheus 指标，结合 Grafana 面板观察压测过程