tcp - 在 PIC 微 Controller 中实现 MQTT

Question

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

1. 在
2. AT+CPIN?
3. AT+CREG?
4. AT+CGATT?
5. AT+CIPSHUT
6. AT+CIP状态
7. AT+CIPMUX=0
8. AT+CSTT=\"互联网\",\"\",\"\"
9. AT+CIICR
10. AT+CIFSR

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

    根据 MQtt 协议(protocol)的文档，我编写了连接数据包函数。 建立 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;<br/> packetlen = 2 + connectdatalen;<br/> 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 规范，您应该检查协议(protocol)名称“MQIsdp”我认为它必须是“MQTT”。 MQTT 规范说

Blockquote The Protocol Name is a UTF-8 encoded string that represents the protocol name “MQTT”, capitalized as shown. The string, its offset and length will not be changed by future versions of the MQTT specification.

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

谢谢