在RabbitMQ中使用新的MQTT 5.0功能

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

MQTT是物联网(IoT)的标准协议,是轻量级的,协议头很小,可以节省网络带宽。MQTT也很有效,与其他消息传递协议相比,客户端通过更短的握手进行连接和身份验证。

以下是本文介绍的MQTT 5.0功能列表:

功能1:消息过期

可以为发布到代理的每条消息设置以秒为单位的过期时间(message-expiry-interval)。如果消息未在到期前被消费,则该消息将被丢弃或标记为死信。

如果队列通过参数 x-dead-letter-exchange 设置了死信交换器,则过期的消息会进入死信交换器,最终进入与死信交换器绑定的队列,即死信队列。

功能2:订阅标识符

客户端可以在订阅时设置订阅标识符(subscription-identifier)。当有匹配该订阅的消息发送给此客户端时,代理会将该订阅标识符包含在PUBLISH数据包中。客户端使用通配符订阅多个主题时,可以通过消息中的订阅标识符区分消息来自哪个订阅。

功能3:订阅选项

QoS

表示服务端在向订阅端发送消息时可以使用的最大 QoS 等级。

0:最多交付一次,可能丢失消息。

1:至少交付一次,可以保证收到消息,但消息可能重复。

2:只交付一次,可以保证消息既不丢失也不重复。QoS等级从低到高,不仅意味着消息可靠性的提升,也意味着传输复杂程度的提升。

No Local

有 0 和 1 两个可取值,为 1 表示服务端不会将消息转发到ClientID等于发布消息的ClientID的客户端,为 0 则相反。

Retain As Publish

有 0 和 1 两个可取值,为 1 表示服务端在向此订阅转发应用消息时需要保持消息中的 Retain 标识不变,为 0 则表示必须清除。

Retain Handling

指定在建立订阅时是否发送保留的消息。

0:在订阅时发送保留的消息。

1:仅当订阅当前不存在时,才在订阅时发送保留消息。

2:在订阅时不发送保留的消息。

功能4:原因码

数据包 CONNACK、PUBACK、PUBREC、PUBREL、PUBCOMP、SUBACK、UNSUBACK、DISCONNECT 和 AUTH 包含原因码。小于 0x80 的原因码用于表示成功,大于等于 0x80 的原因码则用于表示失败。

功能5:用户属性

大多数MQTT数据包可以包含用户属性(user-properties)。MQTT规范没有定义用户属性的含义。

功能6:有效载荷标识和内容类型

消息发布者可以指定MIME内容类型(content-type),如 text/plain 表示文本文件,audio/aac 表示音频文件。还可以设置一个载荷标识符(payload-format-indicator),指示Payload是由UTF-8编码的字符数据还是其它数据组成。

功能7:请求/响应

在发布消息之前,MQTT客户端(请求者)订阅了一个响应主题(response-topic)。请求者将响应主题和一些相关数据包(correlation-data)括在请求消息中。

另一个MQTT客户端(响应者)接收请求消息,执行一些操作,并将带有相同相关数据的响应消息发布到响应主题。

该特性对应于高级消息队列协议中的远程过程调用(Remote Procedure Calls),对于一些投递要求比较严格的消息,可以通过请求/响应来确认消息是否到达订阅端。

功能8:分配的客户端标识符

如果客户端使用零长度的客户端标识符进行连接,则服务器必须使用包含指定客户端标识符的CONNACK进行响应。

功能9:主题别名

主题别名是一个整数值,代替主题名称标识主题。可减少PUBLISH数据包的大小,在主题名称较长并且在一个网络连接中重复使用相同的主题名称时非常有用。

功能10:流量控制

属性Receive Maximum定义了未确认的QoS为1和2的PUBLISH报文最大数量。

功能11:最大数据包大小

客户端和服务器可以独立指定它们支持的最大数据包大小。

功能12:服务器发起的DISCONNECT

DISCONNECT数据包不仅可以从客户端发送到服务器,还可以从服务器发送到客户端。

功能13:会话过期

客户端可以在CONNECT数据包中向服务器建议会话过期间隔(session-expiry-interval)。服务器可以接受所提出的会话到期间隔,或者在CONNACK分组中指定不同的会话到期时间间隔。

当会话到期间隔到期时,客户端和服务器都将删除任何会话状态。

功能14:遗嘱延迟

客户端可以在CONNECT数据包中定义遗嘱延迟间隔(will-delay-interval)。服务器会在遗嘱延迟间隔到期或会话过期间隔到期(以先发生的为准)时发布客户端的遗嘱消息。遗嘱延迟间隔的一个重要用途是,避免在设备因网络波动临时断开连接,但能快速恢复连接继续会话时发出遗嘱消息。文章来源地址https://www.toymoban.com/news/detail-734565.html

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

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

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

相关文章

  • RabbitMQ-网页使用消息队列

    几种模式 从最简单的开始 添加完新的虚拟机可以看到,当前admin用户的主机访问权限中新增的刚添加的环境 1.1查看交换机 交换机列表中自动新增了刚创建好的虚拟主机相关的预设交换机。一共7个。前面两个 direct类型的交换机,一个是(AMQP default)还有一个是amq.direct,它们

    2024年02月07日
    浏览(40)
  • RabbitMQ 消息队列使用

    同步调用优点: 时效性强,立即得到结果 缺点: 耦合度高 新业务新需求到来时,需要修改代码 性能和吞吐能力下降 调用服务的响应时间为所有服务的时间之和 资源浪费 调用链中的服务在等待时不会释放请求占用的资源 级联失败 一个服务执行失败会导致调用链后续所有服务失

    2024年01月21日
    浏览(46)
  • Hyperf使用RabbitMQ消息队列

    Hyperf连接使用RabbitMQ消息中间件 使用Docker部署RabbitMQ,-传送门 使用Docker部署Hyperf,-传送门- 安装amqp扩展 安装command命令行扩展 配置参数 假设已经在rabbitmq设置了交换机exchange_test和队列queue_test 新建 /config/autoload/amp.php配置文件,修改地址和用户名密码 创建生产者中间件 exch

    2024年02月13日
    浏览(43)
  • Golang使用消息队列(RabbitMQ)

    最近在使用Golang做了一个网盘项目(类似百度网盘),这个网盘项目有一个功能描述如下:用户会删除一个文件到垃圾回收站,回收站的文件有一个时间期限,比如24h,24h后数据库中记录和oss中文件会被删除,在之前的版本中,可以使用定时任务来检查数据库记录中删除时间

    2024年02月10日
    浏览(52)
  • 消息队列RabbitMQ.01.基本使用

    目录  RabbitMQ的作用 Message queue 释义  问题思考  存在的问题 优化方案  案例分析  带来的好处  消息队列特点  Email邮件案例分析 Docker安装部署RabbitMQ 1.下拉镜像 2.运行RabbitMQ  3.打开防火墙端口号并重新运行防火墙 4.容器启动后,可以通过 docker logs 容器 查看日志 6.通过刚才

    2024年01月21日
    浏览(41)
  • Java RabbitMQ消息队列简单使用

    消息队列,即MQ,Message Queue。 消息队列是典型的:生产者、消费者模型。生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的解耦。

    2024年02月12日
    浏览(58)
  • SSM 如何使用 RabbitMQ 实现消息队列

    在分布式系统中,消息队列是一种常见的通信方式,可以实现不同服务之间的异步通信和解耦。RabbitMQ 是一个开源的消息队列软件,本文将介绍如何在 SSM 框架中使用 RabbitMQ 实现消息队列。 本文将使用 Spring Boot 作为 SSM 框架,使用 Maven 进行项目管理。 在开始之前,需要安装

    2024年02月06日
    浏览(55)
  • Thinkphp6使用RabbitMQ消息队列

    Thinkphp6连接使用RabbitMQ(不止tp6,其他框架对应改下也一样),使用Docker部署RabbitMQ,在上一篇已经讲了-传送门-。 开始前先进入RabbitMQ的web管理界面,选择Queues菜单,点击底部的Add a new queue,新建一个test的队列。 安装thinkphp6框架 安装workerman扩展 安装rabbitmq扩展 生产者 在a

    2023年04月23日
    浏览(75)
  • 消息队列RabbitMQ.01.安装部署与基本使用

    目录  RabbitMQ的作用 Message queue 释义  问题思考  存在的问题 优化方案  案例分析  带来的好处  消息队列特点  Email邮件案例分析 Docker安装部署RabbitMQ 1.下拉镜像 2.运行RabbitMQ  3.打开防火墙端口号并重新运行防火墙 4.容器启动后,可以通过 docker logs 容器 查看日志 6.通过刚才

    2024年01月24日
    浏览(42)
  • TP5简单使用RabbitMQ实现消息队列

    在使用 RabbitMQ 之前,你要安装好 RabbitMQ 服务,具体安装方法可以参考 windows下安装RabbitMQ 1、安装扩展 进入TP5 更目录下,输入命令安装: composer require php-amqplib/php-amqplib 2、自定义命令 TP5 的自定义命令,这里也简单说下。 第一步: 创建命令类文件,新建 application/api/command

    2024年02月07日
    浏览(52)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包