MQ中间件的测试方法

MQ 中间件的测试核心是围绕功能正确性、性能极限、可靠性、高可用与容错、安全性、可观测性六大维度通过场景模拟、故障注入、压力负载、数据比对等方法验证消息生产、存储、投递、消费全链路的稳定与可靠。一、功能测试基础验证核心目标确认 MQ 基础收发、队列 / 主题管理、确认机制、路由规则等功能正常。消息收发单发单收、多发多收、广播 / 订阅模式Topic验证不同消息体文本 / JSON / 二进制、1KB~10MB收发一致性队列 / 主题创建、删除、权限、过期、优先级功能确认与事务机制生产者 ACK同步 / 异步确认、事务提交 / 回滚消费者 ACK手动 Ack、自动 Ack、Reject/Nack、重试、死信队列DLQ事务消息 / 半消息如 RocketMQ 事务完整性验证路由与过滤交换机类型Direct/Topic/Fanout/Headers、路由键匹配消息过滤、延迟消息、定时消息、顺序消息正确性二、性能测试容量与效率核心指标吞吐量TPS/QPS、延迟P50/P95/P99、资源利用率、稳定性。基准压测固定消息大小1KB/10KB/100KB递增并发生产者 / 消费者记录生产速率、消费速率、端到端延迟、CPU / 内存 / 磁盘 I/O/ 网络场景设计常态70% 小消息 30% 中等消息峰值突发流量、流量毛刺、消费能力不足消息堆积混合生产快消费慢、消费快生产慢、多队列并行常用工具Kafkakafka-producer-perf-test.sh、kafka-consumer-perf-test.shRabbitMQrabbitmq-perf-test、JMeterAMQP 插件通用JMeter、Locust、k6、自研 SDK 压测脚本三、可靠性测试不丢、不重、不乱核心目标极端场景下零丢失、可重复消费、业务幂等。消息持久化Broker 重启 / 宕机 /kill -9 后未消费消息完整恢复磁盘满、磁盘故障下消息保护机制生产端故障网络闪断、超时、Broker 不可用 → 消息重试、补发、不丢失生产者崩溃 → 重启后未确认消息重发消费端故障消费异常 / 抛异常 → 重试、死信、不丢失消费成功但未 Ack → 重投、重复消费验证业务幂等消费者下线 → 消息堆积、重新分配、不丢不重消息重复与幂等强制重复投递 → 验证业务处理幂等如唯一 ID 去重网络重传、客户端重试场景下重复率控制四、高可用与容错测试集群稳定性核心目标节点故障不影响服务、自动故障转移、数据一致。集群故障单 Broker 宕机 → 主从切换、选举、服务恢复、消息不丢多节点宕机、网络分区脑裂→ 一致性、可用性验证扩容 / 缩容 → 负载均衡、吞吐量线性、数据重平衡网络异常断网、延迟、丢包、限流 → 重连、消息不丢、积压可控恢复验证故障恢复时间RTO、数据一致性RPO同步 / 异步复制、ISRKafka、镜像队列RabbitMQ有效性五、安全性测试认证账号 / 密码、SSL/TLS、Kerberos、ACL 权限控制授权生产 / 消费 / 管理权限隔离、越权访问阻断传输加密链路加密、消息内容加密审计操作日志、消息轨迹、敏感数据脱敏六、可观测性与监控验证监控指标队列深度、生产 / 消费速率、堆积量、延迟、错误率、连接数告警堆积阈值、消费停滞、Broker 宕机、磁盘 / CPU 高水位日志与追踪全链路日志、消息 ID 追踪、生产 - 存储 - 消费时序七、典型测试流程通用环境准备复刻生产配置版本、集群规模、磁盘、网络、JVM / 内核参数监控部署PrometheusGrafana、云监控、日志系统ELK用例设计功能正向 反向非法参数、权限、不存在队列性能基准、峰值、混合、长时间稳定性72h可靠性故障注入kill、断网、宕机、异常高可用主从切换、扩缩容、故障转移执行与数据比对消息唯一 ID生产总数 消费总数 死信总数 未消费丢失率 0、重复率≤业务阈值如 0.001%性能吞吐量达标、P99 延迟≤阈值、资源≤70%稳定工具推荐压测JMeter、Locust、k6、厂商自带压测工具故障注入ChaosMesh、Pumba、简单脚本kill/iptables监控Prometheus、Grafana、云厂商 MQ 监控、OpenTelemetry八、常见验收标准参考功能用例通过率 100%性能达到需求 120%、P99 延迟 200ms、CPU70%可靠性丢失率 0、重复率 0.001%高可用单节点故障 30s 恢复、无服务中断稳定性72 小时压测无 OOM、无宕机、无消息异常