问题描述
在Qt发开过程中使用qtmqtt库来连接onenet
的mqtt服务器,在ClientId、Username和Password均填写正确的情况下还是连接不上,查看错误显示QMQTT::SocketRemoteHostClosedError
。
解决方法
client中的CleanSession
标志位必须设置为true
。
client = new QMQTT::Client;client->setHostName("183.230.40.96"); // 服务器IPclient->setPort(1883); // 服务器端口client->setClientId("XXX"); // 设备名称client->setUsername("XXX"); // 产品IDclient->setPassword("XXX"); // 鉴权信息,使用Token工具生成client->setVersion(QMQTT::MQTTVersion::V3_1_1); // 设置MQTT协议版本client->setKeepAlive(60); // 设置保持连接时间client->setCleanSession(true); // 设置会话标志为true
分析过程
排除环境问题和qtmqtt库问题
- 在主机中下载
MQTTX
工具,使用MQTTX
连接onenet
服务器。-> 连接成功 - 使用
qtmqtt
库来连接主机内自己搭建的mosquitto
的MQTT
服务器。-> 连接成功
使用Wireshark工具抓包来分析报文内的信息
- qtmqtt库连接onenet服务器发送的报文如下图所示:
- MQTTX工具连接onenet服务器发送的报文如下图所示:
显而易见qtmqtt
库最后发送FIN, ACK
意味着断开连接,而MQTTX
工具最后一个报文发送ACK
表示成功建立连接,紧接着分析MQTT协议中的内容。 - 以下为
qtmqtt
库发送报文中MQTT协议中的内容:
- 以下为
MQTT
工具发送报文中MQTT协议中的内容:
从上图可以发现两者的MQTT协议中只有Clean Session Flag Set
这个标志位是不同的,那么原因就找到了,连接onenet
的MQTT服务器必须将Clean Session Flag Set
标志位设置为1。那么在Qt中增加clinet->setCleanSession(true);
就可以解决这个问题,成功连接上onenet
的MQTT服务器了。