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% 中等消息
- 峰值：突发流量、流量毛刺、消费能力不足（消息堆积）
- 混合：生产快消费慢、消费快生产慢、多队列并行
常用工具
- Kafka：
kafka-producer-perf-test.sh、kafka-consumer-perf-test.sh - RabbitMQ：
rabbitmq-perf-test、JMeter+AMQP 插件 - 通用：JMeter、Locust、k6、自研 SDK 压测脚本
- Kafka：
三、可靠性测试（不丢、不重、不乱）
核心目标：极端场景下零丢失、可重复消费、业务幂等。
消息持久化
- Broker 重启 / 宕机 /kill -9 后，未消费消息完整恢复
- 磁盘满、磁盘故障下消息保护机制
生产端故障
- 网络闪断、超时、Broker 不可用 → 消息重试、补发、不丢失
- 生产者崩溃 → 重启后未确认消息重发
消费端故障
- 消费异常 / 抛异常 → 重试、死信、不丢失
- 消费成功但未 Ack → 重投、重复消费（验证业务幂等）
- 消费者下线 → 消息堆积、重新分配、不丢不重
消息重复与幂等
- 强制重复投递 → 验证业务处理幂等（如唯一 ID 去重）
- 网络重传、客户端重试场景下重复率控制
四、高可用与容错测试（集群稳定性）
核心目标：节点故障不影响服务、自动故障转移、数据一致。
集群故障
- 单 Broker 宕机 → 主从切换、选举、服务恢复、消息不丢
- 多节点宕机、网络分区（脑裂）→ 一致性、可用性验证
- 扩容 / 缩容 → 负载均衡、吞吐量线性、数据重平衡
网络异常
- 断网、延迟、丢包、限流 → 重连、消息不丢、积压可控
恢复验证
- 故障恢复时间（RTO）、数据一致性（RPO）
- 同步 / 异步复制、ISR（Kafka）、镜像队列（RabbitMQ）有效性
五、安全性测试
- 认证：账号 / 密码、SSL/TLS、Kerberos、ACL 权限控制
- 授权：生产 / 消费 / 管理权限隔离、越权访问阻断
- 传输加密：链路加密、消息内容加密
- 审计：操作日志、消息轨迹、敏感数据脱敏
六、可观测性与监控验证
- 监控指标：队列深度、生产 / 消费速率、堆积量、延迟、错误率、连接数
- 告警：堆积阈值、消费停滞、Broker 宕机、磁盘 / CPU 高水位
- 日志与追踪：全链路日志、消息 ID 追踪、生产 - 存储 - 消费时序
七、典型测试流程（通用）
环境准备
- 复刻生产配置：版本、集群规模、磁盘、网络、JVM / 内核参数
- 监控部署：Prometheus+Grafana、云监控、日志系统（ELK）
用例设计
- 功能：正向 + 反向（非法参数、权限、不存在队列）
- 性能：基准、峰值、混合、长时间稳定性（72h+）
- 可靠性：故障注入（kill、断网、宕机、异常）
- 高可用：主从切换、扩缩容、故障转移
执行与数据比对
- 消息唯一 ID：生产总数 = 消费总数 + 死信总数 + 未消费
- 丢失率 = 0、重复率≤业务阈值（如 0.001%）
- 性能：吞吐量达标、P99 延迟≤阈值、资源≤70%（稳定）
工具推荐
- 压测：JMeter、Locust、k6、厂商自带压测工具
- 故障注入：ChaosMesh、Pumba、简单脚本（kill/iptables）
- 监控：Prometheus、Grafana、云厂商 MQ 监控、OpenTelemetry
八、常见验收标准（参考）
- 功能：用例通过率 100%
- 性能：达到需求 120%、P99 延迟 < 200ms、CPU<70%
- 可靠性：丢失率 = 0、重复率 < 0.001%
- 高可用：单节点故障 < 30s 恢复、无服务中断
- 稳定性：72 小时压测无 OOM、无宕机、无消息异常