【RabbitMQ】几个面试题

亦凉 2022-12-22 04:59 203阅读 0赞

## 一.RabbitMQ基本使用问题 ##

> 参考链接：
> 
>  *  [【消息队列】五个问题详解消息中间件][Link 1]
>  *  [【RabbitMQ】基本特性、工作模型、路由方式][RabbitMQ]

**1.消息队列的作用与使用场景？**

异步、解耦、削峰 + 具体应用场景。

**2.Channel和vhost的作用是什么？**

*  Channel：减少TCP资源的消耗。也是最重要的编程接口。
 *  Vhost：提高硬件资源利用率，实现资源隔离。

**3.RabbitMQ的消息有哪些路由方式？适合在什么业务场景使用？**

Direct、Topic、Fanout

**4.交换机与队列、队列与消费者的绑定关系是什么样的？**

多对多

## 二.RabbitMQ高级特性问题 ##

> 参考链接：
> 
>  *  [【RabbitMQ】原理分析：如何保证消息可靠性投递？][RabbitMQ 1]
>  *  [【RabbitMQ】高级使用：消息过期设置、死信队列、延迟队列、流控][RabbitMQ 2]
>  *  [【RabbitMQ】基本使用：Java操作RabbitMQ–Spring AMQP核心组件解析][RabbitMQ_Java_RabbitMQ_Spring AMQP]
>  *  [【RabbitMQ】高级使用：补偿机制、消息幂等性、最终一致性、消息顺序性][RabbitMQ 3]

**5.多个消费者监听一个队列时（比如一个服务部署多个实例），消息会重复消费吗？**

队列中的消息会被平均**分摊**(轮询)给多个消费者进行处理，而不是每个消费者都收到所有的消息。RabbitMQ不支持队列层面的广播消费，如果需要广播消费，需要在其上进行二次开发，处理起来异常复杂。

注：这点kafka与rabbitmq不同，kafka只要Consumer有不同的groupId，那么就可以重复消费同一topic下的消息

**6.无法被路由的消息，去了哪里？**

*  直接丢弃
 *  回发
 *  可用备份交换机（alternate-exchange）接收

**7.消息在什么时候会变成 Dead Letter（死信）**

*  消息过期；
 *  消息超过队列长度或容量；
 *  消息被拒绝并且未设置重回队列

**8.如果一个项目要从多个服务器接收消息，怎么做？如果一个项目要发送消息到多个服务器，怎么做？**

定义多个ConnectionFactory，注入到消费者监听类/Temaplate。

**9.RabbitMQ如何实现延迟队列？**

*  基于数据库+定时任务；
 *  或者消息过期+死信队列；
 *  或者延迟队列插件。

**10.哪些情况会导致消息丢失？怎么解决？哪些情况会导致消息重复？怎么解决？**

**11. 一个队列最多可以存放多少条消息？**

由硬件决定。

**12.可以用队列的x-max-length最大消息数来实现限流吗？例如秒杀场景。**

不能，因为会删除先入队的消息，不公平。

**13.如何提高消息的消费速率？**

创建多个消费者。

**14.AmqpTemplate和RabbitTemplate的区别？**

Spring AMQP是Spring整合AMQP的一个抽象。Spring-Rabbit是一个实现

**15.如何动态地创建消费者监听队列？**

通过ListenerContainer

container.setQueues(getSecondQueue(),getThirdQueue());//监听的队列

**16.Spring AMQP中消息怎么封装？用什么转换？**

Message，MessageConvertor

**17. 如何保证消息的顺序性？**

一个队列只有一个消费者

## 三.RabbitMQ集群相关问题 ##

> 参考链接：
> 
>  *  [【RabbitMQ】高级使用：集群及haproxy+keepalived高可用负载均衡][RabbitMQ_haproxy_keepalived]

**18.如何保证RabbitMQ的高可用？**

HAProxy（LVS）+Keepalived

**19. RabbitMQ的集群节点类型？**

磁盘节点和内存节点

**20.大量消息堆积怎么办？**

*  重启（不是开玩笑的）
 *  多创建几个消费者同时消费
 *  直接清空队列，重发消息

## 四.消息队列开放问题 ##

> 参考链接：
> 
>  *  [【消息队列】五个问题详解消息中间件][Link 1]
>  *  [【Kafka】是什么？应用场景？架构？][Kafka]
>  *  [【RabbitMQ】基本特性、工作模型、路由方式][RabbitMQ]

**21.MQ选型分析？**

1.  使用和管理
    
     *  API、与Spring集成
     *  管理控制台，权限、安全、监控
     *  扩展性
     *  社区支持
2.  性能
    
     *  并发性
     *  消息吞吐量
     *  消息堆积能力，即堆积多少消息后，仍然能正常提供服务
3.  功能
    
     *  事务性消息
     *  顺序性消息
     *  消息重试
     *  死信队列
     *  优先级队列
     *  延迟队列
4.  可靠+可用
    
     *  集群
     *  持久化
     *  消息同步

**22.设计一个MQ，你的思路是什么？**

MQ实际上就是做了一个存储并转发的工作

*  存储
    
     *  内存：用什么数据结构？
     *  磁盘：文件系统？数据库？
 *  转发（通信）
    
     *  通信协议（TCP HTTP AMQP ）？
     *  一对一？一对多？
     *  推模式？拉模式？
 *  其他特性……

[Link 1]: https://blog.csdn.net/weixin_43935927/article/details/109661259
[RabbitMQ]: https://blog.csdn.net/weixin_43935927/article/details/109712002
[RabbitMQ 1]: https://blog.csdn.net/weixin_43935927/article/details/109742645
[RabbitMQ 2]: https://blog.csdn.net/weixin_43935927/article/details/109731396
[RabbitMQ_Java_RabbitMQ_Spring AMQP]: https://blog.csdn.net/weixin_43935927/article/details/109737660
[RabbitMQ 3]: https://blog.csdn.net/weixin_43935927/article/details/109749429
[RabbitMQ_haproxy_keepalived]: https://blog.csdn.net/weixin_43935927/article/details/109741937
[Kafka]: https://blog.csdn.net/weixin_43935927/article/details/109691566