MQ面试题及答案.docx

MQ面试题及答案

什么是消息队列（MQ）？在实际项目中，你为什么会选择使用MQ？

答案：消息队列是一种中间件，用于在不同应用程序或组件之间传递消息。在实际项目中，使用MQ主要是为了解决系统间的耦合问题，让不同模块可以异步通信，提高系统的吞吐量。比如在电商订单系统中，下单后需要通知库存、支付、物流等多个系统，用MQ的话，订单系统只需把消息发给队列，其他系统自行去取，不用订单系统一个个调用，减少了系统间的依赖。

你了解哪些常见的MQ产品？它们各有什么特点？

答案：常见的有RabbitMQ、Kafka、RocketMQ等。RabbitMQ基于AMQP协议，功能丰富，部署和使用相对简单，适合中小规模的场景，但在高吞吐量方面稍弱。Kafka吞吐量非常高，适合处理大量日志、大数据场景，不过配置和维护相对复杂些。RocketMQ是阿里开源的，在高可用、高吞吐方面表现不错，适合分布式系统，对Java生态支持较好。

MQ中的消息持久化是什么意思？为什么需要做消息持久化？

答案：消息持久化就是把消息保存到磁盘上，而不是只存在内存里。这样一来，即使MQ服务器宕机重启，消息也不会丢失。如果不做持久化，服务器一挂，内存里的消息就没了，可能导致业务数据丢失，比如订单信息没传递到库存系统，就会出现超卖等问题。

如何处理MQ中的消息丢失问题？

答案：消息丢失可能发生在三个环节。生产者发送消息时，可能因为网络问题没发送成功，这时候可以用确认机制，让MQ收到消息后给生产者一个反馈，没收到就重发。MQ服务器本身，要开启消息持久化，把消息存到磁盘，同时做好集群备份。消费者这边，要等消息真正处理完成后再给MQ发送确认，不要一拿到消息就确认，不然处理过程中出错了，消息就丢了。

什么是消息的重复消费？怎么解决？

答案：消息重复消费就是同一条消息被消费者多次处理。可能是因为消费者处理完消息后，给MQ的确认消息没发成功，MQ以为没处理，就又把消息发过来了。解决办法可以在消费者端做幂等处理，比如给每条消息一个唯一ID，处理前先查一下这个ID是否已经处理过，处理过就直接跳过。

MQ的死信队列是什么？它有什么作用？

答案：死信队列是专门存放那些处理失败或者过期的消息的队列。当消息被多次消费还是处理失败，或者消息过期了没被消费，就会进入死信队列。这样可以避免这些有问题的消息一直占用正常队列，也方便我们后续排查问题，看看这些消息为什么处理不了。

在使用MQ时，如何保证消息的顺序性？

答案：要保证消息顺序，首先生产者要把需要按顺序处理的消息发到同一个队列里，因为一个队列里的消息是先进先出的。然后消费者这边，不要用多线程并发处理同一个队列的消息，或者确保多线程处理时能按顺序来。比如在处理订单状态变更的消息时，创建、支付、发货这些消息必须按顺序处理，就可以用一个队列，消费者单线程处理。

MQ集群有什么作用？你了解的MQ集群模式有哪些？

答案：MQ集群主要是为了提高可用性和吞吐量。单个MQ服务器可能会因为硬件故障等原因宕机，集群可以保证其中一台出问题了，其他服务器还能继续工作。另外，多个服务器可以分担消息处理压力，提高整体处理能力。像RabbitMQ有主从集群、镜像集群模式；Kafka是通过分区和副本机制实现集群。

如何监控MQ的运行状态？你会关注哪些指标？

答案：可以用MQ自带的监控工具，比如RabbitMQ的Management插件，能看到队列长度、消息发送接收速率等。也可以结合Prometheus、Grafana等工具做更全面的监控。关注的指标有队列中的消息堆积数量，如果堆积太多，可能说明消费者处理能力不够；还有消息的发送成功率、消费成功率，以及服务器的CPU、内存使用率等。

在项目中，如果MQ突然出现消息堆积严重的情况，你会怎么处理？

答案：首先要排查原因，看看是生产者发送消息太快，还是消费者处理太慢，或者消费者出了故障。如果是消费者处理慢，可以临时增加消费者的数量，比如多部署几台机器处理消息；如果消费者有故障，尽快修复故障让其恢复消费。同时，可以暂停一些非核心的生产者发送消息，优先处理堆积的消息。另外，检查消费者的处理逻辑，看看有没有可以优化的地方，提高处理效率。