【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.mzph.cn/diannao/57122.shtml

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

相关文章

IO编程——消息队列

题目&#xff1a; 代码实现&#xff1a; #include <myhead.h> //正文大小 #define MSGSZ (sizeof(struct msgbuf)-sizeof(long)) //定义要发送的消息类型 struct msgbuf{long msgtype; //消息类型char mtext[1024]; //消息正文 };int main(int argc, const char *ar…

linux下建立软链接

深度学习训练中经常会遇到数据量庞大或者工程中模型报错太多导致磁盘空间不够&#xff0c;但是又不想修改原来在代码中写的路径&#xff0c;这个时候制作软连接很有作用&#xff0c;把占用量大的目录移到别的空闲磁盘&#xff0c;然后在原来的目录做一个软连接指向那个移到的空…

k8s ETCD数据备份与恢复

在 Kubernetes 集群中&#xff0c;etcd 是一个分布式键值存储&#xff0c;它保存着整个集群的状态&#xff0c;包括节点、Pod、ConfigMap、Secrets 等关键信息。因此&#xff0c;定期对 etcd 进行备份是非常重要的&#xff0c;特别是在集群发生故障或需要恢复数据的情况下。本文…

Java--集合(三)之vectorlinkedlisthashset结构

文章目录 0.架构图1.vector解析2.LinkedList分析2.1源码分析2.2迭代器遍历的三种方式 3.set接口的使用方法3.1基本使用说明3.2基本遍历方式3.3HashSet引入3.4数组链表模拟3.5hashset扩容机制3.6hashset源码解读3.7扩容*转成红黑树机制**我的理解 0.架构图 1.vector解析 和之前介…

【Vue】Vue3.0(十四)接口,泛型和自定义类型的概念及使用

上篇文章&#xff1a; 【Vue】Vue3.0&#xff08;十三&#xff09;中标签属性ref&#xff08;加在普通标签上、加在组件标签上&#xff09;、局部样式 &#x1f3e1;作者主页&#xff1a;点击&#xff01; &#x1f916;Vue专栏&#xff1a;点击&#xff01; ⏰️创作时间&…

数据结构——二叉树的基本操作及进阶操作

前言 介绍 &#x1f343;数据结构专区&#xff1a;数据结构 参考 该部分知识参考于《数据结构&#xff08;C语言版 第2版&#xff09;》116 ~ 122页 及 《数据结构教程》201 ~ 213页 重点 树的基本实现并不难&#xff0c;重点在于对递归的理解才是树这部分知识带来的最大收…

python绝对值怎么表示

python abs()函数用于获取数字的绝对值&#xff0c;参数可以是负数、正数、浮点数或者长整形。 语法&#xff1a; abs( x ) 下面是详细参数&#xff1a; X&#xff1a;这是一个数值表达式。 返回值&#xff1a; x的绝对值。 例如&#xff1a; #!/usr/bin/python print &q…

smbms(2)

目录 一、修改密码功能实现 二、优化密码修改&#xff0c;加入旧密码确认环节【使用Ajax】 三、用户管理实现 获取用户数量 获取用户列表 获取角色列表 Servlet 一、修改密码功能实现 1、导入前端素材 2、UserDao接口 3、UserDaoImpl实现类 4、UserService接口 5、Us…

力扣76~80题

题76&#xff08;困难&#xff09;&#xff1a; 分析&#xff1a; 这道题其实不难&#xff0c;但是是我做最久的了&#xff0c;我居然去用res去接所有可能得值&#xff0c;然后再求长度导致空间暴力&#xff0c;我还以为是我queue的问题。。。 最后用暴力求解解的&#xff0c…

【wpf】08 xml文件的存取操作

在使用wpf编程过程中&#xff0c;会用到xml的配置文件&#xff0c;实现对其读取和存储的操作是必须的。 1 xml说明 可扩展标记语言 (Extensible Markup Language, XML) &#xff0c;标准通用标记语言的子集&#xff0c;可以用来标记数据、定义数据类型&#xff0c;是一种允许…

破局汽车基础软件发展丨昂辉科技亮相2024芜湖新能源汽车零部件和后市场生态博览会

10月14—17日&#xff0c;2024芜湖新能源汽车零部件和后市场生态博览会在芜湖市宜居国际博览中心盛大开幕。昂辉科技携新一代EasySAR车载基础软件工具链产品亮相核心零部件展区。 作为新能源汽车行业的一次盛会&#xff0c;本届博览会以“会议论坛展区展示”为特色&#xff0c…

cefsharp79.1.360(Chromium 79.0.3945.130)支持H264视频播放-PDF预览 老版本回顾系列体验

一、关于此版本 版本:Cef 79.1.36/CefSharp 79.1.360/Chromium 79.0.3945.130/支持H264/支持PDF预览 支持PDF预览和H264推荐版本 63/79/84/88/100/111/125 运行环境需要 visual c++ 2015不支持xp/vista/2003/2008默认不支持h264(版权问题)支持打印预览 print preview已知问题…

网络资源模板--Android Studio 实现简易新闻App

目录 一、项目演示 二、项目测试环境 三、项目详情 四、完整的项目源码 一、项目演示 网络资源模板--基于Android studio 实现的简易新闻App 二、项目测试环境 三、项目详情 登录页 用户输入&#xff1a; 提供账号和密码输入框&#xff0c;用户可以输入登录信息。支持“记…

RestHighLevelClient操作es查询文档

目录 利用RestHighLevelClient客户端操作es查询文档 查询match_all dsl语句&#xff1a; ​编辑 java代码 小结 match字段全文检索查询 dsl语句 java代码 multi_match多字段全文检索查询 dsl语句 java代码 term精确查询 dsl语句 java代码 range范围查询 dsl语句 j…

基于SpringBoot的旅店管理系统的设计与实现源码+Vue前端(酒店、民宿、功能较多)

&#x1f497;博主介绍&#x1f497;&#xff1a;✌在职Java研发工程师、专注于程序设计、源码分享、技术交流、专注于Java技术领域和毕业设计✌ 温馨提示&#xff1a;文末有 CSDN 平台官方提供的老师 Wechat / QQ 名片 :) Java精品实战案例《700套》 2025最新毕业设计选题推荐…

Windows系统部署redis自启动服务【亲测可用】

文章目录 引言I redis以本地服务运行(Windows service)使用MSI安装包配置文件,配置端口和密码II redis服务以终端命令启动缺点运行redis-server并指定端口和密码III 知识扩展确认redis-server可用性Installing the Service引言 服务器是Windows系统,所以使用Windows不是re…

文献阅读:通过深度神经网络联合建模多个切片构建3D整体生物体空间图谱

文献介绍 文献题目&#xff1a; 通过深度神经网络联合建模多个切片构建3D整体生物体空间图谱 研究团队&#xff1a; 杨灿&#xff08;香港科技大学&#xff09;、吴若昊&#xff08;香港科技大学&#xff09; 发表时间&#xff1a; 2023-10-19 发表期刊&#xff1a; Nature M…

每日OJ题_牛客_[NOIP2001]装箱问题_01背包_C++_Java

目录 牛客_[NOIP2001]装箱问题_01背包 题目解析 C代码 Java代码 牛客_[NOIP2001]装箱问题_01背包 [NOIP2001]装箱问题 (nowcoder.com) 描述&#xff1a; 有一个箱子容量为V&#xff08;正整数&#xff0c;0 ≤ V ≤ 20000&#xff09;&#xff0c;同时有n个物品&…

Electron入门笔记

Electron入门笔记 ElectronElectron 是什么Electron流程模型创建第一个Electron项目配置自动重启主进程和渲染进程通信打包应用 Electron Electron 是什么 跨平台的桌面应用开发框架使用 JavaScript、HTML 和 CSS 构建桌面应用程序的框架。 嵌入 Chromium和 Node.js Electro…

Print Settings Page 打印设置页面

“打印设置”页面提供了设计时工具&#xff0c;用于自定义控制视图打印版本外观的打印选项。此页面如下图所示。 “选项”和“行为”选项卡式页面提供对视图打印选项的设计时访问&#xff0c;这些选项可通过其 GridView.OptionsPrint 属性或卡片视图的 CardView.OptionsPrint 进…