实例：使用MQTT进行交互

最近在着手研究使用网页控制硬件的交互过程，发现mqtt协议有很多种语言的封装，整个思路也很清晰，就是一个客户端进行发布和订阅+服务器中间代理的过程，于是开始学习使用MQTT框架搭建交互平台。
客户端使用了MQTTjs，服务器使用mosca（基于nodejs）。

QoS在MQTT中有（摘自 MQ 遥测传输 (MQTT) V31 协议规范 ）：

MQTTjs只是支持了MQTT协议，并没有支持QoS，也就是说，只支持最低级别的“至多一次”（QoS0）。

在MQTT协议中，一个MQTT数据包由：固定头（Fixed header）、可变头（Variable header）、消息体（payload）三部分构成。
这里只了解消息体，固定头和可变头并不需要我们手动写。
payload消息体包含CONNECT、SUBSCRIBE、SUBACK、UNSUBSCRIBE四种类型的消息：

（1）Connect    与服务器建立连接。
（2）Disconnect    与服务器断开TCP/IP会话。
（3）Subscribe    订阅。
（4）UnSubscribe    取消订阅。
（5）Publish    发送消息请求，发送完成后返回应用程序线程。
二、实现（具体的API稍后呈现）

MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议。它是一种发布/订阅，极其简单和轻量级的消息传递协议，专为受限设备和低带宽，高延迟或不可靠的网络而设计。它的设计思想是轻巧、开放、简单、规范，易于实现。这些特点使得它对很多场景来说都是很好的选择，特别是对于受限的环境如机器与机器的通信（M2M）以及物联网环境。相对于XMPP，MQTT更加轻量级，并且占用的宽带低。

MQTT协议有以下特点：

那么问题来了？重连连接成功后重复接收到最后一条消息
MQTT推送消息订阅端重复接收问题。
（背景）订阅端断开的时候，发布端多次推送消息。
（现象）订阅端启动时，接收到最后一条推送消息有两次；即使Qos设置为2；依然是两次。
经排查是因为
MqttMessage的Retained设置为了true;
该值很多文章上只说了是 消息保留机制，若设置为true，mqtt服务器会保留每次发布的消息；较少提到 若订阅某主题的客户端重启，则会把此主题之前发布的消息重新推送到客户端。该值默认为false;去掉修改该值即可
那么问题来了？重连连接后手动那么多遗漏的消息，怎么选择只接收最新的一条消息呢？
MQTT推送消息订阅端重复接收问题。
（背景）订阅端断开的时候，发布端多次推送消息。
（现象）订阅端启动时，接收到msg1，msg2，msg3 （这三个消息都是同一个类型消息，只需要处理最新的msg3就好，不然界面会刷新三次）这个谁有什么好办法没呢？

GitHub地址： >

本文将介绍使用 Node-RED 连接到 MQTT 服务器，并对 MQTT 数据进行过滤和处理后再将其发送至 MQTT 服务器的完整 *** 作流程。读者可以快速了解如何使用 Node-RED 对 MQTT 数据进行简单的流处理。

Node-RED 无论是在你本地的电脑上，还是树莓派等设备，亦或是云端服务器，都可以快速安装和使用，下面将使用两种比较常见的安装方式：

使用 npm 进行全局安装：

使用 Docker 进行安装：

如果使用的是 npm 进行的全局安装，那么在提示安装成功后，只需要在全局运行 node-red 命令就可以立即启动 Node-RED。

无论是使用 Docker 还是 npm 在启动成功后，我们只需要打开浏览器，输入当前地址加 1880 端口号，即可打开 Node-RED 的浏览器编辑器页面，例如在本地运行的话，打开浏览器，输入 >

首先需要搭建MQTT服务器，然后搭建MySQL数据库，然后使用海为组态写段程序，最后配置客户端验证即可。具体可以参考内容 Haiwell（海为）HMI/CBOX/IPC MQTT 配置应用教程 网页链接

MQTT-SN的架构如图1所示。有3种类型的MQTT-SN组件：MQTT-SN客户端、MQTT-SN网关、MQTT-SN转发器。MQTT-SN客户端使用MQTT-SN协议连接到MQTT-SN网关，再连接到MQTT服务端。MQTT-SN网关可以集成到MQTT服务端里。如果是做为独立的网关，则MQTT服务端和MQTT-SN网关间将采用MQTT协议，它的主要功能就是MQTT和MQTT-SN之间的转换。
当客户端所在的网络无法直接连接到网关时，客户端也可以通过转发器来存取网关。转发器将它在无线网络侧所接收到的MQTT-SN侦进行简单封包，然后原封不动地发送给网关；相反的，它将从网关侧接收到的侦解封，然后同样原封不动地发送到客户端。
基于网关在MQTT和MQTT-SN间转发所起的作用，我们可以区分出2种类型的网关：透明网关和集聚网关。

对于每个连接的MQTT-SN客户端，透明网关将会和MQTT服务端建立并维护一个MQTT连接。该MQTT连接将会单独为端到端通信保留，而且对于客户端和服务端间的消息交换是透明的。有多少MQTT-SN客户端连接到网关，在网关和服务端之间就有多少MQTT连接。透明网关在两协议间将扮演语法翻译器的角色。因为MQTT-SN客户端和MQTT服务端间的所有消息交换是端到端的，所以服务端可以向客户端提供其实现的所有功能和特性。
虽然和集聚网关比起来，透明网关的实现比较简单，但是它要求服务端支持为每个活动的客户端保持一个单独的连接。一些MQTT服务端实现可能在能支持的并发连接数上有所限制。

不同于每个连接的客户端都有一个MQTT连接，集聚网关将只有一个到服务端的MQTT连接。MQTT-SN客户端到集聚网关的所有信息交换将只到网关。由网关决定哪些信息将进一步传递到服务端。虽然集聚网关的实现比透明网关更复杂，但它在拥有大量传感器的无线传感网络中是非常有用的，因为它减少了服务端必须并发支持的MQTT连接数。

MQTT不存在上传和下发的定义，只有以topic为单位的推送和订阅。你的情况描述是服务器能看到推送的消息，说明网络、broker配置没有问题，要保证“服务器下发给客户端”能顺利实现的话请确认以下几点：

服务器端推送到的topic和客户端订阅的topic是一致的

本地设备开启了1883端口（或者你自定义的端口号），防火墙没有拦截

如果是自己写代码的话，客户端的on message回调函数里解析报文的逻辑是正确

---