【RabbitMQ】RabbitMQ 的七种工作模式介绍

目录

1. Simple(简单模式)

2. Work Queue(工作队列)

3. Publish/Subscribe(发布/订阅)

4. Routing(路由模式)

5. Topics(通配符模式)

6. RPC(RPC通信)

7. Publisher Confirms(发布确认)


上一篇文章中我们简单认识了RabbitM1: 

【RabbitMQ】RabbitMQ 的概念以及使用RabbitMQ编写生产者消费者代码_rabbitmq 编程-CSDN博客

RabbitMQ 共提供了7种工作模式, 进行消息传递, 我们上一篇文章入门程序的案例, 其实就是一个简单模式.

官方文档:https://www.rabbitmq.com/tutorials

1. Simple(简单模式)

P: 生产者, 也就是要发送消息的程序
C: 消费者, 消息的接收者
Queue: 消息队列, 图中黄色背景部分. 类似一个邮箱, 可以缓存消息; 生产者向其中投递消息, 消费者从其中取出消息

特点: 一个生产者P,一个消费者C, 消息只能被消费一次, 也称为点对点(Point-to-Point)模式
适用场景: 消息只能被单个消费者处理

2. Work Queue(工作队列)

一个生产者P,多个消费者C1, C2. 在多个消息的情况下, Work Oueue 会将消息分派给不同的消费者, 每个消费者都会接收到不同的消息.

特点: 消息不会重复, 分配给不同的消费者

适用场景: 集群环境中做异步处理

比如12306 短信通知服务, 订票成功后, 订单消息会发送到RabbitMO, 短信服务从RabbitMO中获取订单信息, 并发送通知信息(在短信服务之间进行任务分配)

3. Publish/Subscribe(发布/订阅)

图中X表示交换机, 在订阅模型中,多了一个Exchange角色, 过程略有变化

概念介绍
Exchange: 交换机(X).
作用: 生产者将消息发送到Exchange,由交换机将消息按一定规则路由到一个或多个队列中(上图中生产者将消息投递到队列中,实际上这个在RabbitMO中不会发生.

RabbitMO交换机有四种类型:fanout, direct, topic, headers, 不同类型有着不同的路由策略. AMOP协议里还有另外两种类型, System和自定义, 此处不再描述.

1. Fanout: 广播,将消息交给所有绑定到交换机的队列(Publish/Subscribe模式)
2. Direct: 定向,把消息交给符合指定routing key的队列(Routing模式)
3. Topic: 通配符,把消息交给符合routing pattern(路由模式)的队列(Topics模式)
4. headers 类型的交换器不依赖于路由键的匹配规则来路由消息,而是根据发送的消息内容中的
headers属性进行匹配. headers类型的交换器性能会很差, 而且也不实用, 基本上不会看到它的存在
Exchange(交换机)只负责转发消息, 不具备存储消息的能力, 因此如果没有任何队列与Exchange绑
定,或者没有符合路由规则的队列,那么消息就会丢失. 

RoutingKey: 路由键, 生产者将消息发给交换器时, 指定的一个字符串, 用来告诉交换机应该如何处理这个消息.

Binding Key: 绑定. RabbitMQ中通过Binding (绑定) 将交换器与队列关联起来, 在绑定的时候一般会指定一个Binding Key, 这样RabbitMQ就知道如何正确地将消息路由到队列了,

比如下图: 如果在发送消息时, 设置了RoutingKey为orange, 消息就会路由到Q1

当消息的Routingkey与队列绑定的Bindingkey相匹配时,消息才会被路由到这个队列

BindingKey 其实也属于路由键中的一种, 官方解释为: the routingkey to use for the binding.

可以翻译为: 在绑定的时候使用的路由键, 大多数时候, 包括官方文档和RabbitMOJava API 中都把
BindingKey和RoutingKey看作RoutingKey, 为了避免混淆, 可以这么理解:

1. 在使用绑定的时候, 需要的路由键是BindingKey.
2. 在发送消息的时候, 需要的路由键是RoutingKey.
 

Publish/Subscribe模式

一个生产者P, 多个消费者C1, C2, X代表交换机消息复制多份,每个消费者接收相同的消息

生产者发送一条消息,经过交换机转发到多个不同的队列,多个不同的队列就有多个不同的消费者

适合场景: 消息需要被多个消费者同时接收的场景. 如: 实时通知或者广播消息

比如中国气象局发布"天气预报"的消息送入交换机, 新浪, 百度, 搜狐, 网易等门户网站接入消息,通过队列绑定到该交换机, 自动获取气象局推送的气象数据

4. Routing(路由模式)

路由模式是发布订阅模式的变种, 在发布订阅基础上, 增加路由key

发布订阅模式是无条件的将所有消息分发给所有消费者, 路由模式是Exchange根据RoutingKey的规则, 将数据筛选后发给对应的消费者队列

适合场景: 需要根据特定规则分发消息的场景

比如系统打印日志, 日志等级分为error, warning, info, debug, 就可以通过这种模式, 把不同的日志发送到不同的队列, 最终输出到不同的文件

5. Topics(通配符模式)

路由模式的升级版, 在routingKey的基础上, 增加了通配符的功能, 使之更加灵活

Topics和Routing的基本原理相同,即: 生产者将消息发给交换机,交换机根据RoutingKey将消息转
发给与RoutingKey匹配的队列. 类似于正则表达式的方式来定义Routingkey的模式

不同之处是: routingKey的匹配方式不同,Routing模式是相等匹配,topics模式是通配符匹配

适合场景: 需要灵活匹配和过滤消息的场景

6. RPC(RPC通信)

在RPC通信的过程中, 没有生产者和消费者, 比较像咱们RPC远程调用, 大概就是通过两个队列实现了一个可回调的过程

1. 客户端发送消息到一个指定的队列, 并在消息属性中设置replyTo字段, 这个字段指定了一个回调队列, 用于接收服务端的响应.

2. 服务端接收到请求后,处理请求并发送响应消息到replyTo指定的回调队列

3. 客户端在回调队列上等待响应消息.一旦收到响应,客户端会检查消息的correlationld属性,以
确保它是所期望的响应,

7. Publisher Confirms(发布确认)

Publisher Confirms模式是RabbitMQ提供的一种确保消息可靠发送到RabbitMQ服务器的机制。在这种模式下,生产者可以等待RabbitMO服务器的确认,以确保消息已经被服务器接收并处理

1.生产者将Channel设置为confirm模式(通过调用channel.confirmSelect()完成)后, 发布的每一条消
息都会获得一个唯一的ID, 生产者可以将这些序列号与消息关联起来,以便跟踪消息的状态

2.当消息被RabbitMO服务器接收并处理后,服务器会异步地向生产者发送一个确认(ACK)给生产者
(包含消息的唯一ID),表明消息已经送达,

通过Publisher Confirms模式,生产者可以确保消息被RabbitMQ服务器成功接收,从而避免消息丢失的问题.

适用场景: 对数据安全性要求较高的场景. 比如金融交易, 订单处理

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/452740.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

面试官-HashMap的容量为什么一定是2^n?

嗨,我是大明哥,一个专注「死磕 Java」系列创作的硬核程序员。 回答 HashMap 的容量被设计为 2^n,主要有如下几个优势: 位运算效率:与使用取模(%)操作相比,使用位运算来计算索引位置…

用Spring AI 做智能客服,基于私有知识库和RAG技术

Java智能客服系统运用RAG技术提升答疑精准度 基于Spring ai 的 RAG(检索增强生成)技术,Java智能客服系统能够利用私有知识库中的信息提供更准确的答疑服务。 它的核心思路是: 首先,将客服QA以Word形式导入到系统中&…

upload-labs Pass-04

upload-labs Pass-04 在进行测试前,先了解一下.htaccess文件 .htaccess文件 .htaccess是Apache网络服务器一个配置文件,当.htaccess文件被放置在一个通过Apache Web服务器加载的目录中,.htaccess文件会被Apache Web服务器软件检测并执行&…

深度学习 之 模型部署 使用Flask和PyTorch构建图像分类Web服务

引言 随着深度学习的发展,图像分类已成为一项基础的技术,被广泛应用于各种场景之中。本文将介绍如何使用Flask框架和PyTorch库来构建一个简单的图像分类Web服务。通过这个服务,用户可以通过HTTP POST请求上传花朵图片,然后由后端…

【大数据技术基础 | 实验四】HDFS实验:读写HDFS文件

文章目录 一、实验目的二、实验要求三、实验原理(一)Java Classpath(二)Eclipse Hadoop插件 四、实验环境五、实验内容和步骤(一)配置master服务器classpath(二)使用master服务器编写…

D42【python 接口自动化学习】- python基础之函数

day42 高阶函数 学习日期:20241019 学习目标:函数﹣- 55 高阶函数:函数对象与函数调用的用法区别 学习笔记: 函数对象和函数调用 # 函数对象和函数调用 def foo():print(foo display)# 函数对象 a foo print(a) # &…

influxdb安装

官网: https://www.influxdata.com/ centos7安装 wget https://dl.influxdata.com/influxdb/releases/influxdb2-2.0.4.x86_64.rpmyum localinstall influxdb2-2.0.4.x86_64.rpm启动 systemctl start influxdb systemctl enable influxdb # netstat -npult |gre…

Springboot指定扫描路径

方式一:通过在启动类的SpringbootApplication中指定包扫描或类扫描 指定需要扫描的包 scanBasePackages{"待扫描包1","待扫描包2", . . . ," "} 指定需要扫描的类 scanBasePackageClasses{类1.class,类2.class,...} 方式二&#xff…

权限(补充)

在上一篇Linux权限(想了解的可以点击看看哦)中已经见识了一部分权限,但是少了很重要的一部分: 那就是用户之间的转换,文件读写的关系,这里就简单的介绍一些; 我们在Linux权限知道了目录权限的关…

sql数据库命令行操作(数据库的创建和删除)

查询数据库 查询电脑里面所有数据库 SHOW DATABASES;查询当前所处的数据库 SELECT DATABASE();应用场景:当我使用了USE命令后不知道自己所在哪个数据库时,可以使用这个命令查询自己所在数据库 创建数据库 创建 CREATE DATABASE [IF NOT EXISTS] 数据…

StarTowerChain:开启去中心化创新篇章

官网: www.startower.fr 在当今创新驱动的时代,StarTowerChain 以其独特的去中心化创新模式,为我们带来了新的希望和机遇。去中心化,这个充满活力与创造力的理念,正引领着我们走向未来的创新之路。 StarTowerChain …

远程连接服务器

linux客户端通过秘钥登录linux服务端root用户 [rootClient ~]# ssh-keygen Generating public/private rsa key pair. Enter file in which to save the key (/root/.ssh/id_rsa): // 存放文件,若直接回车就存在括号文件中) Enter passphrase (empty f…

SpringCloudAlibaba[Nacos]注册配置中心注册与发现服务

Nacos的全称是Dynamic Naming and Configuration Service,Na为naming/nameServer即注册中心,co为configuration即注册中心,service是指该注册/配置中心都是以服务为核心。是阿里巴巴开源易于构建云原生应用的动态服务发现、配置管理和服务管理平台。 Nac…

基于预测算法的航班离港延误系统

毕业设计不知道做什么?想找一个结合算法与应用的项目?那你绝对不能错过这个"基于预测算法的航班离港延误系统"!✈️📊 项目简介: 这个系统专注于航班离港的延误预测,通过强大的神经网络技术对大…

2024软考网络工程师笔记 - 第4章.局域网和城域网

文章目录 局域网基础1️⃣局域网和城域网体系架构 IEEE(负责链路层)2️⃣局域网拓扑结构 🕑CSMA/CD1️⃣CSMA/CD2️⃣CSMA/CD三种监听算法3️⃣冲突检测原理 🕒二进制指数退避算法1️⃣ 二进制指数退避算法 🕓最小帧长…

IO进程---day5

1、使用有名管道实现两个进程之间的相互通信 //管道文件 #include<myhead.h> int main(int argc, const char *argv[]) {//创建有名管道文件1if(mkfifo("./pipe1",0664)-1){perror("创建管道文件失败");return 0;}if(mkfifo("./pipe2",066…

数据结构:二叉树、堆

目录 一.树的概念 二、二叉树 1.二叉树的概念 2.特殊类型的二叉树 3.二叉树的性质 4.二叉树存储的结构 三、堆 1.堆的概念 2.堆的实现 Heap.h Heap.c 一.树的概念 注意&#xff0c;树的同一层中不能有关联&#xff0c;否侧就不是树了&#xff0c;就变成图了&#xff…

RequestBody接收参数报错com.fasterxml.jackson.databind.exc.MismatchedInputException

目录&#xff1a; 1、错误现象2、解决办法3、最终验证 1、错误现象 报错的现象和代码如下&#xff1a; 2、解决办法 查了很多都说参数类型对不上&#xff0c;但是明明是对上的&#xff0c;没有问题&#xff0c;最后只有换接收方式后验证是可以的&#xff1b;最终想了一下&…

效果不错的论文介绍:Im2Flow2Act:-跨领域机器人操控技术

Im2Flow2Act: 跨领域机器人操控技术 简介 今天介绍一个比较惊艳的论文&#xff0c;Im2Flow2Act&#xff0c;可以预测应该怎么移动图象中的物体预测移动方法完成需要执行的动作任务。 Im2Flow2Act 是一个基于学习的机器人操控框架&#xff0c;旨在通过多种数据源为机器人提供操…

计算DOTA文件的IOU

背景 在目标检测任务中&#xff0c;评估不同对象之间的重叠情况是至关重要的&#xff0c;而IOU&#xff08;Intersection Over Union&#xff09;是衡量这种重叠程度的重要指标。本文将介绍如何编写一个Python脚本&#xff0c;通过并行化处理DOTA格式的标注文件&#xff0c;统…