初出茅庐的小李博客之用MQTT.fx软件进行消息发布与订阅【基于EMQX Cloud】

本文主要是介绍初出茅庐的小李博客之用MQTT.fx软件进行消息发布与订阅【基于EMQX Cloud】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

MQTT.fx软件使用简单介绍

在这里插入图片描述
MQTT.fx 的软件界面如下图所示，最上方为 MQTT Broker 连接地址栏，及其连接配置。其下方功能 Tabs 含有 Publish 发布栏、Subscribe 订阅栏、Scripts 脚本栏、Broker Status 状态消息栏、Log 日志信息控制栏。

连接之前要明确几个概念

以下概念仅供学习参考，个人理解描述可能不严谨

概念1：什么是消息发布

我的个人理解就是一个设备是作为信息提供的一方也就是信息的生产者

概念2：什么是消息订阅

我的个人理解就是一个设备作为消息获取的以防也就是信息的消费者

概念3：什么是主题

我的个人理解就是设备进行信息交互的平台可以类比公众号我订阅了某个公众号那这个公众号将来更新了文章我就可以阅读，信息的消费者获取信息的一个渠道，同时信息的生产者也可以把信息传到上面供信息的消费者使用，这个公众号就是一个转发信息的桥梁

MQTT客户端跟MQTT服务器都可以进行信息的发布

在这里插入图片描述

MQTT客户端一旦连接到服务端，便可以发布消息。每条发布的MQTT消息必须包含一个主题。MQTT服务器可以通过主题确定将消息转发给哪些客户端。（注：这里的消息指的是MQTT报文。）

在建立通信前简单提一下QoS（Quality of Service）QoS表示MQTT消息的服务质量等级。QoS有三个级别：0、1和2。QoS决定MQTT通讯有什么样的服务保证。
QoS：发布消息的服务质量，即：保证消息传递的次数
00：最多一次，即：<=1
01：至少一次，即：>=1
10：一次，即：=1
11：预留

什么是报文标识符
报文标识符可用于对MQTT报文进行标识。不同的MQTT报文所拥有的标识符不同。MQTT设备可以通过该标识符对MQTT报文进行甄别和管理。请注意：报文标识符的内容与QoS级别有密不可分的关系。只有QoS级别大于0时，报文标识符才是非零数值。如果QoS等于0，报文标识符为0。这里不展开说如果大家对这个协议感兴趣大家可以看MQTT协议的详细文档
我这里简单描述下
在MQTT协议中规定了一个固定报头固定报头的第一个字节有8个bit
其中高4位的排列组合表示MQTT数据包的类型，
在这里插入图片描述
总共4个bit 排列组合有16种情况分别是以下类型

0 Reserved — 保留
1 CONNECT 客户端到服务器客户端请求连接到服务器
2 CONNACK 服务器到客户端连接确认
3 PUBLISH 双向发布消息
4 PUBACK 双向发布确认
5 PUBREC 双向发布收到（保证第1部分到达）
6 PUBREL 双向发布释放（保证第2部分到达）
7 PUBCOMP 双向发布完成（保证第3部分到达）
8 SUBSCRIBE 客户端到服务器客户端请求订阅
9 SUBACK 服务器到客户端订阅确认
10 UNSUBSCRIBE 客户端到服务器请求取消订阅
11 UNSUBACK 服务器到客户端取消订阅确认
12 PINGREQ 客户端到服务器 PING请求
13 PINGRESP 服务器到客户端 PING应答
14DISCONNECT 客户端到服务器中断连接
15Reserved — 保留

Qos 就是PUBLIS 数据包的低4位的bit2 bit1 其他数据包这两位有其他的含义或者保留
在这里插入图片描述

保留标志的理解

在默认情况下，当客户端订阅了某一主题后，并不会马上接收到该主题的信息。只有在客户端订阅该主题后，服务端接收到该主题的新信息时，服务端才会将最新接收到的该主题信息推送给客户端。
但是在有些情况下，我们需要客户端在订阅了某一主题后马上接收到一条该主题的信息。这时候就需要用到保留标志这一信息。

有效载荷的理解

有效載荷是我们希望通过MQTT所发送的实际内容。我们可以使用MQTT协议发送文本，图像等格式的内容。这些内容都是通过有效載荷所发送的。

重发标志的理解

当MQTT报文的接收方没有及时确认收到报文时，发送方会重复发送MQTT报文。在重复发送MQTT报文时，发送方会将此“重发标志”设置为true。请注意，重发标志只在QoS级别大于0时使用。因为大于0 表示【01】：至少一次，即：>=1 【10】：一次，即：=1

连接设置可以参考我上一篇博客

这里已经连接成功
在这里插入图片描述

订阅/发送消息
完成连接的建立之后，即可开始订阅消息。因为 MQTT 协议采用的是订阅/推送的方式，所以我们需要在连接之后订阅主题，之后主题上有消息产生即可收到来自 EMQX Cloud 推送。

我在 EMQX Clouds 开启了数据功能
在这里插入图片描述
这里的操作需要用到SQL 语言我不太了解就用示例的几个例子进行了简单的配置

具体配置如下
在这里插入图片描述
我的理解是当客户端建立了对这个主题的连接时候会触发一个事件这个事件会触发一个消息
消息是JSON 格式

订阅主题

订阅两个主题：

在这里插入图片描述

向某个主题发布消息

这是向AQST/TEST 发布的消息
在这里插入图片描述
这是收到AQST/TEST 发布的消息

这是向t/a这个主题发布的消息

这是订阅了t/a这个主题收到的消息

至此：
两个主题的订阅跟发布都测试通过了
看一下后台数据记录，连接数最多就是1 订阅最多是2 报文流量根据发送的信息数据量也不一样。