3.RabbitMQ 架构以及 通信方式

news/2024/6/16 18:09:02 标签: rabbitmq, 架构, 分布式

一、RabbitMQ的架构

RabbitMQ的架构可以查看官方地址
在这里插入图片描述
在这里插入图片描述
可以看出RabbitMQ中主要分为三个角色:

  • Publisher:消息的发布者,将消息发布到RabbitMQ中的Exchange
  • RabbitMQ服务:Exchange接收Publisher的消息,并且根据Routes策略将消息转发到Queue中
  • Consumer:消息的消费者,监听Queue中的消息并进行消费
  • Routes:就是我们下面说的 Routing Key

RabbitMQ发送消息的策略是,消息到达Exchange,然后根据 RoutingKey 去配置到 Queue,然后消费者监听queue来完成消费

二、AMQP概念

RabbitMq是基于AMQP协议的。

1.什么是AMQP协议

在这里插入图片描述

  1. server:又称Broker,接收客户端连接,实现AMQP实体服务
  2. Connection: 连接,应用程序与Broker的网络连接
  3. Channel:网络信道,几乎所有的操作都在Channel中进行,Channel是进行消息读写的通道。客户端可建立多个Channel,每个Channel代表一个会话任务。
  4. Virtual Host :虚拟地址,用于进行逻辑隔离,最上层的消息路由。一个Virtual host里面可以有若干个Exchange和Queue,同一个Virtual host 里面不能有相同名称的Exchange或Queue,可以理解为 Mysql中的 db概念,不同的用户可以管理不同的 Virtual Host,默认是 / 目录,也可以在 管理页面上 创建 Virtual Host 并指定给相应的用户,或者在命令行中创建和设置用户。
  5. ExChange:交换机,接收消息,根据路由键转发消息到绑定的队列
  6. Binding:Exchange和Queue之间的虚拟连接,binding中可以包含routing key(路由键)
  7. Routing key:一个路由规则,虚拟机可用它来确定如何路由一个特定消息
  8. Queue:也称为Message Queue,消息队列,保存消息并将它们转发给消费者
  9. Message:消息,服务器和应用程序之间传送的数据,由Properties和Body组成,Properties可以对消息进行修饰,比如消息的优先级、延迟等高级特性;Body则就是消息体内容

二、ExChange详解

  1. Name:交换机名称
  2. Type:RabbitMQ中交换机的类型有 direct(直接) 、topic(主题)、fanout(广播)、headers(标题)
  3. Durability:交换机是否需要持久化,true为持久化。
  4. Auto Delete:当最好一个绑定到Exchange上的队列删除后,自动删除Exchange。
  5. Internal:当前Exchange是否用于RabbitMQ内部使用,默认False
  6. Arguments:扩展参数,用户扩展AMQP协议自制定化使用

三、Queue详解

  1. name:队列的名称
  2. durable:是否是持久化队列
  3. autoDelete:当最后一个消息不在了,是否自动删除队列,默认false。

三、RabbitMQ通讯的方式

RabbitMQ通讯方式 是依赖于 Exchange的类型的。

3.1 direct类型交换机

所有发送到Direct Exchange的消息被转发到RouteKey中指定的Queue

注意:Direct模式可以使用RabbitMQ自带的Exchange:default Exchange,所以不需要将Exchange进行任何绑定操作,消息传递时,RouteKey必须完全匹配才会被队列接收,否则该消息会被抛弃

注意:Direct模式可以使用RabbitMQ自带的Exchange:default
Exchange,所以不需要将Exchange进行任何绑定操作,消息传递时,RouteKey必须完全匹配才会被队列接收,否则该消息会被抛弃

在这里插入图片描述

3.2 fanout类型交换机

  1. 不处理Routing Key,只需要简单的将队列绑定到交换机上
  2. 发送到交换机的消息都会被转发到与该交换机绑定的所有队列上
  3. Fanout交换机转发消息是最快的
    在这里插入图片描述

3.3 topic类型交换机

所有发送到Topic Exchange的消息被转发到所有关心RouteKey中指定Topic的Queue上

Exchange将RouteKey和某个Topic进行模糊匹配,此时队列需要绑定一个Topic

注意:可以使用通配符进行模糊匹配

  • 符号 # 匹配一个或多个词
  • 符号 * 只匹配一个词
  • 例如:log.# 能够匹配到 log.info.a、log.info.c、log.info
  • log.* 只能匹配到 log.info 。

在这里插入图片描述

3.4 headers类型交换机

上面的三种都是通过 Routing Key来进行匹配的,而headers是通过消息的header来进行匹配的。
在这里插入图片描述
headers头部的 x-match 参数是 必须的,如果x-match设置的是all,那么生产者在生产消息时必须满足设置的headers条件,
我上面设置的是 x-match=all ,name=jack,age=23,那么我想发送消息到这个队列里面,那么消息头必须要有 name=jack,age=23。
如果我设置的是 x-match=any ,那么我满足其中一个条件就好了,比如上面是 name = jack,age= 23,那么我消息头带其中的一个就可以了,也就是他们两个的任意一个。
如果不满足的话,消息无法到达exchange绑定的queue中。


http://www.niftyadmin.cn/n/4968407.html

相关文章

uniapp 微信小程序:RecorderManager 录音DEMO

uniapp 微信小程序:RecorderManager 录音DEMO 简介index.vue参考资料 简介 使用 RecorderManager 实现录音。及相关的基本操作。(获取文件信息,上传文件) 此图包含Demo中用于上传测试的服务端程序upload.exe,下载后用…

详解numpy.random.shuffle函数

文章目录 函数原型参数解析该函数的注意事项例子示例代码示例结果 参考 numpy的random模块中的shuffle函数用于np.ndarray数组中的元素打乱顺序,进打乱多维数组的第一维顺序。本博客详细节将该函数的API,并给出示例代码和结果。 函数原型 random.shuff…

docker学习(1)

1、容器与虚拟机的对比: 虚拟机(virtual machine)就是带环境安装的一种解决方案。 它可以在一种操作系统里面运行另一种操作系统,比如在Windows10系统里面运行Linux系统CentOS7。 应用程序对此毫无感知,因为虚拟机看…

【计算机视觉 | 图像分割】arxiv 计算机视觉关于图像分割的学术速递(8 月 22 日论文合集)

文章目录 一、分割|语义相关(16篇)1.1 Test-time augmentation-based active learning and self-training for label-efficient segmentation1.2 Improving Diversity in Zero-Shot GAN Adaptation with Semantic Variations1.3 CVFC: Attention-Based Cross-View Feature Cons…

Java方法的返回值及注意事项

方法的返回值 为什么要有带返回值的方法呢? 调用处拿到方法的结果之后,才能根据结果进行下一步操作 带返回值方法的定义和调用: 如果在调用处,要根据方法的结果去编写另一段代码逻辑 为了在调用处拿到方法产生的结果&#xff…

kettle开发-Day42-远程执行作业

目录 前言: 一、远程执行 1、先看定义 2、前置条件 2.1网络畅通 2.2数据库DB连接一致 二、实战案例-Windows 1、初始配置-被远程端 1.1启动carte服务 1.2cmd 命令启动carte服务 2、初始化-远程端 3、实际应用 3.1、错误案例 3.2、正确案例 三、总结 前言&…

【PHP】PHP基本语法

1、PHP标记 当解析一个文件时&#xff0c;PHP 会寻找起始和结束标记&#xff0c;也就是 <?php 和 ?>&#xff0c;告诉 PHP 开始和停止解析二者之间的代码。此种解析方式使得 PHP 可以被嵌入到各种不同的文档中去&#xff0c;而任何起始和结束标记之外的部分都会被 PHP…

Navicat安装教程

众所周知&#xff0c; Navicat是一款轻量级的用于MySQL连接和管理的工具&#xff0c;非常好用&#xff0c;使用起来方便快捷&#xff0c;简洁。下面我会简单的讲一下其安装以及使用的方法。并且会附带相关的永久安装教程。 简介 一般我们在开发过程中是离不开数据库的&#xf…