RabbitMQ消息属性详解

这篇具有很好参考价值的文章主要介绍了RabbitMQ消息属性详解。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

rabbitmq content_type,消息队列系列,分布式和微服务理论与实践,java-rabbitmq,rabbitmq,java

content-type属性

如同各种标准化的HTTP规范,content-type传输消息体的MIME类型。例如,如果你的应用程序正在发送JSON序列化的数据值,那么将content-type属性设置为application/json将允许尚待开发的消费者应用程序在收到消息时检查消息类型并对消息进行正确解码。

在 RabbitMQ 中,默认的 content-type 是 application/octet-stream。

application/octet-stream 是一个常见的 MIME 类型,它表示二进制数据流,也可以理解为未知的二进制文件类型。"octet" 指的是 8 位字节,表示该类型可以包含任意的二进制数据。由于它是一个通用的二进制数据流类型,它不会对数据进行解析或做出任何假设,而是将数据视为纯粹的字节序列。

application/octet-stream 类型的文件通常没有特定的格式或解析方式,因此接收者需要根据具体的需求和上下文来处理该文件。它可以用于传输任何类型的数据,例如图像、音频、视频、压缩文件等。

在 RabbitMQ 中,默认将消息的 content-type 设置为 application/octet-stream,因为 RabbitMQ 不对消息的内容进行解析或做任何假设,它仅负责将消息传递给消费者。消费者可以根据自己的需求和上下文来解析和处理接收到的消息数据。

content-encoding属性

默认情况下,通过AMQP发送的消息并不会被压缩。在处理如XML这种过于繁杂的标记语言时,甚至在消息数量较大的场景下处理像JSON或YAML等较少使用标记的轻量级格式时,这都可能会是个问题。你的发布者可以在发布消息之前压缩消息,并在收到消息时进行解压缩,如同我们使用gzip在服务器上压缩网页然后在浏览器端实时解压缩这些网页之后再进行展示一样。

RabbitMQ 的content-type和content-encoding是如何结合使用的?

在 RabbitMQ 中,content-type 和 content-encoding 是两个相关但独立的消息属性,用于描述消息的内容类型和内容编码方式。

content-type 属性指定了消息体的内容类型,例如 application/json、text/plain、image/jpeg 等。它告诉消费者如何解析和处理消息的内容。

content-encoding 属性指定了消息体的内容编码方式,例如 gzip、deflate、identity 等。它告诉消费者消息体是否经过了压缩或其他编码方式的处理。

这两个属性可以结合使用,以便消费者能够正确地解码和处理消息。以下是一些示例:

rabbitmq content_type,消息队列系列,分布式和微服务理论与实践,java-rabbitmq,rabbitmq,java

 文章来源地址https://www.toymoban.com/news/detail-577004.html

消费者在接收到消息时,首先会检查 content-type 属性来确定消息的内容类型。然后,根据 content-encoding 属性,消费者可以选择是否需要解码消息体。

如果 content-encoding 属性为 identity,则消息体未经过任何编码处理,消费者可以直接读取和处理消息体。

如果 content-encoding 属性指定了某种编码方式(例如 gzip),则消费者需要根据指定的编码方式对消息体进行解码,以获取原始的消息内容。

需要注意的是,content-type 和 content-encoding 是消息的属性,由生产者在发送消息时设置。消费者在接收到消息时,可以读取这些属性来正确处理消息的内容

message-id和correlation-id

在AMQP规范中,message-id和correlation-id是“应用级别使用”的属性,并没有提供正式的行为定义。这意味着就规范而言,你可以利用它们实现任何目的。这两个字段允许多达255个字节的UTF-8编码数据,并以未压缩的方式存储在Basic.Properties数据结构中。

【Message-id】某些消息类型(如登录事件)并不需要与其关联的唯一标识,但我们很容易想象如销售订单或支持类请求等的消息需要具备这个唯一标识。当消息流经松耦合系统中的各个组件时,message-id属性使得消息能够在消息头中携带数据,该数据可以唯一地识别该消息。message-id 是消息的唯一标识符,由生产者在发送消息时设置。它用于唯一标识一条消息,并且在整个消息的生命周期中保持不变。message-id 属性可以用于跟踪消息、识别重复消息或在消息处理过程中进行日志记录

【Correlation-id】虽然在AMQP规范中没有关于correlation-id的正式定义,但它的一个用途是指定该消息是另一个消息的响应,通过携带关联消息的message-id可以做到这一点。另一种选择是使用它来传送关联消息的事务ID或其他类似数据。correlation-id 是用于关联消息的属性,通常在消息请求和响应之间使用。当一个系统发送请求消息时,它可以设置 correlation-id 属性为一个唯一的值。然后,当该请求消息被处理并得到响应时,响应消息的 correlation-id 属性会与请求消息的 correlation-id 相匹配,以表明响应消息与哪个请求消息相关联。

通过使用 correlation-id 属性,可以轻松地将请求和响应进行匹配和关联。这在分布式系统或异步消息传递中特别有用,允许跟踪消息的处理和建立请求-响应模式。

需要注意的是,message-id 和 correlation-id 都是可选的消息属性,生产者可以选择是否设置它们。如果生产者没有显式设置这些属性,RabbitMQ 会为消息自动生成一个唯一的 message-id。

消费者在接收到消息时,可以读取 message-id 和 correlation-id 属性来处理消息,并根据需要进行跟踪、日志记录或关联请求和响应。

timestamp属性

RabbitMQ 中的消息可以包含一个名为 timestamp 的属性,用于表示消息的时间戳。timestamp 属性指示消息发送的时间,它是一个整数值,表示自1970年1月1日以来的毫秒数。

生产者在发送消息时可以设置 timestamp 属性,以指定消息的时间戳。这对于在消息中包含时间信息,或者与消息的时间相关的处理非常有用。

消费者在接收到消息时可以读取 timestamp 属性,以获取消息的时间戳。这允许消费者根据消息的时间戳进行处理,例如根据消息的发送时间进行排序、计算消息的延迟等

需要注意的是,RabbitMQ 并不会自动为每条消息设置 timestamp 属性,它是可选的。如果生产者没有显式设置 timestamp 属性,则消息的 timestamp 默认为未设置状态。因此,消费者在处理消息时应该检查 timestamp 属性是否存在,以避免处理未设置时间戳的消息。

expiration属性

在 RabbitMQ 中,消息可以具有一个名为 expiration 的属性,用于指定消息的过期时间。expiration 属性是一个字符串,表示消息在队列中可以保留的时间。

当消息在队列中等待被消费时,RabbitMQ 会根据消息的 expiration 属性进行判断。如果消息在队列中的时间超过了指定的过期时间,RabbitMQ 将会自动将该消息从队列中移除,并发送给死信交换机(Dead Letter Exchange)进行进一步处理。

通过设置 expiration 属性,可以实现消息的自动过期和延迟处理。这对于处理具有时间敏感性的消息非常有用,例如在一定时间内未被消费的消息可以被认为是过期的,从而进行相应的处理。

需要注意的是,expiration 属性的值是以毫秒为单位的时间间隔,指示消息在队列中保留的时长。如果 expiration 属性设置为 0 或负数,则表示消息不会过期,会一直保留在队列中。

在 RabbitMQ 中,默认情况下,消息的 expiration 属性是未设置的(unset)。这意味着消息不会自动过期,除非你在发送消息时显式地设置了 expiration 属性。

如果你没有设置消息的 expiration 属性,消息将保留在队列中直到被消费或手动从队列中删除。

需要注意的是,RabbitMQ 中可以配置针对队列级别的消息过期策略,该策略可以在创建队列时指定。这将应用于所有发送到该队列的消息,除非单独设置了消息的 expiration 属性。如果设置了队列级别的消息过期策略,它将覆盖消息的个别 expiration 设置。但是,默认情况下,RabbitMQ 不会对消息应用任何过期策略,消息将保留在队列中直到被处理。

delivery-mode

delivery-mode属性是一个字节字段,向消息代理服务器表明在将消息投递给任何正在等待的消费者之前,是否希望先将它持久化到磁盘上。在RabbitMQ中,持久化消息意味着即使RabbitMQ服务器重新启动,消息也会保留在队列中直到被消费。delivery-mode属性有两个可能的值:1表示非持久化消息,2表示持久化消息。

需要注意的是,默认情况下,RabbitMQ 将消息视为非持久性消息,即 delivery-mode 属性为 1。这意味着,如果没有显式地设置消息的 delivery-mode 属性,消息将被标记为非持久性消息。

app-id和user-id

在 RabbitMQ 中,消息可以包含两个与身份相关的属性:app-id 和 user-id。

app-id 属性用于标识发送消息的应用程序的标识符。它可以是应用程序的名称、ID 或其他标识符。app-id 属性可以帮助消费者识别消息来自哪个应用程序,并根据需要进行处理或路由。

user-id 属性用于标识发送消息的用户的标识符。它可以是用户的名称、ID 或其他标识符。user-id 属性用于在多用户环境中跟踪消息的来源,并可能用于进行权限验证或其他身份验证操作。

这些属性通常由生产者在发送消息时设置,以提供有关消息来源和身份的信息。消费者在接收到消息时可以读取这些属性,以便根据需要进行相应的处理。

消费者在接收到消息时可以通过读取消息的 app-id 和 user-id 属性来识别消息的来源和用户,然后根据需要进行相应的处理。这对于应用程序的日志记录、审计跟踪、权限验证等场景非常有用。

headers消息头自定义属性

headers属性是一个键/值对表,允许用户自定义任意的键和值。键可以是ASCII或Unicode字符串,最大长度为255个字符。而值可以是任何有效的AMQP值类型。

与其他属性不同,headers属性允许你添加任何你想要添加的数据到消息头表中。它还具有另一个独特的功能:RabbitMQ可以根据headers表中填充的值路由消息,而不需要依赖于路由键。

priority优先级属性

在 RabbitMQ 中,消息可以具有一个名为 priority 的属性,用于指定消息的优先级。priority 属性是一个整数值,范围从 0 到 9,其中 0 表示最低优先级,9 表示最高优先级。

通过设置消息的 priority 属性,可以使具有较高优先级的消息在消息队列中被优先处理。RabbitMQ 使用优先级来决定消息的处理顺序。在相同的队列中,具有更高优先级的消息将优先于具有较低优先级的消息被消费。

需要注意的是,RabbitMQ 默认情况下是不支持消息优先级的,除非你在队列的定义中明确启用了消息优先级。在创建队列时,可以通过设置 x-max-priority 参数来启用队列的消息优先级支持。

消费者在接收消息时可以读取消息的 priority 属性,并根据消息的优先级进行相应的处理。具有更高优先级的消息将优先于具有较低优先级的消息被消费。

 

到了这里,关于RabbitMQ消息属性详解的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 消息中间件RabbitMQ详解

    消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。 消息中间件适用于需要可靠的数据传送的分布式环境。采用消息中间件机制的系统中

    2024年02月16日
    浏览(83)
  • RabbitMQ中的消息预取值prefetchCount参数详解

    刚学习RabbitMQ的同学可能对prefetchCount预取值这个参数有一些困惑,本文对其作用进行详细讲解。配合了几张有趣的图片方便同学们理解。   首先要从轮询分发机制讲起,轮询分发顾名思义,依次发消息,生产者不会管你消费者消费消息的速度,我只负责把消息依次给你们,

    2024年01月17日
    浏览(43)
  • RabbitMQ如何保证消息的可靠性6000字详解

    RabbitMQ通过生产者、消费者以及MQ Broker达到了解耦的特点,实现了异步通讯等一些优点,但是在消息的传递中引入了MQ Broker必然会带来一些其他问题,比如如何保证消息在传输过程中可靠性(即不让数据丢失,发送一次消息就会被消费一次)?这篇博客将详细从生产者,MQ B

    2024年02月16日
    浏览(38)
  • 深入详解高性能消息队列中间件 RabbitMQ

      目录 1、引言 2、什么是 RabbitMQ ? 3、RabbitMQ 优势 4、RabbitMQ 整体架构剖析 4.1、发送消息流程 4.2、消费消息流程 5、RabbitMQ 应用 5.1、广播 5.2、RPC VC++常用功能开发汇总(专栏文章列表,欢迎订阅,持续更新...) https://blog.csdn.net/chenlycly/article/details/124272585 C++软件异常排查从入

    2024年02月05日
    浏览(82)
  • RabbitMQ详解(三):消息模式(fanout、direct、topic、work)

    参考官网:https://www.rabbitmq.com/getstarted.html 简单模式 Simple, 参考RabbitMQ详解(二):消息模式 Simple(简单)模式 简单模式是最简单的消息模式,它包含一个生产者、一个消费者和一个队列。生产者向队列里发送消息,消费者从队列中获取消息并消费。 发布订阅模式 fanout 同时向

    2024年02月10日
    浏览(48)
  • 【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka

    作者简介 前言 博主之前写过一个完整的MQ系列,包含RabbitMQ、RocketMQ、Kafka,从安装使用到底层机制、原理。专栏地址: https://blog.csdn.net/joker_zjn/category_12142400.html?spm=1001.2014.3001.5482 本文是该系列的清单综述,会拉通来聊一下三大MQ的特点和各种适合的场景。 目录 1.概述 1.1.M

    2024年02月09日
    浏览(53)
  • 前端篇-Content-Type 详解

    Content-Type(MediaType),即是Internet Media Type,互联网媒体类型,也叫做MIME类型。在互联网中有成百上千中不同的数据类型,HTTP在传输数据对象时会为他们打上称为MIME的数据格式标签,用于区分数据类型。最初MIME是用于电子邮件系统的,后来HTTP也采用了这一方案。 在HTTP协议

    2024年04月27日
    浏览(49)
  • 详解Http的Content-Type

    目录 1.概述 2.常用类型 2.1.application/x-www-form-urllencoded 2.2.application/json 3.Spring MVC支持的编码 3.1.实验 3.2.适配器 3.3.自定义适配器 HTTP(HyperText Transfer Protocol),超文本传输协议。超文本(Hypertext)是一种结构化的文本,其中包含了超链接(Hyperlink)的能力,通过超链接可以在不

    2024年02月09日
    浏览(40)
  • RabbitMQ实现延迟消息,RabbitMQ使用死信队列实现延迟消息,RabbitMQ延时队列插件

    假设有一个业务场景:超过30分钟未付款的订单自动关闭,这个功能应该怎么实现? RabbitMQ使用死信队列,可以实现消息的延迟接收。 队列有一个消息过期属性。就像丰巢超过24小时就收费一样,通过设置这个属性,超过了指定事件的消息将会被丢弃。 这个属性交:x-message

    2024年02月13日
    浏览(79)
  • Centos安装RabbitMQ,JavaSpring发送RabbitMQ延迟延时消息,JavaSpring消费RabbitMQ消息

    erlang 和 rabbitmq 版本说明 https://www.rabbitmq.com/which-erlang.html 确认需要安装的mq版本以及对应的erlang版本。 RabbitMQ下载地址: https://packagecloud.io/rabbitmq/rabbitmq-server Erlang下载地址: https://packagecloud.io/rabbitmq/erlang RabbitMQ延迟消息插件下载 https://github.com/rabbitmq/rabbitmq-delayed-message-exc

    2024年02月08日
    浏览(51)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包