在鸿蒙开发板上使用MQTT协议、OneNET实现第一个物联网项目

小嵌

在鸿蒙开发板上使用MQTT协议、OneNET实现第一个物联网项目, 通常来说，一个物联网产品应当包括设备、云平台、手机APP。我将在鸿蒙系统上移植MQTT协议、OneNET接入协议，实现手机APP、网页两者都可以远程（跨网络，不是局域网的）访问开发板数据，并控制开发板的功能。

理论上来说，任何以MQTT协议为基础的物联网云平台都可以支持接入。



3.11.1 效果

先看下效果，我这边使用的是OneNET物联云平台，进入应用，可以看到如下网页界面。该网页的温度、湿度数据由 鸿蒙开发板（Hi3861）上传，同时有一个开关按钮，可以控制开发板的LED灯。



另外，也提供一个手机APP，



以上界面比较简陋，但不妨碍我们使用，另外选择OneNET云平台的主要是原因是接入方式比较简单方便，易于学习，另外一个是OneNET提供了物联网云平台、手机APP，不需要大家自己再去实现，可以更多地将注意力放在鸿蒙系统开发上。

当我们按下开关按钮时，可以看到开发板打印信息如下：



云平台发送过来的时一串json字符串，key为“ledSwitch”，值为1时，可以看到开发板的LED灯亮，值为0时，开发板LED灯灭。



3.11.2 软件包

我这边已经将mqtt 和 onenet 以软件包的形式发布，两个软件包分别是

（1）onenet——实现onenet 接入能力

（2）pahomqtt——实现MQTT协议功能



只需要将这两个软件包放到 third_party 文件夹下即可。然后修改

code-1.0\vendor\hisi\hi3861\hi3861\BUILD.gn 文件，将pahomqtt和onenet加入到编译中





我们来看下onenet 文件夹：



其中 onenet.h 是头文件

onenet_mqtt.c 是全部源码，它基于paho mqtt的MQTTClient编程模型。

另外 samples文件夹下是一个示例代码，代码内容如下：

• #include <stdio.h>
    
  
• #include <unistd.h>
    
  
• #include “MQTTClient.h“
    
  
• #include “onenet.h“
    
  
• 
    
  
• #define ONENET_INFO_DEVID “597952816“
    
  
• #define ONENET_INFO_AUTH “202005160951“
    
  
• #define ONENET_INFO_APIKEY “zgQdlB5y3Bi9pNd2bUYmS8TJHIY=“
    
  
• #define ONENET_INFO_PROID “345377“
    
  
• #define ONENET_MASTER_APIKEY “gwaK2wJT5wgnSbJYz67CVRGvwkI=“
    
  
• 
    
  
• extern int rand（void）;
    
  
• 
    
  
• 
    
  
• void onenet_cmd_rsp_cb（uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size）
    
  
• {
    
  
•     printf（“recv data is %.*s\n“, recv_size, recv_data）;
    
  
• 
    
  
•     *resp_data = NULL;
    
  
•     *resp_size = 0;
    
  
• }
    
  
• 
    
  
• int mqtt_test（void）
    
  
• {
    
  
•         
    
  
•     device_info_init（ONENET_INFO_DEVID, ONENET_INFO_PROID, ONENET_INFO_AUTH, ONENET_INFO_APIKEY, ONENET_MASTER_APIKEY）;
    
  
•     onenet_mqtt_init（）;
    
  
• 
    
  
•     onenet_set_cmd_rsp_cb（onenet_cmd_rsp_cb）;
    
  
• 
    
  
•         while （1）
    
  
•     {
    
  
•                 int value = 0;
    
  
•                
    
  
•         value = rand（） % 100;
    
  
• 
    
  
•         if （onenet_mqtt_upload_digit（“temperature“, value） < 0）
    
  
•         {
    
  
•             printf（“upload has an error, stop uploading“）;
    
  
•             //break;
    
  
•         }
    
  
•         else
    
  
•         {
    
  
•             printf（“buffer : {\“temperature\“:%d} \r\n“, value）;
    
  
•         }
    
  
•         sleep（1）;
    
  
•     }
    
  
•         return 0;
    
  
• }
  

复制代码

手机APP下载：https://open.iot.10086.cn/doc/art656.html#118



由于本节内容较多，将分成多个文章，陆续放出，目前规划如下：

（1）paho mqtt client移植。其实我之前已经有一篇文章讲了paho mqtt的移植，但是那篇文章只是简单的移植，并不支持多任务，这一次mqtt移植将支持多任务。

（2）onenet协议的移植与实现。主要讲如何在mqtt的基础上实现onenet接入。

（3）如何使用onenet云平台

（4）设备（鸿蒙开发板）如何接入到onenet，实现数据互传。