OpenHarmony Neptune开发板-MQTT连接华为IoT平台

想了解更多内容，接华请访问：
和华为官方合作共建的平台鸿蒙技术社区
https://harmonyos.51cto.com

前言：

之前有发过Neptune开发板-MQTT连接华为IoT平台文章，但发现写的接华程序有很大BUG，导致程序运行到开发板经常发生CPU异常(直接不能运行)和平台命令下发错误，平台在此和之前使用我写的接华程序发生问题的人说一句抱歉，亿华云计算本次我修改程序，平台解决了CPU异常(直接不能运行)和平台命令下发错误问题，接华并测试20~30分钟，平台确保稳定运行，接华并将一些遇到问题做相关介绍。平台

介绍：

本示例将演示如何在Neptune开发板上使用MQTT协议连接华为IoT平台,接华使用的是ATH20温湿度传感器模块与Neptune开发板

本示例实现AHT20温湿度数据上报华为IoT平台,IoT平台下发命令控制LED灯的云服务器开关

使用W800 SDK功能包中libemqtt来实现连接华为IoT平台

程序设计

一、MQTT初始化

void mqtt_init(mqtt_broker_handle_t* broker,平台 const char* clientid);

初始化要连接到代理的信息

二、写入username与password

void mqtt_init_auth(mqtt_broker_handle_t* broker,接华 const char* username, const char* password);

启用身份验证以连接到代理。

三、平台建立TCP连接

编写TCP连接函数,接华代码示例如下：

static int init_socket(mqtt_broker_handle_t *broker, const char *hostname, short port, int keepalive) { int flag = 1; struct hostent *hp; // 创建套接字 if((socket_id = socket(PF_INET, SOCK_STREAM, 0)) < 0) return -1; // 禁用Nagle算法 if (setsockopt(socket_id, IPPROTO_TCP, 0x01, (char *)&flag, sizeof(flag)) < 0) { close_socket(&mqtt_broker); return -2; } // 查询主机IP启动 hp = gethostbyname(hostname); if (hp == NULL ) { close_socket(&mqtt_broker); return -2; } struct sockaddr_in socket_address; memset(&socket_address, 0, sizeof(struct sockaddr_in)); socket_address.sin_family = AF_INET; socket_address.sin_port = htons(port); memcpy(&(socket_address.sin_addr), hp->h_addr, hp->h_length); // 连接套接字 if((connect(socket_id, (struct sockaddr *)&socket_address, sizeof(socket_address))) < 0) { close_socket(&mqtt_broker); return -1; } // MQTT stuffs mqtt_set_alive(broker, mqtt_keepalive); broker->socketid = socket_id; broker->mqttsend = send_packet; return 0; }

四、建立MQTT连接

int mqtt_connect(mqtt_broker_handle_t* broker);

五、订阅MQTT

编写订阅MQTT主题函数,代码示例如下：

static int subscribe_topic(char *topic)//订阅主题 { unsigned short msg_id = 0, msg_id_rcv = 0; int packet_lengthgth = 0; int ret = -1; if(topic == NULL) { return -1; } ret = mqtt_subscribe(&mqtt_broker, topic, &msg_id); if( ret == -1 ) { close_socket(&mqtt_broker); return -1; } packet_lengthgth = read_packet(MQTT_DEMO_READ_TIME_SEC, MQTT_DEMO_READ_TIME_US); if(packet_lengthgth < 0) { printf("Error(%d) on read packet!\n", packet_lengthgth); close_socket(&mqtt_broker); return -1; } if(MQTTParseMessageType(pcaket_buffer) != MQTT_MSG_SUBACK) { printf("SUBACK expected!\n"); close_socket(&mqtt_broker); return -2; } msg_id_rcv = mqtt_parse_msg_id(pcaket_buffer); if(msg_id != msg_id_rcv) { printf("%d message id was expected, but %d message id was found!\n", msg_id, msg_id_rcv); close_socket(&mqtt_broker); return -3; } return 0; }

数据推送与解析

采用cJSON封包与解包(使用W800 SDK功能包中cJSON实现),共有两个封包(一个设备属性上报,一个命令应答上报),一个解包解析IoT平台命令,其他不过多赘述具体详见华为IoTDA 设备接入文档：设备接入 IoTDA 文档

OpenHarmony Neptune开发板-MQTT连接华为IoT平台

想了解更多内容，接华请访问：
和华为官方合作共建的平台鸿蒙技术社区
https://harmonyos.51cto.com

前言：

介绍：