4. MQ 消息队列测试怎么做
MQ，也就是消息队列，是中间件测试中非常重要的一类。很多业务为了提升性能、解耦系统、支持异步处理，会把一些操作放到消息队列里。例如下单后扣库存、支付后更新订单状态、发送短信通知、生成报表、同步搜索索引、发放优惠券，这些都可能通过 MQ 异步完成。测试如果只看接口立即返回，很容易漏掉后续异步链路的问题。
面试中问“MQ 消息队列测试怎么做”，不是让你背 RabbitMQ、Kafka、RocketMQ 的区别，而是看你是否理解异步业务怎么验证结果、消息是否发送、是否消费、失败是否重试、重复消息是否幂等、消息积压怎么发现、顺序和延迟是否符合要求。测试岗位回答 MQ，要围绕业务链路和最终结果来讲。
一、MQ 在项目中解决什么问题
MQ 常见作用包括：
- 系统解耦：订单服务不用直接调用所有下游服务；
- 异步处理：接口先返回，后续慢操作通过消息完成；
- 削峰填谷：高峰请求先进队列，消费者慢慢处理；
- 可靠通知：支付成功后通知订单、积分、优惠券等系统；
- 日志和数据同步：异步写报表、搜索索引、数据仓库。
对测试来说，MQ 意味着一个接口成功不代表整个业务完成。要验证异步结果。
二、MQ 测试核心关注点
1. 消息是否发送
业务操作后是否真的发送消息。比如支付成功后是否发送支付成功消息。
2. 消息是否被消费
消息进入队列后，下游消费者是否正常消费。
3. 消费结果是否正确
消费后订单状态、库存、积分、通知、报表是否更新。
4. 失败是否重试
消费者处理失败时，是否有重试机制、死信队列或补偿任务。
5. 重复消费是否幂等
同一条消息重复投递时，不能重复扣库存、重复发券、重复生成订单。
6. 顺序是否正确
某些业务要求消息顺序，比如订单状态不能先完成后取消。
7. 是否存在消息积压
消息发送快、消费慢时会积压，导致业务延迟。
三、MQ 测试基本流程
可以按这个链路验证：
触发业务操作 -> 产生消息 -> 消息进入队列 -> 消费者处理 -> 业务结果落库 -> 页面或接口展示
测试不能只看第一步接口返回成功，还要看最后业务结果是否完成。
例如支付成功：
- 调用支付回调；
- 检查支付成功消息是否产生；
- 消费者消费消息；
- 订单状态变为已支付；
- 支付流水写入；
- 库存状态更新；
- 用户收到通知。
四、项目场景：下单后异步扣库存
假设创建订单接口返回成功，但库存扣减通过 MQ 异步完成。
测试点：
- 创建订单后是否发送扣库存消息；
- 库存消费者是否消费；
- 库存是否正确扣减；
- 库存不足时如何处理；
- 消息重复时是否重复扣库存；
- 消费失败是否重试；
- 订单和库存状态是否最终一致。
如果接口返回成功，但库存一直不变，就要查消息是否发送或消费者是否异常。
五、项目场景：支付成功更新订单
支付成功后通常会异步通知订单服务。
测试点：
- 支付回调是否成功；
- 是否发送支付成功消息；
- 订单服务是否消费消息；
- 订单状态是否从待支付变为已支付；
- 重复回调是否幂等；
- 消费失败是否重试；
- 最终状态是否一致。
支付类 MQ 测试一定要关注重复消息和幂等，否则可能重复更新或重复发放权益。
六、如何验证消息发送和消费
测试可以通过多种方式验证：
- 查看业务数据库状态；
- 查看 MQ 控制台；
- 查看生产者日志；
- 查看消费者日志；
- 查看消息 topic、queue、tag；
- 查看消费 offset；
- 查看死信队列；
- 查看监控告警；
- 通过接口查询最终结果。
测试环境未必有 MQ 控制台权限，但至少可以通过日志和最终数据判断。
七、MQ 异常场景测试
1. 消费者停止
如果消费者停止，消息会积压。恢复消费者后，消息应继续被消费。
2. 消费失败
例如数据库异常导致消费失败，系统应重试或进入死信队列。
3. 重复消息
同一消息重复投递，业务应幂等处理。
4. 消息丢失
要关注生产者发送失败是否有日志、重试、事务消息或补偿机制。
5. 顺序错乱
订单状态类消息如果乱序，可能导致状态回退。
八、MQ 测试常见 Bug
- 接口成功但消息未发送；
- 消息发送了但消费者未消费；
- 消费成功但数据库没更新；
- 重复消息导致重复扣减；
- 消费失败没有重试；
- 消息积压导致业务延迟；
- 订单状态乱序；
- 死信队列无人处理；
- 日志缺少 messageId，难以追踪。
九、面试回答模板
如果面试官问“MQ 消息队列测试怎么做”，可以这样回答：
MQ 测试我会按异步链路来验证，不只看接口立即返回。一般会先触发业务操作，比如下单或支付成功，然后确认是否产生消息，消息是否进入正确 topic 或 queue，消费者是否消费，最终数据库和页面状态是否正确。测试点包括消息发送、消费成功、消费失败重试、重复消费幂等、消息积压、顺序性和死信队列。比如支付成功后，我会验证支付消息消费后订单状态是否变为已支付，重复回调或重复消息不会重复处理，消费者异常恢复后消息能继续消费。
十、常见追问
追问：怎么判断消息是否消费成功？
看消费者日志、MQ 控制台、消费 offset、数据库状态和业务接口最终结果。
追问：重复消费怎么测？
构造重复消息或重复回调，验证不会重复扣库存、重复发券、重复更新状态。
追问：消费失败怎么办？
看是否有重试、死信队列、补偿任务和告警机制。
追问：接口返回成功是否代表 MQ 链路成功？
不代表。接口成功只代表前置操作成功，异步消费结果还要单独验证。
十一、练习清单
- 画出一个 MQ 异步链路；
- 准备下单扣库存案例；
- 准备支付更新订单案例；
- 查看生产者日志；
- 查看消费者日志；
- 验证消费结果落库；
- 测重复消费；
- 测消费失败重试；
- 测消息积压；
- 准备 MQ 面试回答。
MQ 测试的核心是最终一致性和异常处理。测试不能只验证接口成功，而要验证消息从发送到消费再到业务结果的完整链路。
配套刷题：
