图解RabbitMQ七种工作模式生产者消费者模型的补充

文章目录

  • 1.消费者模型
  • 2.生产者-消费者模型注意事项
    • 2.1资源释放顺序问题
    • 2.2消费者的声明问题
    • 2.3虚拟机和用户的权限问题
  • 3.七种工作模式
    • 3.1简单模式
    • 3.2工作模式
    • 3.3发布/订阅模式
    • 3.4路由模式
    • 3.5通配符模式
    • 3.6RPC通信
    • 3.7发布确认

1.消费者模型

之前学习的这个消息队列的快速上手,只学习了生产者的这个代码编写,并且可以看到这个生产者生产的这个消息的查看;

今天补充一下这个消费者的:这个消费者的和生产者的在很多的地方都是相似的,,例如前面的这个建立连接,开发信道之类的,就是这个消费者进行这个消费消息的时候是对于这个handleDelivery方法进行重写

image-20241201114400423

1)username这个表示的是我们的admin的名字(也就是我们的用户名字)
2)password是我们创建这个用户的时候设置的密码(不是我们的登录密码)
3)virtualhost就是我们的虚拟主机,这个虚拟主机管理我们创建的这些用户;
4)5672就是消息队列上面的这个默认的端口号;
5)sethost就是我们的云服务器的公网ip地址(我自己是用的云服务器);

下面的这个就是idea的控制台上面打印的这个信息:

image-20241201114218429

这个时候,我们去这个查看:发现数据全部都被释放了,但是原本我们是有很多的信息的,他却只打印了一个信息,因此我们可以设置这个休眠的过程,让这个消费者打印所有的消息;

image-20241201114732895

首先,我们还是需要创建消息,就是让这个生产者进行生产(因为现在已经全部被释放了),我们可以设置一个循环,多生产一些;

image-20241201115048792

这个时候页面会进行自动刷新,我们的这个生产的内容消息就会显示出来:

image-20241201115145573

消费者休眠之后,控制台查看:我们可以发现使用这个休眠之后,信息全部显示出来:

QQ_1733025324888

2.生产者-消费者模型注意事项

2.1资源释放顺序问题

下面的这个就是想要解释我们的资源的释放的问题;

下面的这个是先关闭我们的信道,然后是断开这个生产者和消费者之间的这个链接;

如果我们逆向操作,就是把这个释放资源的先后顺序进行调整,这个时候就会出现问题,这个主要是因为我们的连接断开的时候默认这个信道就关闭了;

因此,我们可以先关闭这个信道,再断开连接,但是不可以断开连接之后关闭信道;

image-20241201180201442

2.2消费者的声明问题

下面的这个声明队列的这个内容是可以省略的(针对于消费者而言的);

前提是我们的这个队列是存在的,这个时候我们的33行指定了这个queue,这个时候不会报错,因为我们即使没有声明,33行使用的时候也是可以找到这个queue的;

但是如果我们把这个queue删除了,就是这个不存在了,这个时候我们进行声明,33行进行使用,这个时候也不会报错,相反,使用的时候会根据我们的这个33行的代码创建这个channel出来;

如果我们的这个queue不存在,我们也不生命,在33行直接使用,这个时候就会报错,因为根本找不到这个队列;

image-20241201180456454

2.3虚拟机和用户的权限问题

1)还是之前说过的这个问题:就是我们的一个虚拟机可以对于多个用户进行管理,这个时候我们需要保证我们操作的这个用户是可以有虚拟机管理的这个权限的,否则是无法进行这个生产和消费的过程的;

2)一般我们日常学习是使用一个虚拟主机,在这个虚拟主机上面对于多个用户进行管理,而且我们的这个用户名密码也需要相互对应,否则也是无法进行消息的发送和接受的;

3.七种工作模式

image-20241201181358770

image-20241201181426384

image-20241201181445511

3.1简单模式

简单模式就是我们上面实现的这个快速上手的案例:只有一个生产者,一个消费者的模式;

P:producer就是生产者;

C:comsumer就是消费者;

Quene:消息队列,对于信息进行缓存,生产者的消息放到这个消息队列里面,消费者从这个消息队列里面取出来消息;

image-20241201182053097

3.2工作模式

这个就是工作模式:一个生产者,多个消费者,生产者生产的消息,分配给所有的这个消费者,但是每一个消费者只是获取这个消息里面的一部分内容;

image-20241201182157183

适用场景:集群环境下面的异步处理;

例如我们只有一个12306,但是又很多的这个用户,这个时候12306就会把这个消息不加重复的给到每一个消费者,也就是我们的用户;

3.3发布/订阅模式

这个x表示的是交换机;

这个时候我们的这个c1和c2消费者接受的就是这个生产者的全部内容;

例如这个p生产的内容是10个消息,这个时候10个消息就会给c1一份,给c2一份,而不是像上面的这个工作模式(工作模式里面的这个消费者加起来的总和只有一份,这个发布模式是每一个消费者都是一份,这个就是两者之间的区别之一);

image-20241201182749228

另外一个区别也是显而易见的,就是我们的交换机,交换机主要是下面的几种类型:

1)fanout:广播,把消息交给所有绑定了交换机的队列,我们的这个发布订阅模式使用的就是这个类型的交换机(这个类型就是不进行任何筛选,只要我们有联系,我的这个消息就会给你一份);

2)direct:定向,这个就是把消息给到指定的这个队列里面去,3.4里面的路由模式使用的这个类型的交换机;

3)topic:通配符,把消息给指定的符合通配符要求的队列里面去,也就是下面的这个3.5里面的交换机的类型;

除此之外,我们需要了解一下这个绑定规则:

1)RoutingKey:这个表示的就是我们的生产者和交换机之间的这个绑定的规则;

2)Binding Key:这个表示的就是我们的路由器和消费者之间的这个绑定的规则;

下面会针对于routingKey和biningkey展开介绍和说明;

3.4路由模式

路由模式就是上面的这个发布订阅模式的变种,只不过是有了一定的这个筛选的标准和规则,这个下面的a,b,c就是对应的选择标准;

例如我们之前学习的这个日志的等级:error,warning,info就可以视为是这个a,b,c,符合这个error级别的消息就会到这个c1里面去,符合这个warning和info级别的就回到这个c2消费者里面去;

image-20241201183854340

3.5通配符模式

和上面的路由模式,这个使用的就是模糊匹配,上面的是相等才可以,我们这个是符合条件就可以,比路由模式更加灵活,使用与需要灵活的处理和进行消息的过滤的场景;

*表示的就是一个字符,#表示的就是一个或者多个字符,这个就是通配符的具体的含义;

image-20241201184728058

3.6RPC通信

1)这个下面就是我们的客户端和服务端,没有生产者和消费者;

2)客户端发送消息到这个指定的队列上面,消息属性里面有这个reply和correlation,这个correlation就是最后和接收到的消息进行校验的,reply就是告诉我们的服务器把返回的消息放到这个指定的队列里面去;

3)我们的服务器就是把消息放到这个指定的毁掉队列reply_to里面去,客户端收到消息之后检查这个correlation属性是不是一样的,确保这个就是自己期望的响应的内容;

image-20241201185522790

3.7发布确认

这个就类似于我们学习网络通信时候的这个里面的确认应答的机制,返回一个ack;

这个是我们的生产者和我们的消息队列服务器之间进行这个消息的确认和应答,没有这个消费者的参与,因为这个就是为了确保我们的这个生产者生产的这个消息被我们的消息队列的这个服务器接收到;

image-20241201184400424

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

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

相关文章

如果模块把http改成了https请求,测试方案应该怎么制定

首先确定要测试的模块、接口、功能等,以及测试的目标,确保HTTPS请求能够正常进行、数据传输安全等。 1.功能测试 回归相应的功能模块以及业务逻辑,是否正常 2.兼容测试 测试不同浏览器和操作系统是否能够正常支持HTTPS连接。 验证模块在各种设…

编写按层次顺序(同一层自左至右)遍历二叉树的算法。或:按层次输出二叉树中所有结点;

解:思路:既然要求从上到下,从左到右,则利用队列存放各子树结点的指针是个好办法。 这是一个循环算法,用while语句不断循环,直到队空之后自然退出该函数。 技巧之处:当根结点入队后,会…

头歌 Linux之线程管理

第1关:创建线程 任务描述 通常我们编写的程序都是单进程,如果在一个进程中没有创建新的线程,则这个单进程程序也就是单线程程序。本关我们将介绍如何在一个进程中创建多个线程。 本关任务:学会使用C语言在Linux系统中使用pthrea…

Leetcode101. 对称二叉树(HOT100)

链接 我的错误代码: class Solution { public:bool isSymmetric(TreeNode* root) {if(!root)return true;if(!root->left&&!root->right)return true;if(!(root->left&&root->right))return false;if(root->left->val!root->…

Java 集合:强大的数据管理工具

在 Java 编程中,集合是一种非常重要的工具,它提供了一种方便的方式来存储和操作一组对象。本文将深入探讨 Java 集合框架,包括其主要类型、特点、用法以及一些最佳实践。 一、引言 在软件开发过程中,我们经常需要处理一组数据。…

qtcanpool 知 09:测试框架

文章目录 前言不满改进优化后语 前言 很久以前,作者写的代码都没有测试用例,最多就是写个 demo 验证一下,毕竟不是专业出身,也没经过大公司的洗礼。 后来,参与到一些项目才知道有专门的测试,而且开发也要测…

网络安全系列 之 SQL注入学习总结

目录 1. sql注入概述2. sql注入测试工具3. sql注入防御方法 3.1 问题来源3.2 防御方法4. SQL注入防御举例 4.1 使用JDBC时,SQL语句进行了拼接 1. 使用statement的executeQuery、execute、executeUpdate等函数时,传入的SQL语句拼接了来自外部的不可信参数…

《平衡之策:C++应对人工智能不平衡训练数据的数据增强方法》

在人工智能的广袤领域中,数据是驱动模型学习与成长的核心燃料。然而,不平衡的训练数据却如同一颗隐藏的暗礁,常常使模型的训练之船偏离正确航道,导致性能不佳与偏差增大。当我们聚焦于 C这一强大的编程语言时,又有哪些…

完整指南:在Ubuntu 20.04 ROS 1环境中配置和使用Orbbec SDK

完整指南:在Ubuntu 20.04 ROS 1环境中配置和使用Orbbec SDK 要在Ubuntu 20.04系统中使用ROS 1环境配置和使用Orbbec SDK,可以遵循以下详细且系统化的步骤。这些步骤将引导您从下载必要的工具和SDK到学习如何使用这些资源,确保您能有效地利用…

使用 Selenium 和 Python 爬取腾讯新闻:从基础到实践

使用 Selenium 和 Python 爬取腾讯新闻:从基础到实践 在这篇博客中,我们将介绍如何利用 Selenium 和 Python 爬取腾讯新闻的内容,并将结果保存到 CSV 文件中。本教程包含以下内容: 项目简介依赖安装实现功能的代码实现中的关键技…

element ui 自定义文件上传二进字流传值问题

1.封装的post请求 import axios from ./axios.js //引入axios文件 export function post (url, data) {return axios({method: post,url,data: {...data}}) }//修改后 正常了 export function post (url, data) {return axios({method: post,url,data: data}) } 2.api文件里面…

【设计模式系列】单例模式(二十)

一、什么是单例模式 单例模式(Singleton Pattern)是一种常用的软件设计模式,属于创建型模式。它的目的是确保一个类只有一个实例,并提供一个全局访问点来获取这个实例。 单例模式的主要特点包括: 唯一性&#xff1a…

在 SpringBoot 集成了 Mybatis 的基础上添加 Mybatis-Plus

SpringBoot 集成了 Mybatis 可以参考前一篇文章 《SpringBoot 项目快速集成 Mybatis》 在 SpringBoot 集成了 Mybatis 的基础上添加 Mybatis-Plus 步骤&#xff1a; 引入 mybatis-plus 依赖&#xff1a; <dependency><groupId>com.baomidou</groupId><…

BioDeepAV:一个多模态基准数据集,包含超过1600个深度伪造视频,用于评估深度伪造检测器在面对未知生成器时的性能。

2024-11-29, 由罗马尼亚布加勒斯特大学创建BioDeepAV数据集&#xff0c;它专门设计来评估最先进的深度伪造检测器在面对未见过的深度伪造生成器时的泛化能力&#xff0c;这对于提高检测器的鲁棒性和适应性具有重要意义。 数据集地址&#xff1a;biodeep 一、研究背景&#xff1…

工业—使用Flink处理Kafka中的数据_ChangeRecord1

使用 Flink 消费 Kafka 中 ChangeRecord 主题的数据,当某设备 30 秒状态连续为 “ 预警 ” ,输出预警 信息。当前预警信息输出后,最近30

Flink四大基石之State(状态) 的使用详解

目录 一、有状态计算与无状态计算 &#xff08;一&#xff09;概念差异 &#xff08;二&#xff09;应用场景 二、有状态计算中的状态分类 &#xff08;一&#xff09;托管状态&#xff08;Managed State&#xff09;与原生状态&#xff08;Raw State&#xff09; 两者的…

opencv-android编译遇到的相关问题处理

1、opencv-android sdk下载 下载地址&#xff1a;https://opencv.org/releases/ 下载安卓SDK即可 2、解压下载好的SDK 3、导入opencv的SDK到安卓项目中 导入步骤在/OpenCV-android-sdk/sdk/build.gradle文件的注释中写的非常详细&#xff0c;大家可安装官方给出的步骤导入。…

前端项目开发 如何解决 error ‘val‘ is not defined no-undef 问题?

在前端开发中&#xff0c;error val is not defined no-undef 是 ESLint 报出的错误&#xff0c;表示在代码中使用了未定义的变量 val&#xff0c;但是 ESLint 没有找到它的声明。为了解决这个问题&#xff0c;通常有以下几种方法&#xff1a; 1. 检查变量是否正确声明 最常见…

深入探索 HarmonyOS 的 Navigation 组件:灵活的页面管理与动态导航

在移动应用开发中&#xff0c;页面的跳转和导航一直是核心功能之一。对于 HarmonyOS 开发者来说&#xff0c;Navigation 组件提供了一个强大的工具来实现灵活的页面管理和导航体验。今天&#xff0c;我们将深入探讨如何使用 HarmonyOS 中的 Navigation 组件来管理页面跳转、工具…

OpenSSH-9.9p1 OpenSSL-3.4.0 升级步骤详细

前言 收到漏洞扫描通知 OpenSSH 安全漏洞(CVE-2023-38408) OpenSSH 安全漏洞(CVE-2023-51385) OpenSSH 安全漏洞(CVE-2023-51384) OpenSSH 安全漏洞(CVE-2023-51767) OpenSSH 安全漏洞(CVE-2023-48795) OpenSSH&#xff08;OpenBSD SecureShell&#xff09;是加拿大OpenBSD计划…