乐趣区

关于物联网:MQTT-保留消息是什么如何使用

jiezi

什么是 MQTT 保留音讯？

发布者公布音讯时，如果 Retained 标记被设置为 true，则该音讯即是 MQTT 中的保留音讯（Retained Message）。MQTT 服务器会为每个主题存储最新一条保留音讯，以不便音讯公布后才上线的客户端在订阅主题时仍能够接管到该音讯。

如下图，当客户端订阅主题时，如果服务端存在该主题匹配的保留音讯，则该保留音讯将被立刻发送给该客户端。

何时应用 MQTT 保留音讯？

公布订阅模式尽管能让音讯的发布者与订阅者充沛解耦，但也存在一个毛病，即订阅者无奈被动向发布者申请音讯。订阅者何时收到音讯齐全依赖于发布者何时公布音讯，这在某些场景中就产生了不便。

借助保留音讯，新的订阅者可能立刻获取最近的状态，而不须要期待无奈预期的工夫，例如：

  • 智能家居设施的状态只有在变更时才会上报，然而管制端须要在上线后就能获取到设施的状态；
  • 传感器上报数据的距离太长，然而订阅者须要在订阅后立刻获取到最新的数据；
  • 传感器的版本号、序列号等不会常常变更的属性，可在上线后公布一条保留音讯告知后续的所有订阅者。

MQTT 保留音讯的应用

若要应用 MQTT 保留音讯，只需在音讯公布时将 Retained 状态设置为 true 即可。接下来咱们以开源的跨平台 MQTT 5.0 桌面客户端工具 – MQTT X 为例，演示如何应用 MQTT 保留音讯。

关上 MQTT X 后如下所示，需点击 New Connection 按钮创立一个 MQTT 连贯。

创立页面如下，咱们只需填写一个连贯名称（Name），其余参数放弃默认。Host 将默认为 EMQX Cloud 提供的公共 MQTT 服务器。连贯参数填写实现后，点击右上角的 Connect 按钮创立 MQTT 连贯。

连贯胜利后将会看到连贯名称旁边的状态为绿色。而后咱们在右下角音讯输入框向主题 sensor/t1 发送一条一般的音讯。

接下来咱们选中右下角的 Retain 标记，并向主题 sensor/t2 发送两条保留音讯。

而后点击页面两头的 New Subscription 按钮创立订阅。

如下，咱们订阅通配符主题 sensor/+，该通配符主题将会匹配主题 sensor/t1 及 sensor/t2。

对于通配符主题的更多细节，请查看博客通过案例了解 MQTT 主题与通配符。

最初，咱们将会看到该订阅能胜利收到第二条保留音讯，sensor/t1 的一般音讯及 sensor/t2 的第一条保留音讯都未收到。可见 MQTT 服务器只会为每个主题存储最新一条保留音讯。

对于 MQTT 保留音讯的 Q&A

如何判断一条音讯是否是保留音讯？

当客户端订阅了有保留音讯的主题后，即会收到该主题的保留音讯，可通过音讯中的保留标记位判断是否是保留音讯。须要留神的是，在保留音讯公布前订阅主题，将不会收到保留音讯。须要待保留音讯公布后，从新订阅该主题，才会收到保留音讯。

如下图，咱们先订阅主题 sensor/t2，而后向该主题公布一条保留音讯，该订阅会立刻收到一条音讯，然而该音讯并不是保留音讯。当咱们删除该订阅，再次从新订阅 sensor/t2 主题时，立刻收到了刚刚公布的保留音讯。

保留音讯将保留多久？如何删除？

服务器只会为每个主题保留最新一条保留音讯，保留音讯的保留工夫与服务器的设置无关。若服务器设置保留音讯存储在内存，则 MQTT 服务器重启后音讯即会失落；若存储在磁盘，则服务器重启后保留音讯依然存在。

保留音讯尽管存储在服务端中，但它并不属于会话的一部分。也就是说，即使公布这个保留音讯的会话已完结，保留音讯也不会被删除。删除保留音讯有以下几种形式：

  • 客户端往某个主题发送一个 Payload 为空的保留音讯，服务端就会删除这个主题下的保留音讯；
  • 在 MQTT 服务器上删除，比方 EMQX MQTT 服务器提供了在 Dashboard 上删除保留音讯的性能；
  • MQTT 5.0 新增了音讯过期间隔属性，公布时可应用该属性设置音讯的过期工夫，不论音讯是否为保留音讯，都将会在过期工夫后主动被删除。

EMQX 中的 MQTT 保留音讯

EMQX 是一款寰球下载量超千万的大规模分布式物联网 MQTT 服务器，于 2013 年在 GitHub 公布开源版本。

不久前，EMQX 公布了 5.0 版本，该版本通过一个 23 节点的集群达成了 1 亿 MQTT 连贯 + 每秒 100 万音讯吞吐，这使得 EMQX 5.0 成为目前为止寰球最具扩展性的 MQTT 服务器。

EMQX 5.0 反对在内置的 Dashboard 中查看、设置保留音讯。感兴趣的读者可通过如下 Docker 命令装置 EMQX 5.0 开源版进行体验。

docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:latest

EMQX 装置胜利后，应用浏览器拜访 http://127.0.0.1:18083/ 即可体验 EMQX 5.0 全新 Dashboard。

默认用户名为 admin，明码为 public

登录胜利后，可在左侧菜单 System -> Settings 中批改显示语言为中文。如下图，可点击 性能配置 ->MQTT 菜单查看已保留的音讯列表，同时也能够查看保留音讯的 Payload 或者删除某条保留音讯。

点击保留音讯下的 设置 菜单，可看到 EMQX 反对在 Dashboard 中设置保留音讯的存储类型（内存或磁盘）、最大保留音讯数、保留音讯有效期等参数，点击保留后所有更改将会立刻失效。

结语

本文对 MQTT 保留音讯进行了介绍及应用演示，用户能够参考本文更好地利用 MQTT 保留音讯解决订阅后无奈立刻获取最近数据的问题。除此之外，MQTT 协定还具备更多实用个性，读者可查看 EMQ 提供的 MQTT 入门与进阶系列文章进行深刻理解，摸索 MQTT 的更多高级利用，开启 MQTT 利用及服务开发。

版权申明：本文为 EMQ 原创，转载请注明出处。

原文链接：https://www.emqx.com/zh/blog/mqtt5-features-retain-message

退出移动版