RabbitMQ相关原理说明

小灰灰 2022-12-22 09:44 162阅读 0赞

### 1、重要术语 ###

*   Server(Broker):接收客户端连接，实现AMQP协议的消息队列和路由功能的进程；
 *   Virtual Host：虚拟主机的概念，类似权限控制组，一个Virtual Host里可以有多个Exchange和Queue。   
 *   Exchange:交换机，接收生产者发送的消息，并根据Routing Key将消息路由到服务器中的队列Queue。
 *   ExchangeType:交换机类型决定了路由消息行为，RabbitMQ中有三种类型Exchange，分别是fanout、direct、topic；
 *   Message Queue：消息队列，用于存储还未被消费者消费的消息；
 *   Message：由Header和body组成，Header是由生产者添加的各种属性的集合，包括Message是否被持久化、优先级是多少、由哪个Message Queue接收等；body是真正需要发送的数据内容；
 *  BindingKey：绑定关键字，将一个特定的Exchange和一个特定的Queue绑定起来。

### 2、图示 ###

结合第1中的术语描述，可以用几张图来描述各个元素的关系，在网上借来几个图，如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70 1][]

再上一张实际配置的：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70 2][]

## ##

### 3、RabbitMQ工作模式 ###

在 RabbitMQ 官网上提供了 6 中工作模式：简单模式、工作队列模式、发布/订阅模式、路由模式、主题模式 和 RPC 模式。

1）简单模式：  
也可以说是点对点模式，只涉及生产者、队列、消费者。生产者负责生产消息，将消息发送到队列中，消费者监听队列，队列有消息就进行消费。

2）工作队列模式：  
工作队列模式其实就是有多个消费者的简单模式。当有多个消费者时，消费者平均消费队列中的消息。

3）发布/订阅、4）路由模式、5）主题模式  
这三种模式就要用到Exchange了。具体可以看下面（4、Exchange的几种工作模式）说明，  
生产者不直接与队列交互，而是将消息发送到交换机中，再由交换机将消息发送到已绑定改交换机的队列中给消费者消费。

6）RPC 模式  
客户端发送一个请求消息然后服务器回复一个响应消息。为了收到一个响应，我们需要发送一个'回调'的请求的队列地址。

### 4、Exchange的工作模式 ###

常用的交换机类型有 3 种：fanout、direct、topic。

1）Direct--路由模式  
任何发送到Direct Exchange的消息都会被转发到RouteKey指定的Queue。  
这种模式下不需要将Exchange进行任何绑定(binding)操作。  
消息传递时需要一个“RouteKey”，可以简单的理解为要发送到的队列名字。  
如果vhost中不存在RouteKey中指定的队列名，则该消息会被抛弃。

2） Fanout--发布/订阅模式  
任何发送到Fanout Exchange的消息都会被转发到与该Exchange绑定(Binding)的所有Queue上。  
这种模式不需要RouteKey。  
这种模式需要提前将Exchange与Queue进行绑定，一个Exchange可以绑定多个Queue，一个Queue可以同多个Exchange进行绑定。  
如果接受到消息的Exchange没有与任何Queue绑定，则消息会被抛弃。

3）Topic--匹配订阅模式  
任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue上。  
就是每个队列都有其关心的主题，所有的消息都带有一个“标题”(RouteKey)，Exchange会将消息转发到所有关注主题能与RouteKey模糊匹配的队列。  
这种模式需要RouteKey，也许要提前绑定Exchange与Queue。  
在进行绑定时，要提供一个该队列关心的主题。  
.“\#”表示0个或若干个关键字，“\*”表示一个关键字。  
同样，如果Exchange没有发现能够与RouteKey匹配的Queue，则会抛弃此消息。

4） headers  
headers exchange主要通过发送的request message中的header进行匹配，其中匹配规则（x-match）又分为all和any，all代表必须所有的键值对匹配，any代表只要有一个键值对匹配即可。headers exchange的默认匹配规则（x-match）是any。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70]: /images/20221120/e6642899b48c43da9b93cdd08c9ba965.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70 1]: /images/20221120/8e21af2af71d4662ba18d64e9accd3c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Z0b3BxeA_size_16_color_FFFFFF_t_70 2]: /images/20221120/87394b547a2040899117147d2eeb72f5.png