这里先演示最简单的模型：直连模式。其结构图为：

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudye3635c40-e7db-40b7-a8ec-cba48c9215ac.png)

一个生产者 -> 消息队列 -> 一个消费者

生产者只需要将数据丢进消息队列，而消费者只需要将数据从消息队列中取出，这样就实现了生产者和消费者的消息交互。

1. 创建一个新的实验环境，即新建一个Virtual Host。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy1f29c750-cb47-4e1b-95aa-42469986760f.png)
2. 添加新的虚拟主机之后，我们可以看到，当前admin用户的主机访问权限中新增了刚刚添加的环境。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy6316ca37-e782-4b77-b4c2-187bfaa626c3.png)
3. 查看交换机。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudyb2d6cc09-9f35-4c5f-bdf5-c8c82af5035c.png)

交换机列表中自动新增了刚刚创建好的虚拟主机相关的预设交换机，一共7个。

这里首先介绍一下前面两个`direct`类型的交换机，一个是`(AMQP default)`还有一个是`amq.direct`，它们都是直连模式的交换机。

- 单击`(AMQP default)`进入详情。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudyed04d228-9e0e-414f-a38c-99950ce215d6.png)

- `(AMQP default)`是所有虚拟主机都会自带的一个默认交换机。
        - 此交换机默认绑定到所有的消息队列。

如果是通过默认交换机发送消息，会根据消息的`routingKey`（发消息时指定）决定发送给哪个同名的消息队列，同时也不能显式地将消息队列绑定或解绑到此交换机。
        - 此交换机不可删除。

可以看到，详细信息中，特征（Features）项为：`durable:true`，表明当前交换机特性是持久化的，也就是说就算机器重启，此交换机也会保留；如果不是持久化，那么一旦重启就会消失。

在列表中看到`D`的字样，就表示此交换机是持久化的。

> 所有自动生成的交换机都是持久化的。
    - 单击`amq.direct`进入详情。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy48b055a6-d18d-4b8e-b667-021e15c95207.png)

这个交换机和默认交换机类型一致，并且也是持久化的。

但是可以看到它是具有绑定关系的，如果没有指定的消息队列绑定到此交换机上，那么这个交换机无法正常将信息存放到指定的消息队列中，也是根据`routingKey`寻找消息队列（可以自定义）。
4. 查看消息队列。目前没有消息队列，所以需要创建一个。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy64ed785b-bf41-4d16-9581-c812ebb7bd2b.png)

- Virtual host：虚拟主机。这里选择自建的，在这个虚拟主机下创建此消息队列。
    - Type：类型。选择`Classic`，也就是经典类型。
    - Name：名称。可以随便取，这里取test。
    - Durability：持久化。这里选择Durable，即持久的。
    - Auto delete：自动删除。这里选择`No`，如果选`Yes`，即代表需要至少有一个消费者连接到这个队列，一旦所有与这个队列连接的消费者都断开时，就会自动删除此队列。
    - Arguments：参数。暂时不用设置。
5. 点击创建的消息队列名称，可查看详情。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy59d79cfd-ef1b-4668-bf36-c09c0b70c970.png)

详细信息中包括队列的当前负载状态、属性、消息队列占用的内存，消息数量等。

从绑定信息可以发现，该队列默认绑定了交换机，就是前面介绍的`(AMQP default)`默认交换机。

现在需要将此消息队列绑定到`amq.direct`，这样就可以通过此交换机向此消息队列发送消息了：

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy9804dd0e-e8bd-4320-90af-dca531b51b18.png)
6. 回到交换机。这里也显示了与队列的绑定关系。

向该消息队列中发送一条消息：

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy5c64e3dc-412b-4b89-a936-926c54adb17d.png)
7. 回到队列。

可以看到已经有一条消息了：

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudyecbad92c-a48c-48cd-a5c2-f41f6fe59509.png)
8. 获取消息。

选择Get messages，可以获取消息：

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy670fd55c-d043-4c31-8ad2-27df359db99c.png)

- Ack Mode：接收消息的模式。有4种，分别为：
        - `Nack message requeue true`：获取到消息的内容；不会去消费消息。
        - `Automatic ack`：获取到消息的内容；会去消费消息。
        - `Reject requeue true`：拒绝获取消息；消息重新入队。
        - `Reject requeue false`：拒绝获取消息；消息不重新入队，将会被删除。

这里使用默认的即第1种就可以了，这样只会查看消息，但是不会取出，消息依然存在于消息队列中。
    - Encoding：编码格式。使用默认的就可以。
    - Messages：要生效的操作数量。选择1就行。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy92cf420f-a4dc-4841-a63b-021ad0cb1e51.png)

消息已经成功读取到。
9. 除了在交换机发送消息给消息队列之外，也可以直接在消息队列这里发。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy1418ff89-919c-4402-9251-9e2354328f32.png)

- Delivery mode：推送方式。
        - Non-persistent：不持久化。如果服务器重启，此消息删除。
        - Persistent：持久化。如果服务器重启，此消息依然存在。
    - Headers：头部信息。
    - Properties：属性。
    - Payload：载荷的消息。
10. 如果不需要再使用此消息队列了，可以手动对其进行删除或是清空。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2023/03/23/kuangstudy70e53b1a-e0eb-4160-9833-56e45afcb524.png)

---

- 环境
    - Ubuntu 22.04
    - RabbitMQ 3.11.10
    - Erlang 25.3

RabbitMQ 03 直连模式-可视化界面

总共已有 0 条评论