HarmonyOS系统中内核实现MQTT连接华为云的方法
大家好,今天主要和大家聊一聊,如何使用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 | 获得设备信息失败 |
-2 | mqtt 客户端初始化失败 |
第三:华为IOT平台初始化
int oc_mqtt_init(void);
华为IoT平台初始化函数,需要在使用 华为IoT平台 功能前调用。
参数 | 描述 |
---|---|
无 | 无 |
返回 | 描述 |
0 | 成功 |
-1 | 获得设备信息失败 |
-2 | mqtt 客户端初始化失败 |
第四:设置命令响应函数
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,访问这里,填写注册设备后生成的设备ID(DeviceId)和密钥(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 hereif(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 hereif(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 responsecmdresp.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,并填写厂商名称,在下方模型定义栏中选择所属行业以及添加设备类型,并单击右下角“立即创建”如图:
创建完成后,在产品页会自动生成刚刚创建的产品,单击“查看”可查看创建的具体信息。
单击产品详情页的自定义模型,在弹出页面中新增服务
服务ID:Agriculture
(必须一致)
服务类型: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.26SENSOR:lum:15.83 temp:27.01 hum:39.36SENSOR:lum:15.83 temp:26.95 hum:39.45SENSOR:lum:15.83 temp:26.89 hum:39.56SENSOR:lum:15.83 temp:26.84 hum:39.56SENSOR:lum:13.33 temp:26.80 hum:39.64SENSOR:lum:13.33 temp:26.73 hum:39.76SENSOR:lum:12.50 temp:26.71 hum:39.78SENSOR:lum:15.83 temp:26.67 hum:39.91SENSOR:lum:16.67 temp:26.66 hum:40.00
平台上的设备显示为在线状态
点击设备右侧的“查看”,进入设备详情页面,可看到上报的数据
在华为云平台设备详情页,单击“命令”,选择同步命令下发,选中创建的命令属性,单击“确定”,即可发送下发命令控制设备
HarmonyOS系统中内核实现MQTT连接华为云的方法相关推荐
- esp8266WiFi模块通过MQTT连接华为云
esp8266WiFi模块通过MQTT连接华为云 总结: 一. MQTT透传AT固件烧录 二. 串口调试 2.1 设置模块为STA模式 2.2 连接WiFi 2.3 设置MQTT的登陆用户名与密码 2 ...
- 使用MQTT连接华为云的物联网平台(二)
使用MQTT连接华为云IOT平台 文章目录 使用MQTT连接华为云IOT平台 前言 一.MQTT.fx连接华为云需要什么 二.连接步骤 1.创建连接 2.订阅主题与发布主题 3.实践操作 总结 前言 ...
- 一种STM32F1系列+ESP8266使用MQTT连接阿里云的方法
摘要:本文讲述一种使用STM32F103C8T6控制器+ESP8266使用MATT连接阿里云的方法,可以搭配这篇文章中的云Web或移动开发,实现物联网功能并在电脑网页或手机网页让硬件的数据可视化,实验 ...
- HarmonyOS系统中内核实现智慧物流控制的方法
大家好,今天主要和大家聊一聊,如何使用鸿蒙系统实现智能物流的开发. 目录 第一:智能物流简介 第二:华为IOT平台API分析 数据上传 设备消息上报 设备上报属性数据 网关批量上报属性数据 属性设置的 ...
- HarmonyOS系统中内核实现智慧烟感控制的方法
大家好,今天主要和大家聊一聊,如何利用鸿蒙系统实现智慧烟感方法 目录 第一:鸿蒙系统智慧烟感基本简介 第二:华为IOT平台API 数据上传 设备消息上报 设备上报属性数据 网关批量上报属性 ...
- HarmonyOS系统中内核实现NFC无线通信的方法
大家好,今天主要聊一聊,如何使用鸿蒙系统中的NFC视频通信方法. 目录 第一:NFC基本简介 第二:鸿蒙系统中API分析 第三:硬件设计 第四: 软件设计 第五:编译调试 第六:运行结果 第一:NFC ...
- STM32L+BC20+MQTT连接华为云传输温湿度数据并控制继电器
一.材料准备 准备以下材料 二.设备连接 2.1.插入物联网卡 首先把BC20核心板从开发板上拆下来 然后将物联卡放置在BC20核心板内 物联卡放置完成将BC20核心板重新插入到开发板内(注意不要弄错 ...
- HarmonyOS系统中内核实现烟雾检测的方法
大家好,今天我们主要来聊一聊,如何使用鸿蒙系统来操作烟雾浓度传感器. 目录 第一:烟雾浓度传感器原理 第二: 鸿蒙相关API函数分析 Init_E53_SF1() MQ2_PPM_Calibratio ...
- HarmonyOS系统中内核实现三轴加速度检测方法
大家好,今天主要和大家聊一聊,如何使用鸿蒙系统读取三轴加速度的方法. 目录 第一:三轴加速速基本原理 第二:E53_SC2中API分析 第三:硬件设计 第四:软件设计 第五:编译调试 第六: ...
最新文章
- java游戏开发--连连看-让程序运行更稳定、更高效
- googleapiclient.discovery
- 海信电视root工具_海信璀璨系列家电:一次购买便能享受全方位智能家居生活...
- Unix原理与应用学习笔记----第六章 文件的基本属性2
- python range函数怎么表示无限_Python for循环与range函数的使用详解
- (101)FPGA面试题-Verilog设计偶校验位
- jQuery.extend函数详细用法![转]
- Emacs+Lisp环境搭建
- hbase 查询某列_hbase shell使用STARTROW、ENDROW、FILTER查出指定的列
- [单片机框架][drivers层][ADC] fuelgauge 软件电量计(二)
- 74HC595中文资料
- 【预测模型-随机森林分类】基于随机森林算法实现数据分类附matlab代码
- 模拟退火算法应用(Java)
- Grasshopper 二次开发 (C#) Part 1 - Introductions to the C# Coding in Grasshopper
- 氟虫腈-13C2,15N2同位素内标的基质效应
- 麦田的守望者背景与分析
- 已知起始点坐标、目的地方位角,计算沿着测地线飞行一定距离到达的目的地坐标
- UVa 12096 The SetStack Computer 【STL】【stack】
- 中国大陆地区W酒店推出全新夏日计划“幻梦一夏”
- wide deep论文-----2016.6.24