HarmonyOS系统中内核实现MQTT连接华为云的方法

阿里云国内75折 回扣 微信号：monov8
阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6

      大家好今天主要和大家聊一聊如何使用MQTT连接华为云平台的方法

目录

第一MQTT通信基本原理

第二华为IOT平台API

第三华为IOT平台初始化

第四设置命令响应函数

第五数据上传

设备消息上报

设备上报属性数据

网关批量上报属性数据

属性设置的响应结果

属性查询响应结果

将命令的执行结果返回给平台

第六软件设计

连接平台

推送数据

命令接收

第七编译调试

创建产品

修改代码中设备信息

   第八修改BUILD.gn

 

第一MQTT通信基本原理

 MQTT消息队列遥测传输协议是一种基于发布/订阅publish/subscribe模式的“轻量级”通信协议该协议构建与TCP、IP协议上。MQTT最大优点在于可以以极少的代码和有限的带宽为连接远程设备提供实时可靠的消息服务。做为一种低开销、低带宽占用的即时通讯协议使其在物联网、小型设备、移动应用等方面有较广泛的应用。

MQTT 传输的消息分为主题 Topic 和负载 payload 两部分
1 Topic 可以理解为消息的类型订阅者订阅 Subscribe 后就会收到该主题的消息内容
payload
2 payload 可以理解为消息的内容是指订阅者具体要使用的内容。
 

第二华为IOT平台API

    初始化设备信息

 void device_info_init(char *client_id, char * username, char *password);

设置设备信息在调用oc_mqtt_init()前要先设置设备信息

参数描述
无无
返回描述
0成功
-1获得设备信息失败
-2mqtt 客户端初始化失败

第三华为IOT平台初始化

int oc_mqtt_init(void);

华为IoT平台初始化函数需要在使用 华为IoT平台 功能前调用。

参数描述
无无
返回描述
0成功
-1获得设备信息失败
-2mqtt 客户端初始化失败

第四设置命令响应函数

void oc_set_cmd_rsp_cb(void(*cmd_rsp_cb)(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size));

设置命令响应回调函数。

参数描述
recv_data接收到的数据
recv_size数据的长度
resp_data响应数据
resp_size响应数据的长度
返回描述
无无

第五数据上传

设备消息上报

int oc_mqtt_profile_msgup(char *deviceid,oc_mqtt_profile_msgup_t *payload);

是指设备无法按照产品模型中定义的属性格式进行数据上报时可调用此接口将设备的自定义数据上报给平台平台将设备上报的消息转发给应用服务器或华为云其他云服务上进行存储和处理。

参数描述
deviceid设备id
payload要上传的消息
返回描述
0上传成功
1上传失败

设备上报属性数据

int oc_mqtt_profile_propertyreport(char *deviceid,oc_mqtt_profile_service_t *payload);

用于设备按产品模型中定义的格式将属性数据上报给平台。

参数描述
deviceid设备id
payload要上传的消息
返回描述
0上传成功
1上传失败

属性上报和消息上报的区别请查看消息通信说明

网关批量上报属性数据

int oc_mqtt_profile_gwpropertyreport(char *deviceid,oc_mqtt_profile_device_t *payload);

用于批量设备上报属性数据给平台。网关设备可以用此接口同时上报多个子设备的属性数据。

参数描述
deviceid设备id
payload要上传的消息
返回描述
0上传成功
1上传失败

属性设置的响应结果

int oc_mqtt_profile_propertysetresp(char *deviceid,oc_mqtt_profile_propertysetresp_t *payload);

参数描述
deviceid设备id
payload消息
返回描述
0上传成功
1上传失败

属性查询响应结果

int oc_mqtt_profile_propertygetresp(char *deviceid,oc_mqtt_profile_propertygetresp_t *payload);

参数描述
deviceid设备id
payload消息
返回描述
0上传成功
1上传失败

将命令的执行结果返回给平台

int oc_mqtt_profile_cmdresp(char *deviceid,oc_mqtt_profile_cmdresp_t *payload); 平台下发命令后需要设备及时将命令的执行结果返回给平台如果设备没回响应平台会认为命令执行超时。

参数描述
deviceid设备id
payload要上传的消息
返回描述
0上传成功
1上传失败

第六软件设计

连接平台

在连接平台前需要获取CLIENT_ID、USERNAME、PASSWORD访问这里填写注册设备后生成的设备IDDeviceId和密钥DeviceSecret生成连接信息ClientId、Username、Password。

WifiConnect("TP-LINK_65A8","0987654321");
device_info_init(CLIENT_ID,USERNAME,PASSWORD);
oc_mqtt_init();
oc_set_cmd_rsp_cb(oc_cmd_rsp_cb);

推送数据

当需要上传数据时需要先拼装数据然后通过oc_mqtt_profile_propertyreport上报数据。代码示例如下

static void deal_report_msg(report_t *report)
{
    oc_mqtt_profile_service_t    service;
    oc_mqtt_profile_kv_t         temperature;
    oc_mqtt_profile_kv_t         humidity;
    oc_mqtt_profile_kv_t         luminance;
    oc_mqtt_profile_kv_t         led;
    oc_mqtt_profile_kv_t         motor;


    service.event_time = NULL;
    service.service_id = "Agriculture";
    service.service_property = &temperature;
    service.nxt = NULL;

    temperature.key = "Temperature";
    temperature.value = &report->temp;
    temperature.type = EN_OC_MQTT_PROFILE_VALUE_INT;
    temperature.nxt = &humidity;

    humidity.key = "Humidity";
    humidity.value = &report->hum;
    humidity.type = EN_OC_MQTT_PROFILE_VALUE_INT;
    humidity.nxt = &luminance;

    luminance.key = "Luminance";
    luminance.value = &report->lum;
    luminance.type = EN_OC_MQTT_PROFILE_VALUE_INT;
    luminance.nxt = &led;

    led.key = "LightStatus";
    led.value = g_app_cb.led?"ON":"OFF";
    led.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
    led.nxt = &motor;

    motor.key = "MotorStatus";
    motor.value = g_app_cb.motor?"ON":"OFF";
    motor.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
    motor.nxt = NULL;

    oc_mqtt_profile_propertyreport(USERNAME,&service);
    return;
}

命令接收

华为IoT平台支持下发命令命令是用户自定义的。接收到命令后会将命令数据发送到队列中task_main_entry函数中读取队列数据并调用deal_cmd_msg函数进行处理代码示例如下


void oc_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)
{
	app_msg_t *app_msg;

	int    ret = 0;
	app_msg = malloc(sizeof(app_msg_t));
	app_msg->msg_type = en_msg_cmd;
	app_msg->msg.cmd.payload = (char *)recv_data;

    printf("recv data is %.*s\n", recv_size, recv_data);
    ret = osMessageQueuePut(mid_MsgQueue,&app_msg,0U, 0U);
    if(ret != 0){
        free(recv_data);
    }
    *resp_data = NULL;
    *resp_size = 0;
}
static int task_main_entry( void )
{
    app_msg_t *app_msg;

	WifiConnect("TP-LINK_65A8","0987654321");
	device_info_init(CLIENT_ID,USERNAME,PASSWORD);
	oc_mqtt_init();
	oc_set_cmd_rsp_cb(oc_cmd_rsp_cb);

    while(1){
        app_msg = NULL;
        (void)osMessageQueueGet(mid_MsgQueue,(void **)&app_msg,NULL, 0U);
        if(NULL != app_msg){
            switch(app_msg->msg_type){
                case en_msg_cmd:
                    deal_cmd_msg(&app_msg->msg.cmd);
                    break;
                case en_msg_report:
                    deal_report_msg(&app_msg->msg.report);
                    break;
                default:
                    break;
            }
            free(app_msg);
        }
    }
    return 0;
}
static void deal_cmd_msg(cmd_t *cmd)
{
    cJSON *obj_root;
    cJSON *obj_cmdname;
    cJSON *obj_paras;
    cJSON *obj_para;

    int cmdret = 1;
    oc_mqtt_profile_cmdresp_t  cmdresp;
    obj_root = cJSON_Parse(cmd->payload);
    if(NULL == obj_root){
        goto EXIT_JSONPARSE;
    }

    obj_cmdname = cJSON_GetObjectItem(obj_root,"command_name");
    if(NULL == obj_cmdname){
        goto EXIT_CMDOBJ;
    }
    if(0 == strcmp(cJSON_GetStringValue(obj_cmdname),"Agriculture_Control_light")){
        obj_paras = cJSON_GetObjectItem(obj_root,"paras");
        if(NULL == obj_paras){
            goto EXIT_OBJPARAS;
        }
        obj_para = cJSON_GetObjectItem(obj_paras,"Light");
        if(NULL == obj_para){
            goto EXIT_OBJPARA;
        }
        ///< operate the LED here
        if(0 == strcmp(cJSON_GetStringValue(obj_para),"ON")){
            g_app_cb.led = 1;
            Light_StatusSet(ON);
            printf("Light On!");
        }
        else{
            g_app_cb.led = 0;
            Light_StatusSet(OFF);
            printf("Light Off!");
        }
        cmdret = 0;
    }
    else if(0 == strcmp(cJSON_GetStringValue(obj_cmdname),"Agriculture_Control_Motor")){
        obj_paras = cJSON_GetObjectItem(obj_root,"Paras");
        if(NULL == obj_paras){
            goto EXIT_OBJPARAS;
        }
        obj_para = cJSON_GetObjectItem(obj_paras,"Motor");
        if(NULL == obj_para){
            goto EXIT_OBJPARA;
        }
        ///< operate the Motor here
        if(0 == strcmp(cJSON_GetStringValue(obj_para),"ON")){
            g_app_cb.motor = 1;
            Motor_StatusSet(ON);
            printf("Motor On!");
        }
        else{
            g_app_cb.motor = 0;
            Motor_StatusSet(OFF);
            printf("Motor Off!");
        }
        cmdret = 0;
    }

EXIT_OBJPARA:
EXIT_OBJPARAS:
EXIT_CMDOBJ:
    cJSON_Delete(obj_root);
EXIT_JSONPARSE:
    ///< do the response
    cmdresp.paras = NULL;
    cmdresp.request_id = cmd->request_id;
    cmdresp.ret_code = cmdret;
    cmdresp.ret_name = NULL;
    (void)oc_mqtt_profile_cmdresp(NULL,&cmdresp);
    return;
}

第七编译调试

   登录

设备接入华为云平台之前需要在平台注册用户账号华为云地址https://www.huaweicloud.com/

在华为云首页单击产品找到IoT物联网单击设备接入IoTDA 并单击立即使用。

 

创建产品

在设备接入页面可看到总览界面展示了华为云平台接入的协议与域名信息根据需要选取MQTT通讯必要的信息备用。

接入协议端口号MQTT 1883

域名iot-mqtts.cn-north-4.myhuaweicloud.com

选中侧边栏产品页单击右上角“创建产品”

 在页面中选中所属资源空间并且按要求填写产品名称选中MQTT协议数据格式为JSON并填写厂商名称在下方模型定义栏中选择所属行业以及添加设备类型并单击右下角“立即创建”如图

 创建完成后在产品页会自动生成刚刚创建的产品单击“查看”可查看创建的具体信息。

 

单击产品详情页的自定义模型在弹出页面中新增服务

服务IDAgriculture(必须一致)

服务类型Senser(可自定义)

 在“Agriculture”的下拉菜单下点击“添加属性”填写相关信息“Temperature” “Humidity”“Luminance”“LightStatus”“MotorStatus”。

 

 

 

在“Agriculture”的下拉菜单下点击“添加命令”填写相关信息。

命令名称Agriculture_Control_light

参数名称Light

数据类型string

长度3

枚举值ON,OFF

命令名称Agriculture_Control_Motor

参数名称Motor

数据类型string

长度3

枚举值ON,OFF

 

注册设备

在侧边栏中单击“设备”进入设备页面单击右上角“注册设备”勾选对应所属资源空间并选中刚刚创建的产品注意设备认证类型选择“秘钥”按要求填写秘钥。

 

 记录下设备ID和设备密钥

注册完成后在设备页面单击“所有设备”即可看到新建的设备同时设备处于未激活状态

 

修改代码中设备信息

在连接平台前需要获取CLIENT_ID、USERNAME、PASSWORD访问这里填写注册设备时生成的设备ID和设备密钥生成连接信息ClientId、Username、Password并将修改代码对应位置。

 

修改wifi热点信息 

   第八修改BUILD.gn

   修改 applications\sample\BearPi\BearPi-HM_Nano路径下 BUILD.gn 文件指定 oc_mqtt 参与编译。

#"D1_iot_wifi_sta:wifi_sta",
#"D2_iot_wifi_sta_connect:wifi_sta_connect",      
#"D3_iot_udp_client:udp_client",
#"D4_iot_tcp_server:tcp_server",
#"D5_iot_mqtt:iot_mqtt",        
"D6_iot_cloud_oc:oc_mqtt",
#"D7_iot_cloud_onenet:onenet_mqtt",

示例代码编译烧录代码后按下开发板的RESET按键通过串口助手查看日志会打印温湿度及光照强度信息。

SENSOR:lum:15.83 temp:27.10 hum:39.26

SENSOR:lum:15.83 temp:27.01 hum:39.36

SENSOR:lum:15.83 temp:26.95 hum:39.45

SENSOR:lum:15.83 temp:26.89 hum:39.56

SENSOR:lum:15.83 temp:26.84 hum:39.56

SENSOR:lum:13.33 temp:26.80 hum:39.64

SENSOR:lum:13.33 temp:26.73 hum:39.76

SENSOR:lum:12.50 temp:26.71 hum:39.78

SENSOR:lum:15.83 temp:26.67 hum:39.91

SENSOR:lum:16.67 temp:26.66 hum:40.00

平台上的设备显示为在线状态

 点击设备右侧的“查看”进入设备详情页面可看到上报的数据

 在华为云平台设备详情页单击“命令”选择同步命令下发选中创建的命令属性单击“确定”即可发送下发命令控制设备

阿里云国内75折 回扣 微信号：monov8
阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6
返回列表

上一篇：老板要的物联网可视化大屏，我30分钟就搞定了

下一篇：高通再度回归，然而华为、阿里已先行一步，外媒：来不及了

“HarmonyOS系统中内核实现MQTT连接华为云的方法” 的相关文章

react-redux的connect详解1年前 (2023-02-01)
RabbitMQ常见场景问题1年前 (2023-02-02)
软件测试刚入职，很茫然怎么办~1年前 (2023-02-02)
AFNetworking整体框架简单整理1年前 (2023-02-02)
聊聊MongoDB中连接池、索引、事务1年前 (2023-02-02)
读编程与类型系统笔记11_高级类型及其他1年前 (2023-02-02)
区块链特辑——solidity语言基础(六)1年前 (2023-02-02)
Nginx配置将二级域名解析到Linux服务器指定端口1年前 (2023-02-02)
Flutter 耗时监控 | 路由名为空原因分析1年前 (2023-02-02)
Hexo 修改默认文章路径1年前 (2023-02-02)

阿里云国际版