在 PIC 微控制器中实现 MQTT

Question

我正在尝试使用 sim 900 gprs 调制解调器在 pic 微控制器中实现 MQTT 协议，我已经阅读了 mqtt 文档版本 3.1。成功地我可以使用以下命令从 gprs 调制解调器连接到 myserver ip(117.218.81.15) ...

1. 在
2. AT+CPIN?
3. AT+CREG?
4. AT+CGATT?
5. AT+CIPSHUT
6. AT+CIPSTATUS
7. AT+CIPMUX=0
8. AT+CSTT=\"INTERNET\",\"\",\"\"
9. AT+CIICR
10. AT+CIFSR

11. AT+CIPSTART= \"TCP\" , \"117.218.81.15\", \"1883\"

    根据 MQtt 协议的文档，我编写了连接数据包功能。 建立 tcp 连接后，我尝试发送 connect_packet() 函数，但没有从经纪人那里得到任何确认。请帮我解决这个问题 我用wireshark网络分析工具检查了我的数据到达1883 tcp端口，但我不知道为什么我没有得到任何确认？ connect_packet 代码为 unsigned char topiclen = 0,time_out1=0,time_out2=0; unsigned char connectdatalen,packetlen; memset(buffer,0,sizeof(buffer)); time_out1 = (time_out >>8) & 0XFF; time_out2 = (time_out & 0XFF); topiclen = strlen(sacketid); connectdatalen = 2 + 6 + 1 + 1 + 2 + 2 + topiclen;
packetlen = 2 + connectdatalen;
buffer[0] = 0X10; buffer[1] = connectdatalen; buffer[2] = 0x00; buffer[3] = 0X06; buffer[4] = 'M'; buffer[5] = 'Q'; buffer[6] = 'I'; buffer[7] = 's'; buffer[8] = 'd'; buffer[9] = 'p'; buffer[10] = 0x03; buffer[11] = 0x02; buffer[12] = time_out1; buffer[13] = time_out2; buffer[14] = (topiclen >> 8); buffer[15] = topiclen & 0XFF; for(i=0;i<packetlen;i++) { buffer[(i+16)] = sacketid[i]; } uart_puts(buffer); uart_puts("\x1A"); 在 void main 函数中，代码是 uart_init(9600,16); DelayMs(100); gprs_init(); gprs_tcpconnect(); DelayMs(200); connect_packet("MQTT",180); memset(buffer,0,sizeof(buffer));

Answer 1

希望您已经找到解决方案，因为它是一个旧帖子。

如果您遵循 MQTT-3.1.1 规范，您应该检查协议名称“MQIsdp”我认为它必须是“MQTT”。 MQTT 规范说

Blockquote 协议名称是一个 UTF-8 编码的字符串，代表协议名称“MQTT”，如图所示。 MQTT 规范的未来版本不会更改字符串、其偏移量和长度。

如果您的协议名称与规范不匹配，代理将静默丢弃您的数据包。 此外，您还必须更新缓冲区数组，因为 MQTT 在 MQTT 协议的可变标头中占用 2+4 个字节。

谢谢