RocketMQ Proxy 性能测试全解：集群与本地两种部署模式如何选
【免费下载链接】rocketmqApache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.项目地址: https://gitcode.com/gh_mirrors/ro/rocketmq
Apache RocketMQ Proxy 支持集群、本地两种部署模式。本文按"先跑通压测，再谈选型"的顺序，给出 RocketMQ Proxy 性能测试的参数设置、结果解读方法与两种模式的对比结论，帮助你在部署前做出判断。
先说清楚 Proxy 是干什么的
很多团队上 RocketMQ 时只接触过 NameServer、Broker 和客户端，新版本里多出来的 Proxy 层容易让人困惑：它是必须部署的吗？
Proxy 是一个无状态的计算组件，可以理解为"客户端与 Broker 之间的代理层"。它原生支持 gRPC 协议，把传入的流量转换成 RocketMQ 自定义的 Remoting 协议，再去访问 Broker 和 NameServer，同时负责连接管理与流量治理。
它还有一个关键特性：借助 POP 消费机制（一种按"取走一条处理一条"方式拉取消息的消费模式，不需要客户端自己维护消费位点），Proxy 可以以无状态方式处理消费请求，这也是它敢于水平扩容的前提。
两种部署模式，差别到底在哪
部署上，Proxy 只有两种模式，核心区别是"算"和"存"是否分开放：
| 对比维度 | 集群模式 | 本地模式 |
|---|---|---|
| 部署形态 | Proxy 独立成集群，通过 Remoting 远程调用 Broker | Proxy 与 Broker 同进程部署 |
| 网络开销 | 每次调用多一跳网络 | 进程内通信，省掉网络这一跳 |
| 扩展能力 | 可随流量峰值独立增减节点 | 扩展粒度受 Broker 进程限制 |
| 部署与升级 | 组件多一套，升级链路更长 | 更简单，单进程搞定 |
| 架构效果 | 计算与存储分离 | 单机性能表现更优 |
一句话概括：集群模式买的是弹性，本地模式买的是省心和低延迟。
压测参数怎么设：消息大小、并发数与采样间隔
RocketMQ 自带一套压测工具，放在 distribution/benchmark 目录下，包含生产端与消费端脚本。生产者脚本内部执行的命令形如：
sh ./runclass.sh -Dorg.apache.rocketmq.client.sendSmartMsg=true org.apache.rocketmq.example.benchmark.Producer $@对照 Consumer.java 所在的example模块源码，参数默认值都能查到。一组推荐的压测矩阵：
- 消息大小：1KB、4KB、16KB 三档，覆盖小消息、常规业务和大 payload；
- 并发线程数：16、32、64（生产者默认 64，消费者默认 20），逐步加压观察拐点；
- 测试时长：30 分钟，短压测容易被预热效应干扰；
- 采样间隔：1 秒，方便画出吞吐与延迟曲线。
消费者端脚本对应：
sh ./runclass.sh org.apache.rocketmq.example.benchmark.Consumer $@结果怎么读：吞吐与延迟分别看什么
压测结束后，重点不是记下平均吞吐，而是看两类指标在两种模式下的相对变化：
- 吞吐类：平均吞吐量、峰值吞吐、持续吞吐能力。集群模式在 1000+ QPS 的压力下，扩节点就能继续分担流量；本地模式在 16KB 大消息场景下，因为少一跳网络，表现通常更好。
- 延迟类：平均延迟、P99 延迟、最大延迟。两种模式下延迟都能做到毫秒级，但 P99 对网络跳数更敏感，对比时建议把 30 分钟曲线拉出来看，别只盯着平均值。
哪种场景选哪种模式
结合上面的对比，选型可以收敛成三句话：
- 流量有明显峰值、希望计算层独立扩容：选集群模式，Proxy 节点随峰值增减，Broker 保持稳定；
- 单机资源有限、想少一跳网络：选本地模式，部署升级简单，大消息场景收益明显；
- 协议要求 gRPC：两种模式都走 Proxy，差别只在部署位置，不影响功能。
监控上两类模式都要盯三件事：Proxy 节点负载、网络连接状态、消息处理延迟。
上线前检查清单
- NameServer 集群地址在 Proxy 配置中可达，Topic 路由能正常返回；
- 用 benchmark 工具跑出一组基线数据（三档消息大小 × 至少两个并发档位）；
- 确认监控覆盖：Proxy 负载、连接状态、消费延迟三项指标有告警；
- 集群模式下明确 Proxy 与 Broker 的版本兼容与灰度升级顺序。
集群模式的独立启动命令：
nohup sh mqproxy &一句话收束：选型标准就一条——你的瓶颈在计算弹性，还是在那一跳网络。需要注意的是，本文结论基于参考环境的测试方向，具体数值会因硬件、消息特征和配置而异；正式投产前，请用上面的参数矩阵在自己的环境复测一轮，以实测曲线为准。
【免费下载链接】rocketmqApache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.项目地址: https://gitcode.com/gh_mirrors/ro/rocketmq
创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
