博客 信使之舞 之 RabbitMQ 核心概念

信使之舞 之 RabbitMQ 核心概念

   数栈君   发表于 2025-01-08 12:07  104  0

前言

后续使用云服务器上的服务器,来对rabbitmq 进行运行
我们需要先把云服务器上的 rabbitmq 服务启动起来
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/648a403186ca06bf231e59729e8b1139..png


一、RabbitMQ 核心概念

在安装完RabbitMQ之后, 我们接下来学习如何去使用RabbitMQ
在上一个篇幅, 我们讲了RabbitMQ的安装, 并安装了管理界面

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/894fb9d1ad93dbf497fa8d9b639dcd05..png


Overview —>Totals

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/e214bdb7145b13f93a084efdba8d643a..png


Overview —>Nodes

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/bf3827c536c8f984711b4688b159040f..png


Overview —>Ports and contexts

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/78d481d6774dfe6af3a4336e39700ef7..png


界面上的导航栏共分6部分, 这6部分分别是什么意思呢, 我们先看看RabbitMQ的工作流程

1、工作流程(生产者/消费者 模型)


http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/29438c060cdbb3f7db42729a618b1433..png

RabbitMQ是⼀个消息中间件, 也是⼀个⽣产者消费者模型. 它负责接收, 存储并转发消息.

消息传递的过程类似邮局.
当你要发送一个邮件时,你把你的邮件放到邮局,邮局接收邮件, 并通过邮递员送到收件人的手上.

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/93348146e821098a6f9bc10fc90d6470..png


按照这个逻辑, Producer 就类似邮件发件人. Consumer 就是收件人, RabbitMQ就类似于邮局

2、Producer 和 Consumer

Producer: 生产者, 是RabbitMQ Server的客户端, 向RabbitMQ发送消息
Consumer: 消费者, 也是RabbitMQ Server的客户端, 从RabbitMQ接收消息
Broker:其实就是RabbitMQ Server, 主要是接收和收发消息

生产者(Producer)创建消息, 然后发布到RabbitMQ中. 在实际应用中, 消息通常是⼀个带有⼀定业务逻辑结构的数据, 比如JSON字符串. 消息可以带有⼀定的标签, RabbitMQ会根据标签进行路由, 把消息发送给感兴趣的消费者(Consumer).
消费者(Consumer)连接到RabbitMQ服务器, 就可以消费消息了, 消费的过程中, 标签会被丢掉. 消费者只会收到消息, 并不知道消息的生产者是谁, 当然消费者也不需要知道.
对于RabbitMQ来说,⼀个RabbitMQ Broker可以简单地看作⼀个RabbitMQ服务节点, 或者RabbitMQ服务实例. 大多数情况下也可以将⼀个RabbitMQ Broker看作⼀台RabbitMQ服务器
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/858bcbe1dbaf9af4e8c78f3d43fdf678..png


3、Connection 和 Channel

Connection: 连接. 是客户端和RabbitMQ服务器之间的⼀个TCP连接. 这个连接是建⽴消息传递的基础, 它负责传输客户端和服务器之间的所有数据和控制信息.
Channel: 通道, 信道. Channel是在Connection之上的⼀个抽象层. 在 RabbitMQ 中, ⼀个TCP连接可以有多个 Channel, 每个Channel 都是独⽴的虚拟连接. 消息的发送和接收都是基于 Channel的.通道的主要作用是将消息的读写操作复用到同⼀个TCP连接上,这样可以减少建立和关闭连接的开销,提⾼性能.

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/4dcf150937ee12fddfd43cdb7bc992de..png


4、Virtual host

Virtual host: 虚拟主机. 这是⼀个虚拟概念. 它为消息队列提供了⼀种逻辑上的隔离机制. 对于RabbitMQ而言, ⼀个 BrokerServer 上可以存在多个 Virtual Host. 当多个不同的用户使用同⼀个RabbitMQ Server 提供的服务时,可以虚拟划分出多个 vhost,每个用户在自己的 vhost 创建exchange/queue 等

类似MySQL的"database", 是⼀个逻辑上的集合. ⼀个MySQL服务器可以有多个database.

5、Queue

Queue: 队列, 是RabbitMQ的内部对象, 用于存储消息.

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/9a5e8164496c12a43ee9f8f48cefee51..png


多个消费者, 可以订阅同⼀个队列
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/53d1e5ee3107d4104cf59090f7cc1f72..png



6、Exchange

Exchange: 交换机. message 到达 broker 的第⼀站, 它负责接收生产者发送的消息, 并根据特定的规则把这些消息路由到⼀个或多个Queue队列中.
Exchange起到了消息路由的作用,它根据类型和规则来确定如何转发接收到的消息

类似于发快递之后, 物流公司怎么处理呢, 根据咱们的地址来分派这个快递到不同的站点, 然后再送到收件人手里. 这个分配的工作,就是交换机来做的

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/49d79f77503c12d6e571288e101efe13..png


7、小结

  • Producer 生产了⼀条消息
  • Producer 连接到RabbitMQBroker,建⽴⼀个连接(Connection),开启⼀个信道(Channel)
  • Producer 声明⼀个交换机(Exchange), 路由消息
  • Producer 声明⼀个队列(Queue), 存放信息
  • Producer 发送消息⾄RabbitMQ Broker
  • RabbitMQ Broker 接收消息, 并存入相应的队列(Queue)中, 如果未找到相应的队列, 则根据生产者 的配置, 选择丢弃或者退回给生产者.
如果我们把RabbitMQ比作⼀个物流公司,那么它的⼀些核心概念可以这样理解:

  • Broker就类似整个物流公司的总部, 它负责协调和管理所有的物流站点, 确保包裹安全、高效地送达.
  • Virtual Host可以看作是物流公司为不同的客户或业务部门划分的独立运营中心. 每个运营中心都有自己的仓库(Queue), 分拣规则(Exchange)和运输路线(Connection和Channel), 这样可以确保不同客户的包裹处理不会相互⼲扰, 同时提供定制化的服务
  • Exchange就像是站点里的分拣中心. 当包裹到达时, 分拣中心会根据包裹上的标签来决定这个包裹应该送往哪个目的地(队列). 快递站点可能有不同类型的分拣中心, 有的按照具体地址分拣, 有的将包裹复制给多个收件人等.
  • Queue就是快递站点⾥的⼀个个仓库, ⽤来临时存放等待派送的包裹. 每个仓库都有⼀个或多个快递员(消费者)负责从仓库中取出包裹并派送给最终的收件人.
  • Connection就像是快递员与快递站点之间的通信线路. 快递员需要通过这个线路来接收派送任务(消息).
  • Channel就像是快递员在执⾏任务时使用的多个并行的通信线路. 这样,快递员可以同时处理多个包裹, 比如⼀边派送包裹, 一边接收新的包裹

二、AMQP

AMQP(Advanced Message Queuing Protocol)是⼀种高级消息队列协议, AMQP定义了⼀套确定的消息交换功能, 包括交换器(Exchange), 队列(Queue) 等. 这些组件共同⼯作, 使得生产者能够将消息发送到交换器. 然后由队列接收并等待消费者接收.
AMQP还定义了⼀个网络协议, 允许客户端应用通过该协议与消息代理和AMQP模型进行交互通信
RabbitMQ是遵从AMQP协议的,换句话说,RabbitMQ就是AMQP协议的Erlang的实现(当然RabbitMQ还支持STOMP2, MQTT2等协议). AMQP的模型结构和RabbitMQ的模型结构是⼀样的.

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/62718f3661e65d06d2069fec91bb3d5e..png


三、Web界面操作
RabbitMQ管理界⾯上的Connections,Channels, Exchange, Queues 就是和上面流程图的概念是⼀样的, Overview就是视图的意思, Admin是用户管理.
我们在操作RabbitMQ前, 需要先创建Virtual host
接下来看具体操作:

1、用户相关操作(添加用户)
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/6d74d5aa339f0d9d1f6a7047984f2f63..png


点击 Admin -> Add user

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/e736cc5f6a827424e058374554b8083e..png


设置账号密码及权限
①: 设置账号
②: 设置密码
③: 确认密码
④: 设置权限
添加完成后, 点击[Add user]
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/d4dc2cd06fa6b63fe235a1a1091f301c..png



观察用户是否添加成功

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/2623d62522df865a6204f52dffdbd1ff..png


2、点击要删除的用户, 查看用户详情
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/27c16c7562476af21e7fa8c1e3307a0e..png


3、在用户详情页面, 进行更新或删除操作
设置对虚拟机的操作权限
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/66c58eed176993e66a9c5ce73b09a790..png



更新/删除用户
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/b935305b62f03bdfc475b233a705406f..png



4、退出当前用户
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/50c5412b69c3b595bbea067fef922c03..png


5、创建虚拟主机

在Admin标签⻚下, 点击右侧 Virtual Hosts -> Add a new virtual host
设置虚拟主机名称
类似于 MySQL的database
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/0d4769559549b676fda841d39b0023d0..png



观察设置结果
此操作会为当前登录用户设置虚拟主机

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/f52ecb9cfc349fe80287033ef3c801d8..png


6、特性

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/67df0cc09460915d722df4faed7415ab..png

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/0d01aef382695344bb72f005c1dad81d..png

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/c1adcfe4cf0f040711b7fa3507541449..png


http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/5469a0c36c26020eac690e3c86a3fb6e..png



7、Connections

生产者和消费者使用的不是同一个连接
Connections 显示的是客户端的连接
客户端的连接 就包含 生产者和消费者 的连接

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/dfaa48cd9c91f9128ccc8620bd29601b..png

8、交换机


http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/09dda29d9495f2c4fbff79de3120a23c..png


四、小结

RabbitMQ的每一环节都如同一位舞者,协调一致地进行着信息的流转与传递。每一次消息的产生与消费,都是技术与艺术的完美融合,推动着现代分布式系统在这一舞台上翩翩起舞。

本文系转载,版权归原作者所有,如若侵权请联系我们进行删除!

《数据资产管理白皮书》下载地址:https://www.dtstack.com/resources/1073/?src=bbs

《行业指标体系白皮书》下载地址:https://www.dtstack.com/resources/1057/?src=bbs

《数据治理行业实践白皮书》下载地址:https://www.dtstack.com/resources/1001/?src=bbs

《数栈V6.0产品白皮书》下载地址:https://www.dtstack.com/resources/1004/?src=bbs

想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友,浏览袋鼠云官网:https://www.dtstack.com/?src=bbs

同时,欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」,交流最新开源技术信息,群号码:30537511,项目地址:https://github.com/DTStack

0条评论
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群