IT评测·应用市场-qidao123.com
标题:
RabbitMQ — 异步调用
[打印本页]
作者:
温锦文欧普厨电及净水器总代理
时间:
2024-11-9 09:23
标题:
RabbitMQ — 异步调用
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 的隔离效果。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/)
Powered by Discuz! X3.4
