关于ESP8266使用mqtt发布信息给腾讯云问题及解决方案！

Jack_tang

最近在学习ESP8266的MQTT事，我通过MQTT连接到腾讯云MQTT服务器。现在ESP8266可以订阅并接收来自腾讯云MQTT的信息，但是在使用mqtt发布上报信息给腾讯云时出现了问题。
上报信息的JOSN格式："{\"method\":\"report\",\"clientToken\":\"xxxxx-8gauvcWJrb\",\"params\":{\"switch_1\": 1}}"
但是腾讯云无法接收到完成的上报信息，因为我使用在线调试只能看到report_reply消息，但是无法查看到report消息。而我用MQTT.fx软件模拟时，当我只发送{"method": "report"}时会出现这样的现在。但是当我发送完整的JOSN上报信息时就不会只有report_reply消息。

MQTT.fx模拟正常的JOSN上报数据：


MQTT.fx模拟异常的JOSN上报数据：


目前ESP8266使用以下代码，将JOSN数据上报给腾讯云会出现和MQTT.fx模拟异常的JOSN上报数据现象。

1. #define TEST_SW1_REPORT_OFF "{"method":"report","clientToken":"MBN7N5MMO8-8gauvcWJrb","params":{"switch_1": 0}}"

复制代码

1. void mqttDataCb(uint32_t *args, const char* topic, uint32_t topic_len, const char *data, uint32_t data_len)
   
2. {
   
3.     char *topicBuf = (char*)os_zalloc(topic_len+1),
   
4.             *dataBuf = (char*)os_zalloc(data_len+1);
   
5. 
   
6.     uint8_t res = 0;
   
7.     static uint8_t flag = 0;
   
8. 
   
9.     MQTT_Client* client = (MQTT_Client*)args;
   
10. //===========如果数据接收出现丢失，应该使用环形缓冲区来保存没有来得及处理的数据================
    
11.     os_memcpy(topicBuf, topic, topic_len);
    
12.     topicBuf[topic_len] = 0;
    
13. 
    
14.     os_memcpy(dataBuf, data, data_len);
    
15.     dataBuf[data_len] = 0;
    
16. 
    
17.     INFO("Receive topic: %s, data: %s \r\n", topicBuf, dataBuf);
    
18. 
    
19.     //===解析JOSN数据====
    
20.     res = Parse_Josn_data(dataBuf,&sw_status);
    
21.     if(res == JOSN_OK)        //成功获取到腾讯云发的“智能插座”MQTT的JOSN并解析
    
22.     {
    
23.         //====执行命令========
    
24.         smartSW_action.Control(sw_status);
    
25.         if(flag == 1)
    
26.         {
    
27.                 flag = 0;
    
28.                 MQTT_Publish(client, MQTT_UP_TOPIC, TEST_SW2_REPORT_OFF, os_strlen(TEST_SW2_REPORT_OFF) + 1, 0, 0);
    
29.                 INFO("flag = 1\n");
    
30.                 INFO(TEST_SW2_REPORT_OFF)
    
31.                 INFO("\n");
    
32.         }
    
33.         else
    
34.         {
    
35.                 flag = 1;
    
36.                 MQTT_Publish(client, MQTT_UP_TOPIC, TEST_SW2_REPORT_ON, os_strlen(TEST_SW2_REPORT_ON) + 1, 0, 0);
    
37.                 INFO("flag = 0\n");
    
38.                 INFO(TEST_SW2_REPORT_ON)
    
39.                 INFO("\n");
    
40.         }
    
41. 
    
42.     }
    
43. 
    
44.     os_free(topicBuf);
    
45.     os_free(dataBuf);
    
46. }

复制代码

解决方法及分析过程：
原因：多发了一个字节的00数据。其实就是在发送JOSN字符串时，考虑了字符串的结束标志'\0'

1. 通过WireShark抓包工具抓取MQTT的PUBLISH报文数据包


数据：
30 57 00 29 24 74 68 69 6e 67

2f 75 70 2f 70 72 6f 70 65 72 74 79 2f 4d 42 4e

37 4e 35 4d 4d 4f 38 2f 53 6d 61 72 74 5f 53 57

30 30 31 7b 22 6d 65 74 68 6f 64 22 3a 22 72 65

70 6f 72 74 22 2c 22 70 61 72 61 6d 73 22 3a 7b

22 73 77 69 74 63 68 5f 32 22 3a 20 30 7d 7d

2. 在ESP8266的SDK开发源代码中获取到的PUBLISH消息数据包内容。


数据：
30 58 00 29 24 74 68 69 6e 67 2f 75 70 2f 70 72 6f 70 65 72 74 79 2f 4d 42 4e 37 4e 35 4d 4d 4f 38 2f 53 6d 61 72 74 5f 53 57 30 30 31 7b 22 6d 65 74 68 6f 64 22 3a 22 72 65 70 6f 72 74 22 2c 22 70 61 72 61 6d 73 22 3a 7b 22 73 77 69 74 63 68 5f 32 22 3a 20 31 7d 7d 00

总结：
通过比较两个数据包的内容很容易发现，在串口输出的信息中多了一个字节的00数据。再结合ESP8266 SDK开发中的源代码，在调用MQTT_Publish（）函数中发送的时多了一个字节(考虑到了字符串结束标志....)。

即将以下代码

1. MQTT_Publish(client, MQTT_UP_TOPIC, TEST_SW2_REPORT_ON, os_strlen(TEST_SW2_REPORT_ON) + 1, 0, 0);

复制代码

修改为正确的代码

1. MQTT_Publish(client, MQTT_UP_TOPIC, TEST_SW2_REPORT_ON,os_strlen(TEST_SW2_REPORT_ON),0,0);

复制代码

Jack_tang

大神帮忙看下，为什么会这样？MQTT发送report报文给腾讯服务器会收不到？
用的是ESP8266_NONOS_SDK-3.0.4下的mqtt例程。

答：已经解决了。哈哈！

Kiwi2021

最近在学习ESP8266的MQTT事，我通过MQTT连接到腾讯云MQTT服务器。现在ESP8266可以订阅并接收来自腾讯云MQTT的信息，但是在使用mqtt发布上报信息给腾讯云时出现了问题。
[天津快乐十分]https://www.1680380.com/view/klsf_tianjin/klsf_index.html
上报信息的JOSN格式："{\"method\":\"report\",\"clientToken\":\"xxxxx-8gauvcWJrb\",\"params\":{\"switch_1\": 1}}"
但是腾讯云无法接收到完成的上报信息，因为我使用在线调试只能看到report_reply消息，但是无法查看到report消息。
[幸运飞艇]https://www.1680380.com/view/xingyft/pk10kai.html
而我用MQTT.fx软件模拟时，当我只发送{"method": "report"}时会出现这样的现在。但是当我发送完整的JOSN上报信息时就不会只有report_reply消息。
[福彩双色球]https://1680380.com/view/fcssq/index.html

AiThinker-半颗心脏

666