RabbitMQ快速入门（一）核心概念及web界面操作

港控/mmm° 2021-12-11 16:01 536阅读 0赞

这段时间在学习MQ相关的知识，因此在这里对学习过程进行一下记录。本文主要记录了RabbitMQ的相关概念；web界面创建交换器及队列的方法，并演示如何将交换器和队列进行绑定。

**目录**

1、相关概念

2、RabbitMQ的安装

3、RabbitMQ运行机制

4、如何使用web界面创建交换机及队列，并将队列和交换机绑定

--------------------

### 1、相关概念 ###

RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue Protocol)的开源实现。

核心概念：

*  **1.1 Message**

消息：由消息头和消息体组成。消息体是不透明的，消息头是由一系列可选择属性组成，这些属性包括routing-key(路由方法键）、priority(相对于其他消息的优先级)、delivery-mode（指出该消息可能需要持久性存储）等。

*  **1.2 Publisher**

消息的生产者，也是一个向交换器发布消息的客户端应用程序。

*  **1.3 Exchange**

交换器，用来接收生产者发送的消息，并将这些消息路由给服务器中的队列。Exchange由4中类型：direct(默认)、fanout、topic和headers,不同类型的Exchange转发消息的策略有区别。（下文有三种交换器的详细说明）

*  **1.4 Queue**

消息队列，用来保存消息直到发送给消费者。一个消息可投入一个或多个队列，消息一直在队列里面，等待消费者连接到这个队列将其取走。

*  **1.5 Binding**

绑定，用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则。Exchange和Queue之间可以是多对多的关系。

*  **1.6 Connection**

网络连接，比如一个TCP连接。

*  **1.7 Channel**

信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接，AMQP命令都是通过信道发出去的，不管是发布消息、订阅队列还是接受消息，这些动作都是通过信道完成。因为对于操作系统来说建立和销毁TCP都是昂贵的开销，所以引入信道的概念，以复用一条TCP连接。

*  **1.8 Consumer**

消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。

*  **1.9 Virtual Host**

虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质就是一个mini版的RabbitMQ服务器，拥有自己的队列、交换器、绑定和权限机制。vhost是AMQP概念的基础，必须在连接时指定，RabbitMQ默认的vhost是 / 。

*  **1.10 Broker**

表示消息队列服务器实体。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70][]

### 2、RabbitMQ的安装 ###

（省略，网上好多。。。）

### 3、RabbitMQ运行机制 ###

**3.1 AMQP中的消息路由**

AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别，AMQP 中增加了 **Exchange** 和 **Binding** 的角色。生产者把消息发布到 Exchange 上，消息最终到达队列并被消费者接收，而 Binding 决定交换器的消息应该发送到哪个队列。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 1][]

**3.2 Exchange类型**

**Exchange**分发消息时根据类型的不同分发策略有区别，目前共四种类型：**direct****、****fanout****、****topic****、****headers** 。headers 匹配 AMQP 消息的 header 而不是路由键， headers 交换器和 direct 交换器完全一致，但性能差很多，目前几乎用不到了，所以直接看另外三种类型：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 2][]

消息中的路由键（routing key）如果和 Binding 中的 binding key 一致， 交换器就将消息发到对应的队列中。路由键与队列名完全匹配，如果一个队列绑定到交换机要求路由键为“dog”，则只转

发 routing key 标记为“dog”的消息，不会转发“dog.puppy”，也不会转发“dog.guard”等等。**它是完全匹配、单播的模式。**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 3][]

每个发到 fanout 类型交换器的消息都会分到所有绑定的队列上去。fanout 交换器不处理路由键，只是简单的将队列绑定到交换器上，每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。**很像子网广播，每台子网内的主机都获得了一份复制的消息。fanout 类型转发消息是最快的。**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 4][]

topic 交换器通过模式匹配分配消息的路由键属性，将路由键和某个模式进行匹配，此时队列需要绑定到一个模式上。它将路由键和绑定键的字符串切分成单词，这些**单词之间用点隔开**。它同样也会识别两个通配符：符号“\#”和符号“\**”**。**\#**匹配**0**个或多个单词**，**\**匹配一个单词。

### 4、如何使用web界面创建交换机及队列，并将队列和交换机绑定 ###

首先访问http://localhost:15672 进行登录（默认的用户名和密码为guest）：

![2019070915450936.png][]

之后进入主界面：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 5][]

该界面中Admin中可以添加新的用户信息，在Exchange中可以创建不同种类的交换器并绑定队列，在Queues中可以创建队列。

在这里完成如下绑定，四个队列分别名为atguigu、atguigu.news、atguigu.emps、gulixueyuan.news，三个交换器分别为exchange.direct（direct类型）、exchange.fanout（fanout类型）、exchange.topic（topic类型）。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 6][]

**4.1 创建4个队列**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 7][]

**4.2 创建3种类型的交换器**  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 9][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 10][]

创建后如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 11][]

**4.3 创建binding**

首先将4个队列和exchange.direct交换器绑定，由于direct类型是完全匹配的，因此需要设置路由键，这里将路由键设置为各个队列的名称。操作如下图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 12][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 13][]

其他的同理，exchange.direct绑定的结果如下（要解绑，点击unbind）：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 14][]

其次将exchange.fanout和四个队列绑定，由于fanout是类似局域网广播，因此和它连接的队列都能接受到信息，它不需要设置路由键。结果如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 15][]

最后将exchange.topic和四个队列绑定，将atguigu、atguigu.emps、atguigu.news的路由键设置为**atguigu.\#,** 将atguigu.news和gulixueyuan.news的路由键设置为\***.news**, ***（\#匹配0个或多个单词，\*匹配一个单词）***，绑定结果如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 16][]

因此对于符合**\*.news**的消息，exchange.topic交换器会将此消息转发给atguigu.news和gulixueyuan.news队列。

对于符合**atguigu.\#**的消息,exchange.topic交换器会将此消息转发给atguigu、atguigu.news、atguigu.emps队列。

**4.4 测试**

直接点击exchange.direct，在Publish message区域发送消息：

routing key:指定路由键，exchange.direct交换器根据路由键将消息转发到对应的队列中。

delivery mode:消息是否持久存储

payload:消息体

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 17][]

下图可以看到exchange.direct转发给了atguigu队列。

![2019070916222096.png][]

点击atguigu,获取消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 18][]

再次查看消息被消费并从队列中删除：

![2019070916250913.png][]

直接点击exchange.fanout，在Publish message区域发送消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 19][]

![20190709162625224.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 20][]

exchange.fanout类似于广播，与它连接的队列均接受到了信息。

直接点击exchange.topic，在Publish message区域发送消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 21][]

![20190709163331419.png][]

exchange.topic将hello.news 转送到了 符合\*.news的队列中。

## ##

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70]: /images/20211211/83dba49222cc46f4930c493748e13493.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 1]: /images/20211211/040b14da3ba141eab55083c6fef998d6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 2]: /images/20211211/9b815c71e1bf4c2ea4133f8eae31e516.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 3]: /images/20211211/12e5fd3c89b9407ebdda2cc85345511d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 4]: /images/20211211/a6350c843b574a1f82eec8dd3838e920.png
[2019070915450936.png]: /images/20211211/43f1cf2833b44eda9238888c77cd1c92.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 5]: /images/20211211/baec047b57314c4ba287f6f58204b0ce.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 6]: /images/20211211/75ce190c120642d5a86d417e33bf34f7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 7]: /images/20211211/7ced9afc3729479aa7d37d6fd88bc81f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 8]: /images/20211211/2f410ecdc9e9434f8a15f37928de0122.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 9]: /images/20211211/f2f1b9a854f54641ba655f2f13b3d27e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 10]: /images/20211211/06192db918d04f9f94c48434fb03bc40.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 11]: /images/20211211/bb6b4841beb645819dca943b87e1b60f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 12]: /images/20211211/6ab91d1d59de41cbaac81d8bbea7f139.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 13]: /images/20211211/aa9bb9e8e82c4461bd6688402b9e4a95.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 14]: /images/20211211/3b506c78f3e24e729dba3844f1e24e7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 15]: /images/20211211/a7d7275bbc9f422b9741315382ccbca2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 16]: /images/20211211/160dc03cf49f485f8cb43201c27b7f99.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 17]: /images/20211211/166389e2f90e476a9ff3b4b939f17fe8.png
[2019070916222096.png]: /images/20211211/a4e75b9655404bcf86580524ef01d05f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 18]: /images/20211211/c539d96715aa4e2983019ee378dc5cb2.png
[2019070916250913.png]: /images/20211211/2f761a3aa3bf445780d7ae4d68f2f676.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 19]: /images/20211211/c9dc1ccb4412469a8b8d3870bda395d8.png
[20190709162625224.png]: /images/20211211/105725f119e645a0b2a47e33a9565d08.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 20]: /images/20211211/a24f379ef47d43a7bdaddf72fffa3634.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3VqaWFuX0xpdQ_size_16_color_FFFFFF_t_70 21]: /images/20211211/92310575388841d9890911ac6d78486f.png
[20190709163331419.png]: /images/20211211/95ee944a50a34ea98b1a1721bc6d3ce8.png