RabbitMQ面试题
RabbitMQ面试题
RabbitMQ是什么？它的主要特点是什么？
RabbitMQ是一个开源的消息中间件，实现了AMQP（高级消息队列协议）标准。它具有以下主要特点：
- 可靠性：RabbitMQ提供持久化消息和消息确认机制，确保消息的可靠传递。
- 灵活的路由：RabbitMQ支持灵活的消息路由和交换机类型，例如直连交换机、主题交换机、扇形交换机等。
- 高可用性：RabbitMQ可以通过设置集群和镜像队列来提供高可用性，以防止单点故障。
- 多种语言支持：RabbitMQ提供了多种编程语言的客户端库，使开发者能够使用各种编程语言与之交互。
RabbitMQ的消息发布和订阅模型是怎样的？
RabbitMQ使用发布和订阅模型。在该模型中，消息生产者将消息发送到交换机（exchange），而消费者则创建队列并将其绑定到交换机上以接收消息。交换机根据特定的路由规则将消息传递给队列，然后消费者从队列中获取消息进行处理。
RabbitMQ的消息确认机制是什么？为什么它很重要？
RabbitMQ的消息确认机制是指在消费者从队列中获取消息后，向RabbitMQ发送确认消息，告知RabbitMQ该消息已经被成功处理。这种机制可以确保消息的可靠传递，防止消息丢失。如果消费者在处理消息时发生错误，消息将保留在队列中，直到消费者确认处理成功。
RabbitMQ的消息持久化是如何实现的？为什么它重要？
RabbitMQ通过将消息和队列标记为持久化来实现消息的持久化。当消息和队列被标记为持久化后，它们将被写入磁盘，即使RabbitMQ服务器重启，消息也不会丢失。
RabbitMQ的交换机类型有哪些？它们之间有什么区别？
RabbitMQ支持多种交换机类型，包括直连交换机（Direct Exchange）、主题交换机（Topic Exchange）、扇形交换机（Fanout Exchange）和头交换机（Headers Exchange）。它们之间的区别如下：
- 直连交换机：通过完全匹配的路由键将消息路由到与之绑定的队列。
- 主题交换机：通过模式匹配的路由键将消息路由到与之匹配的队列。
- 扇形交换机：将消息广播到与之绑定的所有队列，忽略路由键。
- 头交换机：根据消息的头部属性来匹配路由键，而不是直接匹配路由键本身。
RabbitMQ的消息优先级是如何实现的？
RabbitMQ通过在消息的属性中设置优先级来实现消息优先级。较高优先级的消息将在队列中优先处理，以确保重要消息的及时处理。然而，需要注意的是，RabbitMQ并不保证严格按照优先级顺序进行消息处理。
RabbitMQ的集群是如何工作的？它提供了哪些优势？
RabbitMQ集群由多个节点组成，通过互相通信和数据同步来提供高可用性和负载均衡。集群中的节点可以共享队列、交换机和绑定信息，当一个节点故障时，其他节点可以接管其工作。RabbitMQ集群提供以下优势：
- 高可用性：当一个节点故障时，其他节点可以接管其工作，确保消息的可靠传递。
- 负载均衡：通过将队列和交换机分布在多个节点上，可以平衡消息的负载，提高系统的性能。
- 扩展性：可以通过添加更多的节点来扩展集群的处理能力，以满足高负载的需求。
RabbitMQ与其他消息队列系统（如Kafka）之间的区别是什么？
RabbitMQ和Kafka是两个不同的消息队列系统，它们有以下区别：
- 协议：RabbitMQ实现了AMQP协议，而Kafka使用自己的二进制协议。
- 消息传递模型：RabbitMQ使用发布和订阅模型，而Kafka使用发布和订阅的日志模型。
- 持久化：RabbitMQ可以将消息和队列标记为持久化，而Kafka将所有消息持久化到磁盘。
- 性能：Kafka在处理大量数据时具有更高的吞吐量和更低的延迟，适用于高吞吐量的场景。RabbitMQ更适合于强调可靠性和灵活路由的场景。
RabbitMQ的元数据是什么？
- Queue 元数据（queue 名字和属性等）
- Exchange 元数据（exchange 名字、类型和属性等）
- Binding 元数据（存放路由关系的查找表）
- Vhost 元数据（vhost 范围内针对前三者的名字空间约束和安全属性设置）。
RabbitMQ的信道？
由于 TCP 连接的创建和销毁开销较大，且并发数受系统资源限制，会造成性能瓶颈。RabbitMQ 使用信道的方式来传输数据。信道是建立在真实的 TCP 连接内的虚拟连接，且每条 TCP连接上的信道数量没有限制。
RabbitMQ如何确保消息接收方消费了消息？
RabbitMQ使用接收方消息确认机制来确保消息接收方消费了消息。
接收方消息确认机制：消费者接收每一条消息后都必须进行确认（消息接收和消息确认是两个不同操作）。只有消费者确认了消息，RabbitMQ 才能安全地把消息从队列中删除。
RabbitMQ如何避免消息重复投递或重复消费？
在消息生产时，MQ 内部针对每条生产者发送的消息生成一个消息id ，作为去重和幂等的依据（消息投递失败并重传），避免重复的消息进入队列
在消息消费时，要求消息体中必须要有一个业务Id（对于同一业务全局唯一，如支付ID、订单ID、帖子ID等）作为去重和幂等的依据，避免同一条消息被重复消费。
RabbitMQ如何保证消息的顺序性？
拆分多个queue，每个queue一个consumer。