RabbitMQ 是一个开源的消息代理中间件，它使用高级消息队列协议（AMQP, Advanced Message Queuing Protocol）来实现不同系统之间的消息传递。它以 Erlang 语言编写，具有高可靠性、灵活性和易于扩展的特点，被广泛应用于异步通信、数据流处理等场景。
官网地址：https://www.rabbitmq.com/
1. RabbitMQ 的核心组件
在 RabbitMQ 中，主要有以下几个核心组件：
-
Producer（生产者）： 负责发送消息的应用程序或系统。生产者将消息发送到指定的交换机。
-
Exchange（交换机）： 接收生产者的消息，并根据路由规则将消息转发到队列。交换机类型决定了消息的路由方式。主要的交换机类型有：
-
Direct Exchange（直连交换机）： 精确匹配路由键，将消息发送到指定的队列。
-
Fanout Exchange（扇形交换机）： 广播模式，将消息发送到绑定的所有队列。
-
Topic Exchange（主题交换机）： 根据通配符匹配路由键，将消息发送到相应的队列。
-
Headers Exchange（头交换机）： 根据消息头属性来匹配队列，使用不多。
-
-
Queue（队列）： 消息的存储区域，消费者从队列中获取消息。消息在队列中以 FIFO（先进先出）方式进行存储。
-
Binding（绑定）： 将交换机与队列连接起来，定义了交换机如何根据路由键将消息路由到队列。
-
Consumer（消费者）： 从队列中接收消息并进行处理的应用程序或服务。
-
Routing Key（路由键）： 生产者发送消息时，指定的一个标签，用于交换机确定将消息转发到哪个队列。
-
Virtual Host（虚拟主机）： 用于多租户隔离的逻辑分区，每个 Virtual Host 可以有自己的交换机、队列、绑定等。
-
Connection 和 Channel：
-
Connection（连接）： 指的是应用程序与 RabbitMQ Broker 的 TCP 连接。
-
Channel（信道）： 多个 Channel 可以复用同一个 Connection。通常建议每个线程使用一个独立的 Channel。
-
2. RabbitMQ 的工作流程
RabbitMQ 的消息流大致如下：
-
生产者将消息发送到交换机（Exchange）。
-
交换机根据消息的路由键和绑定规则，将消息分配到相应的队列（Queue）。
-
消费者从队列中获取消息并处理。
-
确认机制（ACK）： 消费者处理完消息后，发送确认。RabbitMQ 将确认的消息从队列中删除，确保消息不被重复消费。
3. 服务部署
基于Docker来安装RabbitMQ，使用下面的命令即可：
docker run \-e RABBITMQ_DEFAULT_USER=cyt\-e RABBITMQ_DEFAULT_PASS=123321 \-v mq-plugins:/plugins \--name mq \--hostname mq \-p 15672:15672 \-p 5672:5672 \--network cyt-net\-d \rabbitmq:3.8-management可以看到在安装命令中有两个映射的端口：
-
15672：RabbitMQ提供的管理控制台的端口
-
5672：RabbitMQ的消息发送处理接口
安装完成后，我们访问 http://ip:15672即可看到管理控制台。首次访问需要登录，默认的用户名和密码在配置文件中已经指定了。
4. 收发消息
4.1 交换机
管理控制台主页，打开Exchanges选项卡，可以看到已经存在很多交换机
点击任意交换机，即可进入交换机详情页面。
利用控制台中的publish message 发送一条消息
这里是由控制台模拟了生产者发送的消息。由于没有消费者存在，最终消息丢失了，这样说明交换机没有存储消息的能力。
4.2 队列
打开Queues选项卡，新建一个队列
此时，我们再次向amq.fanout交换机发送一条消息。会发现消息依然没有到达队列！！
怎么回事呢？
发送到交换机的消息，只会路由到与其绑定的队列，因此仅仅创建队列是不够的，我们还需要将其与交换机绑定。
4.3 绑定关系
点击Exchanges选项卡，点击amq.fanout交换机，进入交换机详情页，然后点击Bindings菜单，在表单中填写要绑定的队列名称
4.4 发送消息
再次回到exchange页面，找到刚刚绑定的amq.fanout，点击进入详情页，再次发送一条消息。
回到Queues页面，可以发现被绑定的队列中已经有一条消息了。
这个时候如果有消费者监听了MQ的队列，自然就能接收到消息了。
5. 数据隔离
5.1 用户管理
点击Admin选项卡，首先会看到RabbitMQ控制台的用户管理界面：
这里的用户都是RabbitMQ的管理或运维人员。目前只有安装RabbitMQ时添加的cyt这个用户。仔细观察用户表格中的字段，如下：
-
Name：cyt，也就是用户名 -
Tags：administrator，说明cyt用户是超级管理员，拥有所有权限 -
Can access virtual host：/，可以访问的virtual host，这里的/是默认的virtual host
对于小型企业而言，出于成本考虑，通常只会搭建一套MQ集群，公司内的多个不同项目同时使用。这个时候为了避免互相干扰， 我们会利用virtual host的隔离特性，将不同项目隔离。一般会做两件事情：
-
给每个项目创建独立的运维账号，将管理权限分离。
-
给每个项目创建不同的
virtual host，将每个项目的数据隔离。
比如，我们创建一个新的用户，命名为cyt123,发现此时cyt123用户没有任何virtual host的访问权限，下来需要进行授权。
5.2 virtual host
切换到刚刚创建的cyt123用户登录，然后点击Virtual Hosts菜单，进入virtual host管理页
可以看到目前只有一个默认的virtual host，名字为 /。
可以在该用户下创建一个单独的virtual host，而不是使用默认的/。
由于我们是登录cyt123账户后创建的virtual host，因此回到admin菜单，你会发现当前用户已经具备了对新建的这个virtual host的访问权限了。
此时，点击页面右上角的virtual host下拉菜单，切换virtual host为 刚刚创建的，然后就可以对这个virtual host下的交换机和队列进行操作。
这就是基于virtual host 的隔离效果。
