RabbitMQ 面试题

RabbitMQ routing 路由模式

消息生产者将消息发送给交换机按照路由判断,路由是字符串(info) 当前产生的消息携 带路由字符(对象的方法)，交换机根据路由的 key，只能匹配上路由 key 对应的消息队列, 对应的消费者才能消费消息。

根据业务功能定义路由字符串。

从系统的代码逻辑中获取对应的功能字符串,将消息任务扔到对应的队列中。

业务场景：error 通知、EXCEPTION、错误通知的功能、传统意义的错误通知、客户 通知、利用 key 路由，可以将程序中的错误封装成消息传入到消息队列中，开发者可以自 定义消费者，实时接收错误。

消息怎么路由？

消息提供方->路由->一至多个队列消息发布到交换器时，消息将拥有一个路由键 （routing key），在消息创建时设定。通过队列路由键，可以把队列绑定到交换器上。消 息到达交换器后，RabbitMQ 会将消息的路由键与队列的路由键进行匹配（针对不同的交

换器有不同的路由规则）。

常用的交换器主要分为一下三种：

• fanout：如果交换器收到消息，将会广播到所有绑定的队列上。

• direct：如果路由键完全匹配，消息就被投递到相应的队列。

• topic：可以使来自不同源头的消息能够到达同一个队列。 使用 topic 交换器时，可

以使用通配符。

RabbitMQ publish/subscribe 发布订阅(共享资源)

• 每个消费者监听自己的队列。

• 生产者将消息发给 broker，由交换机将消息转发到绑定此交换机的每个队列，每个绑

定交换机的队列都将接收到消息。

能够在地理上分开的不同数据中心使用 RabbitMQ cluster 么？

不能。

第一，你无法控制所创建的 queue 实际分布在 cluster 里的哪个 node 上（一般使用

HAProxy + cluster 模型时都是这样），这可能会导致各种跨地域访问时的常见问题。 第二，Erlang 的 OTP 通信框架对延迟的容忍度有限，这可能会触发各种超时，导致业务 疲于处理。

第三，在广域网上的连接失效问题将导致经典的“脑裂”问题，而 RabbitMQ 目前无法 处理（该问题主要是说 Mnesia）。

RabbitMQ 有那些基本概念？

• Broker：简单来说就是消息队列服务器实体。

• Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。

• Queue：消息队列载体，每个消息都会被投入到一个或多个队列。

• Binding：绑定，它的作用就是把 exchange 和 queue 按照路由规则绑定起来。

• Routing Key：路由关键字，exchange 根据这个关键字进行消息投递。

• VHost：vhost 可以理解为虚拟 broker ，即 mini-RabbitMQ server。其内部均含

有独立的 queue、exchange 和 binding 等，但最最重要的是，其拥有独立的权限 系统，可以做到 vhost 范围的用户控制。当然，从 RabbitMQ 的全局角度，vhost 可以作为不同权限隔离的手段（一个典型的例子就是不同的应用可以跑在不同的 vhost 中）。

• Producer：消息生产者，就是投递消息的程序。

• Consumer：消息消费者，就是接受消息的程序。

• Channel：消息通道，在客户端的每个连接里，可建立多个 channel，每个 channel

代表一个会话任务。

• 由 Exchange、Queue、RoutingKey 三个才能决定一个从 Exchange 到 Queue 的唯

一的线路。

什么情况下会出现 blackholed 问题？

blackholed 问题是指，向 exchange 投递了 message ，而由于各种原因导致该 message 丢失，但发送者却不知道。可导致 blackholed 的情况：1.向未绑定 queue 的 exchange 发送 message；2.exchange 以 binding_key key_A 绑定了 queue queue_A，但向该 exchange 发送 message 使用的 routing_key 却是 key_B。

什么是消费者 Consumer?

消费消息，也就是接收消息的一方。

消费者连接到 RabbitMQ 服务器，并订阅到队列上。消费消息时只消费消息体，丢弃标 签。

消息如何分发？

• 若该队列至少有一个消费者订阅，消息将以循环（round-robin）的方式发送给消费

者。每条消息只会分发给一个订阅的消费者（前提是消费者能够正常处理消息并进行 确认）。

• 通过路由可实现多消费的功能

Basic.Reject 的用法是什么？

该信令可用于 consumer 对收到的 message 进行 reject 。若在该信令中设置 requeue=true，则当 RabbitMQ server 收到该拒绝信令后，会将该 message 重新发 送到下一个处于 consume 状态的 consumer 处（理论上仍可能将该消息发送给当前 consumer）。若设置 requeue=false ，则 RabbitMQ server 在收到拒绝信令后，将直 接将该 message 从 queue 中移除。

另外一种移除 queue 中 message 的小技巧是，consumer 回复 Basic.Ack 但不对获 取到的 message 做任何处理。而 Basic.Nack 是对 Basic.Reject 的扩展，以支持一次 拒绝多条 message 的能力。

什么是 Binding 绑定？

通过绑定将交换器和队列关联起来，一般会指定一个 BindingKey,这样 RabbitMq 就知道 如何正确路由消息到队列了。