RabbitMQ核心概念及工作流程 + AMQP

devtools/2025/2/15 21:43:46/

文章目录

  • 一. RabbitMQ核心概念
    • 1. Producer, Consumer, Broker
    • 2. Connection和Channel
    • 3. Virtual host
    • 4. Queue
    • 5. Exchange
  • 二. RabbitMQ的工作流程
  • 三. AMQP
  • 四. web界面操作
    • 对用户操作
    • 对虚拟机操作

一. RabbitMQ核心概念

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

1. Producer, Consumer, Broker

  • Producer: ⽣产者, 是RabbitMQ Server的客⼾端, 向RabbitMQ发送消息
  • Consumer: 消费者, 也是RabbitMQ Server的客⼾端, 从RabbitMQ接收消息
  • Broker:其实就是RabbitMQ Server, 主要是接收和收发消息
    在这里插入图片描述
    在这里插入图片描述

2. Connection和Channel

  • Connection: 连接. 是客⼾端和RabbitMQ服务器之间的⼀个TCP连接. 这个连接是建⽴消息传递的基础, 它负责传输客⼾端和服务器之间的所有数据和控制信息.
  • Channel: 通道, 信道. Channel是在Connection之上的⼀个抽象层. 在 RabbitMQ 中, ⼀个TCP连接可以有多个Channel, 每个Channel 都是独⽴的虚拟连接. 消息的发送和接收都是基于 Channel的.

通道的主要作⽤是将消息的读写操作复⽤到同⼀个TCP连接上,这样可以减少建⽴和关闭连接的开销,
提⾼性能.
在这里插入图片描述

3. Virtual host

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

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

4. Queue

  • Queue: 队列, 是RabbitMQ的内部对象, ⽤于存储消息.在这里插入图片描述
    多个消费者, 可以订阅同⼀个队列
    在这里插入图片描述

5. Exchange

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

类似于发快递之后, 物流公司怎么处理呢, 根据咱们的地址来分派这个快递到不同的站点, 然后再送到
收件⼈⼿⾥. 这个分配的⼯作,就是交换机来做的
在这里插入图片描述

二. RabbitMQ的工作流程

在这里插入图片描述

  1. Producer ⽣产了⼀条消息
  2. Producer 连接到RabbitMQBroker, 建⽴⼀个连接(Connection),开启⼀个信道(Channel)
  3. Producer 声明⼀个交换机(Exchange), 路由消息
  4. Producer 声明⼀个队列(Queue), 存放信息
  5. Producer 发送消息⾄RabbitMQ Broker
  6. RabbitMQ Broker 接收消息, 并存⼊相应的队列(Queue)中, 如果未找到相应的队列, 则根据⽣产者的配置, 选择丢弃或者退回给⽣产者.

如果我们把RabbitMQ⽐作⼀个物流公司,那么它的⼀些核⼼概念可以这样理解:

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

三. AMQP

AMQP(Advanced Message Queuing Protocol)是⼀种⾼级消息队列协议, AMQP定义了⼀套确定的消息交换功能, 包括交换器(Exchange), 队列(Queue) 等. 这些组件共同⼯作, 使得⽣产者能够将消息发送到交换器. 然后由队列接收并等待消费者接收. AMQP还定义了⼀个⽹络协议, 允许客⼾端应⽤通过该协议与消息代理和AMQP模型进⾏交互通信

RabbitMQ是遵从AMQP协议的,换句话说,RabbitMQ就是AMQP协议的Erlang的实现(当然RabbitMQ还⽀持STOMP2, MQTT2等协议). AMQP的模型结构和RabbitMQ的模型结构是⼀样的.
在这里插入图片描述

四. web界面操作

对用户操作

  1. 添加用户
    在这里插入图片描述
  2. 删除用户
    点击用户名
    在这里插入图片描述
    在这里插入图片描述
  3. 对虚拟机的权限操作
    在这里插入图片描述
  4. 退出当前用户
    在这里插入图片描述

对虚拟机操作

  1. 创建虚拟主机
    在这里插入图片描述
  2. 删除虚拟机
    在这里插入图片描述
    在这里插入图片描述
  3. 修改用户权限
    在这里插入图片描述

http://www.ppmy.cn/devtools/140686.html

相关文章

海选女主角

Description 光头强虽然很喜欢教书,但是迫于生活压力,不得不想办法在业余时间挣点外快以养家糊口。 “做什么比较挣钱呢?筛沙子没力气,看大门又不够帅...”光头强老师很是无奈。 “冯小刚比你还难看,现在多有钱呀&a…

uniapp微信小程序任意图片铺满, 超出下滑

uniapp微信小程序任意图片铺满, 超出下滑 直接上代码 <template><scroll-view scroll-y"true" class"rule-box"><img :src"img" mode"widthFix" class"rule-img"></scroll-view> </template&g…

第十六届蓝桥杯模拟赛(第一期)-Python

本次模拟赛我认为涉及到的知识点&#xff1a; 分解质因数 Python的datetime库 位运算 简单dp 1、填空题 【问题描述】 如果一个数 p 是个质数&#xff0c;同时又是整数 a 的约数&#xff0c;则 p 称为 a 的一个质因数。 请问 2024 有多少个质因数。 【答案提交】 这是一道结…

聚簇索引与非聚簇索引

目录 一、聚簇索引&#xff08;Clustered Index&#xff09; 二、非聚簇索引&#xff08;Non-Clustered Index&#xff09; 三、示例说明 一、聚簇索引&#xff08;Clustered Index&#xff09; 定义&#xff1a; 聚簇索引是一种将数据存储和索引合为一体的索引方式。 表中…

TTC模型(1D和2D)理论推导及python实现

目录 第一部分:TTC模型理论背景与应用场景1.1 什么是TTC?1.2 为什么需要TTC?1.3 应用场景第二部分:TTC模型理论推导(1D 和 2D)2.1 1D模型推导距离公式2.2 2D模型推导相对位置与速度第三部分:Python实现:TTC模型计算(面向对象设计)3.1 Python实现的一维TTC代码实现3.2…

C++平常学习用的

4.1 友元函数 4.2 友元类 5.2 类模板 7.2 虚函数dynamic_cast运算 7.2 纯虚函数和抽象类

webpack 题目

文章目录 webpack 中 chunkHash 和 contentHash 的区别loader和plugin的区别&#xff1f;webpack 处理 image 是用哪个 loader&#xff0c;限制 image 大小的是...&#xff1b;webpack 如何优化打包速度 webpack 中 chunkHash 和 contentHash 的区别 主要从四方面来讲一下区别&…

Nginx配置中server_name参数未生效的问题解决

天行健&#xff0c;君子以自强不息&#xff1b;地势坤&#xff0c;君子以厚德载物。 每个人都有惰性&#xff0c;但不断学习是好好生活的根本&#xff0c;共勉&#xff01; 文章均为学习整理笔记&#xff0c;分享记录为主&#xff0c;如有错误请指正&#xff0c;共同学习进步。…