AMQP-核心概念-5

本文参考以下链接摘录翻译:

https://www.rabbitmq.com/tutorials/amqp-concepts

消息确认(Message Acknowledgements)

消费者应用,就是接收和处理消息的应用。它们偶尔会处理个别消息失败,断开与服务器之间的连接或许多其他失败。

也可能有网络问题导致的问题。这些情况提出了一个问题:消息代理应该在何时删除消息?AMQP 0-9-1让消费者来控制消息的删除时机。有2中确认模式:

  • 在消息代理将一条消息发送给一个应用后删除这条消息(使用basic.deliver 或 basic.get-ok 方法)【自动确认模式】
  • 在消费者应用发送回确认后删除(使用basic.ack方法)【显式确认模式】

使用显式确认时,应用选择何时发送确认。可以在收到消息后马上发送,可以在将消息保存到数据库尚未处理前发送,或者在完全处理完一条消息后发送(例如,成功获取了一个网络页面,处理完并存储到某个持久化数据库)。

如果一个消费者挂掉了,没用发回确认,消息代理会将消息重新发送给另一个消费者,如果正好没有可接收消息的消费者,消息代理会等到至少有一个消费者订阅这个队列,然后尝试重新发送消息给这个消费者。

拒绝消息(Rejecting Messages)

当一个消费者应用收到一条消息,消息处理可能成功或失败。一个应用可以通过拒绝一条消息来告知消息代理:消息处理失败了(或者当前不能完成消息处理)。当拒绝一条消息,应用可以叫消息代理删除消息或将消息重新放入队列。当一个队列只有一个消费者时,确保不要因为同一个消费者拒绝和重新入队一条消息,而产生无限的消息发送循环

反向确认(Negative Acknowlegements)

拒绝消息使用basic.reject方法。basic.reject有一个限制:无法一次拒绝多条消息,但ack可以一次确认多条消息。尽管如此,如果你使用RabbitMQ,可以用RabbitMQ的反向确认【negative acknowlegements 或 nacks】来实现。

预取消息(Prefetching Messages)

对于多个消费者共享一个队列的情形,在发送下一次确认之前,指定每次发送多少条消息给一个消费者是有用的。这可以实现简单的负载均衡,或者增加吞吐量,如果想批量发送消息的话。例如,一个生产者应用每分钟发送消息,由于它工作的特质。

消息属性和负载(Message Attributes and Payload)

AMQP 0-9-1模型中的消息有属性。有些属性很常见,应用开发者不必关心它们的名字。下面是一些属性名:

  • Content Type
  • Content encoding
  • Routing key 路由键
  • Delivery mode(persist or not) 发送模式,持久化或否
  • Message priority 消息优先级
  • Message publishing timestamp 消息发布时间戳
  • Publisher application id 发布者应用id

一些属性被AMQP代理使用,但绝大多数都得由接收消息的应用去解析。有些熟悉是可选得,叫做头(headers)。它们与HTTP中的X-Headers类似。消息属性在消息发布时设置。

消息也有一个负载(即消息携带的数据),在AMQP代理中,负载是一个透明的字节数组。消息代理不会审查或修改负载。消息可以只包含属性,不包含负载。为了将结构化数据设置为负载,一般用序列化格式,如JSON,Thrift, Protocol Buffers和MessagePack来序列化。经常使用content-type和content-encoding来说明数据格式,原则上是这样。

消息可以发布为持久化的,这时消息代理会把消息保存到磁盘。如果代理服务器被重启了,系统会确保收到的持久化消息不会丢失。简单地发布一条消息到一个持久化的交换机或持久化的队列,不会让这条消息被持久化。消息的持久化完全依赖消息自身的持久化模式。将消息发布为持久化会影响性能(就像数据存储,持久化带来一定的性能消耗)。

待续。。。

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

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

相关文章

数据库基础--概念模型

文章目录 概念模型回顾概念结构设计基本概念概念模型中的几个基本概念联系——实体集之间的对应关系讨论:怎样寻找信息世界中的实体和联系?实体和联系的举例概念模型的设计概念模型的设计方法与步骤概念结构设计步骤合并E-R图时的冲突解决方法练习&#…

二叉树习题leetcode 572. 另一棵树的子树

题目链接:572. 另一棵树的子树 二叉树遍历综合问题 题意 给定两棵树,判断第二棵树是否为第一颗树的子树。 思路 用到了100. 相同的树 的思路,把给定的二叉树,每个节点都和subRoot都做一次相同的树的比较,只要正确&…

Llama + Dify,在你的电脑搭建一套AI工作流

theme: smartblue 点赞 关注 收藏 学会了 本文简介 最近字节在推Coze,你可以在这个平台制作知识库、制作工作流,生成一个具有特定领域知识的智能体。 那么,有没有可能在本地也部署一套这个东西呢?这样敏感数据就不会泄露了&…

使用两台虚拟机分别部署前端和后端项目

使用两台虚拟机分别部署前端和后端项目 1 部署方案2 准备两台虚拟机,并配置网络环境3 部署后端项目3.1 打包服务3.2 上传jar包到服务器3.3 集成Systemd3.3.1 移动端服务集成Systemd3.3.2 后台管理系统集成Systemd 4 配置域名映射5 部署前端项目5.1 移动端5.1.1 打包…

Kettle下载安装

环境说明 虚拟机:Win7;MySql8.0 主机:Win11;JDK1.8;Kettle 9.4(Pentaho Data Integration 9.4)(下载方式见文末) 安装说明 【1】解压后运行Spoon.bat 【2】将jar包 复…

DjangoRF-6-项目模块projects模型

首先,这是个新模块,在apps下创建projects 1.1、django-admin startapp projects 1.2进行注册 ‘apps.projects.apps.ProjectsConfig’ 进行接口编写的过程中,落入数据库的字段相同的有很多我们要在utils文件下进行闯进模型鸡肋 from django…

【黑科技】:Laravel 项目性能提升 20 倍

令人激动的黑科技:Laravel 项目性能提升 20 倍 这个项目能够在无需修改任何代码且无需第三方扩展的前提下,将你的 Laravel 项目性能提高 20 倍。它仅依赖于 PHP 原生的 pcntl、posix、fiber 和 sockets。 项目灵感 起因是看到官方发布的 PHP 8.1 更新…

【教学类-70-01】20240728一个茶壶两个茶杯(果茶)

‘ 背景需求: 用通义万相下载简笔画茶壶、茶杯 茶杯,简单笔画,卡通,黑白,未着色,幼儿插图,线条画,没有背景,没有颜色,黑白漫画线条艺术:,空背景…

【全国大学生电子设计竞赛】2022年B题

🥰🥰全国大学生电子设计大赛学习资料专栏已开启,限时免费,速速收藏~

Hakuin:一款自动化SQL盲注(BSQLI)安全检测工具

关于Hakuin Hakuin是一款功能强大的SQL盲注漏洞安全检测工具,该工具专门针对BSQLi设计,可以帮助广大研究人员优化BSQLi测试用例,并以自动化的形式完成针对目标Web应用程序的漏洞扫描与检测任务。 该工具允许用户以轻松高效的形式对目标Web应…

基于Python的宿舍管理系统/基于Spring Boot的学生宿舍管理系统/计算机专业/课设

摘要 宿舍管理系统是一种基于计算机技术的管理工具,旨在提高学生宿舍管理的效率、准确性和安全性。随着高校规模的不断扩大和学生数量的增加,宿舍管理工作变得愈发复杂,传统的手工管理已经无法满足需求。因此,开发宿舍管理系统已…

Greenplum的诞生与成长过程

Greenplum 成立与早期发展 Greenplum的诞生于早起发展 Greenplum于2003年在美国硅谷成立,在2006年发布了基于PostgreSQL(8.x)的MPP数据库产品,作为与公司同名的MPP数据库,专为分析和管理海量数据集而设计,支持复杂的数据分析和商…

大语言模型系列-Transformer:深入探索与未来展望

大家好,我是一名测试开发工程师,已经开源一套【自动化测试框架】和【测试管理平台】,欢迎大家联系我,一起【分享测试知识,交流测试技术】 Transformer模型自其问世以来,便迅速在自然语言处理领域崭露头角&a…

synchronized锁解析+synchronized锁的膨胀过程

目录 synchronized锁(具体详解) synchronized锁具体的三种形式: synchronized锁的实现原理是什么? 类锁和对象锁(面试重点) 锁的升级与对比(synchronized锁的膨胀 面试重点) 偏…

Jenkins持续部署

开发环境任务的代码只要有更新,Jenkins会自动获取新的代码并运行 1. pycharm和git本地集成 获取到下面的 Git可执行文件路径 2. pycharm和gitee远程仓库集成 先在pycharm中安装gitee插件 在设置中找到gitee,点击添加账户,并将自己的账户添…

vscode 根据不同语言项目自定义配置项(插件版本)

2024.7.28 天微热,心情燥。 前文,如果我们是一个全栈开发者,我们想在写前端项目时只让vscode加载前端的插件,写后端的时候只加载后端的插件,该如何配置呢? 1. 通过配置 workspace 这里大家都会&#xff0…

HAL库源码移植与使用之SPI驱动VS1053音频解码

你可以理解为带着dac adc芯片功能的集成芯片,声音的高低音形成由频率决定,大小声由波峰决定,所以采集时记录时间和电压值就可以确定高低音色和大小声,形成声音波形,再把波形用dac输出给喇叭,让喇叭在对应时…

Nginx系列-12 HTTP消息处理流程

背景 了解Nginx处理HTTP请求的11个阶段,有助于理解和配置nginx、自定义模块、基于lua模块自定义功能。按如下配置,执行"curl http://localhost:8001/query/test.html",如果读者对结果不是很确定,建议阅读本文。 serve…

初识C++ · AVL树(2)

目录 前言: 1 左右旋 2 右左旋 3 部分细节补充 3.1 单旋和插入 3.2 部分小函数 前言: AVL树作为一种结构,理解树的本身是不大难的,难的在于,树旋转之后的连接问题,写AVL树的代码大部分都是在旋转部分…

压力温度实时图 livecharts

var mapper Mappers.Xy<MeasureModel>() //.X(model > model.currentTime.Ticks/TimeSpan.FromDays(1).Ticks) //使用 Time.作为X轴的标签 .X(model>model.Time) .Y(model > model.Value); // 作为Y轴的值 //全局保存映射器 Charting.For<Measu…