RabbitMq消息模型-队列消息

news2024/11/29 10:01:23

队列消息分为2种:

  • 基本模型(SimpleQueue)、工作模型(WorkQueue)

队列消息特点:

  1. 消息不会丢失 并且 有先进先出的顺序。
  2. 消息接收是有顺序的,不是随机的,仅有一个消费者能拿到数据,而且不同消费者拿不到同一份数据。

基本模型: SimpleQueue
在这里插入图片描述
在上图的模型中,有以下几个概念:

  • P:为生产者,也就是要发送消息的程序
  • C:为消费者:消息的接受者,会一直等待消息到来。
  • queue:为消息队列,为上图中间红色部分。类似为一个邮箱,可以缓存消息,生产者向其中投递消息,消费者从其中取出消息。

适用场景:基本模型适用于 消息存取 数量不多,频率不高。

工作模型: WorkQueue
在这里插入图片描述

WorkQueue简单来说就是让多个消费者绑定到一个队列,共同消费队列中的消息

弊端:
  当消息处理比较耗时的时候,可能生产消息的速度会远远大于消息的消费速度。长此以往,消息就会堆积越来越多,无法及时处理。那么这时就可以用WorkQueue模型,多个消费者共同处理消息,处理消息的速度就能大大提高了。

 工作模型它默认分配模式是 平均分配给每个消费者,并没有考虑到消费者的处理能力。这样显然是有问题的。有的消费者性能高,有的消费者性能低。如果两个消费者都消费同样的消息,那么就会造成一个消费的快些一个消费的慢些,因为性能高的消费者它的消费能力要强些,性能低的消费者消费能力要弱些。

 当然默认的平均分配模式也可以在消费者的配置文件中更改为能者多劳模式,能力强的多干点,能力弱的少干点。

适用场景:工作模型适用于 消息存取 数量多,频率高。

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

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

相关文章

代码随想录算法训练营第五十六天|583. 两个字符串的删除操作、72. 编辑距离、编辑距离总结篇

583. 两个字符串的删除操作 文档讲解 : 代码随想录 - 583. 两个字符串的删除操作 状态:再次回顾。 动态规划五部曲: 确定dp数组(dp table)以及下标的含义 dp[i][j]:以i-1为结尾的字符串word1,和…

肖特基二极管SBD,SOD-123封装有哪些型号?

肖特基二极管,常用二极管之一,对于电子工程师来说,并不陌生。肖特基二极管,又称肖特基势垒二极管、热载流子二极管,英文Schottky Barrier Diode,缩写SBD,是利用金属-半导体(M-S)接触特性制成&am…

C语言:扫雷小游戏

文接上一篇博文C语言:三子棋小游戏。本篇博文是使用C语言来实现扫雷小游戏的。这里不对扫雷的规则进行赘述。玩家通过键盘输入坐标来探雷。博主在实现扫雷之前从未看过扫雷实现的相关视频,所以这里实现的扫雷完全是博主的原生思路,具有逻辑性…

用python开发一个炸金花小游戏

众所周知扑克牌可谓是居家旅行、桌面交友的必备道具, 今天我们用 Python 来实现一个类似炸金花的扑克牌小游戏,先来看一下基本的游戏规则。 炸(诈)金花又叫三张牌,是在全国广泛流传的一种民间多人纸牌游戏…

乐信仍面临资产质量下降和拖欠率上升风险

来源:猛兽财经 作者:猛兽财经 公司介绍 乐信(LX)成立于2013年10月,是中国领先的新消费数字科技服务商。旗下业务包括线上分期购物商城分期乐,全场景信用消费产品乐花卡,新型分期购物平台买吖,助力金融机构…

广告、政府、IT三重合作:凭爱校对轻松搞定文本质量

在广告创意、政府政策和IT开发这三个看似不相关的领域中,有一个共同的需求:高质量的文本内容。本文将探讨如何通过使用“爱校对”工具,在这三个行业内确保文本质量,从而提高工作效率和准确性。 广告行业:语境与创意的完…

EDM邮件营销:使用EDM代发实现更高发送率

虽然现在进入数字时代,但电子邮件依然是企业跟客户之间沟通最有效的方式之一。为了吸引并且留存目标用户,各大企业都在努力做好EDM(Electronic Direct Mail)邮件营销。但是通常用电子邮箱发送外贸邮件会有发送数量和自动化的限制&…

固定资产管理怎么写报告

撰写固定资产管理报告时,需要考虑以下几个维度的数据:  资产总量和分类:列出公司的固定资产总量、种类以及各类型资产的数量。  资产使用情况:统计各类型资产的使用率、闲置率、报废率等数据,以及不同部门的资产使…

西电Latex毕业模板使用时的小技巧

西电Latex毕业模板 配置的环境:textlivetextstudio \qqad 空格 参考文献先设置成bib,放到tex文件下,然后如下操作就可以将参考文献加载进去 如果搜不到相关文献的bib格式,可以用zotero软件将下载好的文件导出为bib格式&#xf…

43、Flink之Hive 读写及详细验证示例

Flink 系列文章 1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接 13、Flink 的table api与sql的基本概念、通用api介绍及入门示例 14、Flink 的table api与sql之数据类型: 内置数据类型以及它们的属性 15、Flink 的ta…

在线客服如何与客户进行有效沟通?

在今天的“互联网”时代,越来越多的服务都开始向线上转移,其中最受欢迎的莫过于在线客服。在线客服不仅可以提供7x24小时的在线咨询服务,还可以提高企业的服务效率和满意度。然而,有时候在线客服与客户之间的沟通效果却不太令人满…

EMERSON A6500-CC 机架接口模块 AMS参数

EMERSON A6500-CC 机架接口模块 AMS参数 ModBus和机架接口模块设计用于工厂的高可靠性 最关键的旋转机械。它从所有AMS A6500 ATG模块读取参数 并通过ModBus TCP/IP和/或ModBus RTU(串行)输出这些参数。 此外,OPC UA可用于向第三方系统传输数…

sentinel1.8.6中的blockHandler/blockHandlerClass和fallback/fallbackClass

官网介绍 简单的说blockHandler/blockHandlerClass是给限流降级用的,异常为BlockException,fallback/fallbackClass是给除BlockException之外的业务异常兜底用的。 官方文档还说明。1.6.0 之前的版本 fallback 函数只针对降级异常(DegradeEx…

Leetcode125. 验证回文串

力扣(LeetCode)官网 - 全球极客挚爱的技术成长平台 如果在将所有大写字符转换为小写字符、并移除所有非字母数字字符之后,短语正着读和反着读都一样。则可以认为该短语是一个 回文串 。 字母和数字都属于字母数字字符。 给你一个字符串 s&…

软件测试/测试开发丨Web自动化测试 关键数据记录

点此获取更多相关资料 本文为霍格沃兹测试开发学社学员学习笔记分享 原文链接:https://ceshiren.com/t/topic/27105 记录关键数据的作用 内容作用日志1、记录代码执行情况,方便复现场景,也可以作为bug依据截图1、断言失败或成功的截图&#…

cesium开发入门(vue2)

一、cesium介绍 Cesium是国外一个基于JavaScript编写的使用WebGL的地图引擎。Cesium支持3D,2D,2.5D形式的地图展示,可以自行绘制图形,高亮区域,并提供良好的触摸支持,且支持绝大多数的浏览器和mobile。 中文文档 官网 二、创建…

transformer位置编码最详细的解析

位置编码positional encoding 1. 位置编码是什么,为什么需要它?2. transformer提出的位置编码方法3. 直觉4. 其他细节5. 相对位置6. 常见问题解答 1. 位置编码是什么,为什么需要它? 位置和词语的顺序是任何语言的重要组成部分。它…

韩老师java教程

基础知识 进制 进制首位表示方式二进制0B十进制无八进制0十六进制0X 进制转换 x进制转十进制 正常,没什么问题 十进制转x进制 将该数不断除以x,直到商为0为止,然后将每一步得到的余数倒过来,就是对应的x进制 二进制转八进…

MySQL——单行处理函数和多行处理函数

数据处理函数: 单行处理函数:一个输入对应一个输出 多行处理函数:多个输入对应一个输出 单行处理函数: 将大写转换为小写:lower(); select lower(ename) as ename from emp; 将小写转换为大写:upper(); se…

软件测试工作中需要使用的工具

作为一个测试人员在日常工作中会使用到很多的工具,今天给大家分享一下这些工具。对软件测试、接口、自动化、性能测试和日常文档编写办公有帮助的网站。 接口测试大力推荐国产的接口测试工具:apipost,apipost还是一款很不错的接口文档生产工…