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

RocketMQ Proxy 的两种部署模式会直接决定集群的吞吐上限和延迟下限。这篇 RocketMQ Proxy 性能测试指南把问题拆成四步：Proxy 到底承担什么职责、集群和本地模式差在哪、benchmark 参数怎么配、吞吐与延迟数据怎么读，最后给出选型结论。

🧩 Proxy 在链路中承担什么职责

Proxy 是加在客户端和存储之间的一层无状态网关：它用 gRPC 接收客户端请求，翻译成 RocketMQ 内部的 Remoting 协议，再转给 Broker 或 NameServer 处理。普通、顺序、事务、延迟这几种消息类型，消费侧都走 POP 机制。

POP 消费机制让消费行为本身变成无状态的：客户端不再需要固定绑定某组队列，消费进度由 Broker 统一管理。这是 Proxy 可以随意加减节点的关键前提。

另外，SSL、鉴权、日志与 metrics、连接管理和流量治理都收敛在 Proxy 层，Broker 不用重复实现这些横切逻辑。

集群模式和本地模式差在哪

两种模式的区别本质上是 Proxy 的部署位置：

• 集群模式：Proxy 作为独立进程集群运行，通过远程调用访问 Broker 和 NameServer。计算与存储彻底分离——Proxy 只负责处理请求，需要扛流量峰值时直接加节点；Broker 专注存储引擎和高可用。
• 本地模式：Proxy 和 Broker 装在同一个进程里，内部调用不走网络。形态更接近 RocketMQ 4.x，对已有集群来说部署、升级路径更平滑，单节点开销也更小。

启动方式：在distribution/conf/rmq-proxy.json里配好nameSrvAddr，把proxyMode设为cluster或local（大小写不敏感），然后执行nohup sh mqproxy &。本地模式下这一条命令会同时拉起 Proxy 和 Broker；集群模式只启动 Proxy，需要 NameServer 和 Broker 已经就位。

性能测试参数怎么配

压测用仓库 distribution/benchmark/ 目录里的内置脚本，覆盖生产者、消费者和批量发送场景。典型的参数组合：

• 消息大小：1KB、4KB、16KB，对应小、中、大消息三档
• 并发线程：16、32、64，逐步加压观察吞吐曲线何时走平
• 单轮时长：30 分钟，足够把短时抖动磨平
• 采样间隔：1 秒，用于还原峰值和均值

参数这么配的原因：吞吐和延迟对消息大小很敏感，单点数据代表不了整体，必须多档组合着看。

📊 吞吐量与延迟结果怎么解读

一次发送就是一次 RPC 往返：客户端发出请求，Broker 处理完再回复。两种模式的差异主要出在这条链路上：

• 延迟：本地模式的调用留在进程内，网络耗时和抖动更小；集群模式多一跳网络，高并发下 P99 更容易被放大。
• 吞吐：集群模式不受单机容量封顶，Broker 吃满时继续加 Proxy 节点就能往上堆；本地模式上限跟着机器走，但因为省掉一跳网络，单机效率更高。
• 大消息：16KB 档位下传输量放大，本地模式的低开销优势更明显；集群模式的价值则体现在横向扩容。

定性结论：相同硬件下两种模式量级接近，差别在于本地模式赢在单机效率，集群模式赢在规模上限。

调优与监控看哪些点

调优动作可以收敛成三条：

1. 集群模式：核对 NameServer 地址列表完整，避免路由抖动；Proxy 节点数按峰值 QPS 评估，而不是简单对齐 Broker 数量。
2. 本地模式：Proxy 与 Broker 共享进程资源，盯住整机 CPU 和内存，别让两个组件互相挤占。
3. 负载策略：确认流量在 Proxy / Broker 节点间摊开，别出现单节点热点。

监控盯三个指标：

• 节点负载：每个 Proxy 节点的 CPU、内存、线程池水位
• 连接状态：连接数与异常断开，连接治理本来就是 Proxy 的职责
• 消息处理延迟：平均、P99 与最大值，P99 的趋势比均值更值得看

metrics 里自带proxy_mode标签（见ProxyMetricsConstant中的LABEL_PROXY_MODE），指标天然带模式标识，两种模式的数据可以直接拆开对比。

✅ 选型结论

• 大规模生产集群、弹性峰值明显、希望计算层独立扩缩：选集群模式。
• 中小规模、从 4.x 存量集群升级、运维人手有限：选本地模式，开销低、迁移顺。
• 单机性能摸底或消息偏大的业务：先跑本地模式基准，再验证集群模式的扩容上限。

口径说明：以上结论基于标准测试环境，实际数值受硬件、网络与消息特征影响，请以自己环境里跑出的 benchmark 数据为准。

【免费下载链接】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