HarmonyOS系统中内核实现智慧烟感控制的方法
大家好,今天主要和大家聊一聊,如何利用鸿蒙系统实现智慧烟感方法
目录
第一:鸿蒙系统智慧烟感基本简介
第二:华为IOT平台API
数据上传
设备消息上报
设备上报属性数据
网关批量上报属性数据
属性设置的响应结果
属性查询响应结果
将命令的执行结果返回给平台
第三:软件设计
连接平台
推送数据
命令接收
第四:编译调试
登录
创建产品
第五:修改代码中设备信息
第六:修改 BUILD.gn 文件
第七:编译调试
第一:鸿蒙系统智慧烟感基本简介
在鸿蒙开发板上使用MQTT协议连接华为IOT平台,使用智慧烟感和开发板进行通信的实例。
华为云是华为的云服务品牌,用在线的方式将华为30多年在ICT基础设施领域的技术积累和产品解决方案开放给客户,致力于提供稳定可靠、安全可信、可持续创新的云服务,做智能世界的”黑土地”,推进实现 “用得起、用得好、用得放心”的普惠Al。华为云作为底座,为华为全栈全场景AI战略提供强大的算力平台和更易用的开发平台。
第二:华为IOT平台API
数据上传
设备消息上报
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 | 上传失败 |
第三:软件设计
连接平台
在连接平台前需要设置获取CONFIG_APP_DEVICEID、CONFIG_APP_DEVICEPWD、CONFIG_APP_SERVERIP、CONFIG_APP_SERVERPORT,通过oc_mqtt_profile_connect()函数连接平台。
WifiConnect(CONFIG_WIFI_SSID, CONFIG_WIFI_PWD);dtls_al_init();mqtt_al_init();oc_mqtt_init();g_app_cb.app_msg = queue_create("queue_rcvmsg",10,1);if(NULL == g_app_cb.app_msg){printf("Create receive msg queue failed");}oc_mqtt_profile_connect_t connect_para;(void) memset( &connect_para, 0, sizeof(connect_para));connect_para.boostrap = 0;connect_para.device_id = CONFIG_APP_DEVICEID;connect_para.device_passwd = CONFIG_APP_DEVICEPWD;connect_para.server_addr = CONFIG_APP_SERVERIP;connect_para.server_port = CONFIG_APP_SERVERPORT;connect_para.life_time = CONFIG_APP_LIFETIME;connect_para.rcvfunc = msg_rcv_callback;connect_para.security.type = EN_DTLS_AL_SECURITY_TYPE_NONE;ret = oc_mqtt_profile_connect(&connect_para);if((ret == (int)en_oc_mqtt_err_ok)){g_app_cb.connected = 1;printf("oc_mqtt_profile_connect succed!\r\n");}else{printf("oc_mqtt_profile_connect faild!\r\n");}
推送数据
当需要上传数据时,需要先拼装数据,让后通过oc_mqtt_profile_propertyreport上报数据。代码示例如下:
static void deal_report_msg(report_t *report)
{oc_mqtt_profile_service_t service;oc_mqtt_profile_kv_t smoke_value;oc_mqtt_profile_kv_t beep;service.event_time = NULL;service.service_id = "Smoke";service.service_property = &smoke_value;service.nxt = NULL;smoke_value.key = "Smoke_Value";smoke_value.value = &report->smokevalue;smoke_value.type = EN_OC_MQTT_PROFILE_VALUE_STRING;smoke_value.nxt = &beep;beep.key = "BeepStatus";beep.value = g_app_cb.beep ? "ON" : "OFF";beep.type = EN_OC_MQTT_PROFILE_VALUE_STRING;beep.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), "Smoke_Control_Beep")){obj_paras = cJSON_GetObjectItem(obj_root, "paras");if (NULL == obj_paras){goto EXIT_OBJPARAS;}obj_para = cJSON_GetObjectItem(obj_paras, "Beep");if (NULL == obj_para){goto EXIT_OBJPARA;}///< operate the LED hereif (0 == strcmp(cJSON_GetStringValue(obj_para), "ON")){g_app_cb.beep = 1;Beep_StatusSet(ON);printf("Beep On!");goto EXIT_JSONPARSE;}else{g_app_cb.beep = 0;Beep_StatusSet(OFF);printf("Beep Off!");goto EXIT_JSONPARSE;}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:Smoke
(必须一致)
服务类型:Senser
(可自定义)
在“Smoke”的下拉菜单下点击“添加属性”填写相关信息“Smoke_Value”,“BeepStatus”。
在“Smoke”的下拉菜单下点击“添加命令”填写相关信息。
命令名称:Smoke_Control_Beep
参数名称:Beep
数据类型:string
长度:3
枚举值:ON,OFF
注册设备
在侧边栏中单击“设备”,进入设备页面,单击右上角“注册设备”,勾选对应所属资源空间并选中刚刚创建的产品,注意设备认证类型选择“秘钥”,按要求填写秘钥。
记录下设备ID和设备密钥
注册完成后,在设备页面单击“所有设备”,即可看到新建的设备,同时设备处于未激活状态
第五:修改代码中设备信息
修改iot_cloud_oc_sample.c
中第31行附近的wifi的ssid和pwd,以及设备的DEVICEID和DEVICEPWD(这两个参数是在平台注册设备时产生的),
第六:修改 BUILD.gn 文件
修改 applications\sample\BearPi\BearPi-HM_Nano
路径下 BUILD.gn 文件,指定 cloud_oc_smoke
参与编译。
"D8_iot_cloud_oc_smoke:cloud_oc_smoke"
#"D9_iot_cloud_oc_light:cloud_oc_light"
#"D10_iot_cloud_oc_manhole_cover:cloud_oc_manhole_cover"
#"D11_iot_cloud_oc_infrared:cloud_oc_infrared"
#"D12_iot_cloud_oc_agriculture:cloud_oc_agriculture"
第七:编译调试
示例代码编译烧录代码后,按下开发板的RESET按键,通过串口助手查看日志,平台上的设备显示为在线状态。
点击设备右侧的“查看”,进入设备详情页面,可看到上报的数据
在华为云平台设备详情页,单击“命令”,选择同步命令下发,选中创建的命令属性,单击“确定”,即可发送下发命令控制设备
HarmonyOS系统中内核实现智慧烟感控制的方法相关推荐
- HarmonyOS系统中内核实现智慧物流控制的方法
大家好,今天主要和大家聊一聊,如何使用鸿蒙系统实现智能物流的开发. 目录 第一:智能物流简介 第二:华为IOT平台API分析 数据上传 设备消息上报 设备上报属性数据 网关批量上报属性数据 属性设置的 ...
- HarmonyOS系统中内核实现三轴加速度检测方法
大家好,今天主要和大家聊一聊,如何使用鸿蒙系统读取三轴加速度的方法. 目录 第一:三轴加速速基本原理 第二:E53_SC2中API分析 第三:硬件设计 第四:软件设计 第五:编译调试 第六: ...
- HarmonyOS系统中内核实现NFC无线通信的方法
大家好,今天主要聊一聊,如何使用鸿蒙系统中的NFC视频通信方法. 目录 第一:NFC基本简介 第二:鸿蒙系统中API分析 第三:硬件设计 第四: 软件设计 第五:编译调试 第六:运行结果 第一:NFC ...
- HarmonyOS系统中内核实现烟雾检测的方法
大家好,今天我们主要来聊一聊,如何使用鸿蒙系统来操作烟雾浓度传感器. 目录 第一:烟雾浓度传感器原理 第二: 鸿蒙相关API函数分析 Init_E53_SF1() MQ2_PPM_Calibratio ...
- HarmonyOS系统中内核实现MQTT连接华为云的方法
大家好,今天主要和大家聊一聊,如何使用MQTT连接华为云平台的方法 目录 第一:MQTT通信基本原理 第二:华为IOT平台API 第三:华为IOT平台初始化 第四:设置命令响应函数 第五:数据上传 设 ...
- 用户管理 之 Linux 系统中的超级权限的控制
作者:北南南北 赞助: eTony,pandonny,懒猫, Arch 来自:LinuxSir.Org 摘要: 超级用户是系统最高权限的拥有者,是系统管理唯一的胜任者:由于权限的超级并且达到无所不能的 ...
- Linux系统中运行.sh文件的几种方法
在Linux系统中执行.sh文件的几种方法: 1. cd到.sh文件所在的目录,然后执行./xxx.sh [前提:该./sh文件要有可执行的权限,chmod u+x xxx.sh] 2. 在任何 ...
- linux系统下定时备份,在Linux系统中简单地实现定时备份的方法 -电脑资料
运行一个简单的脚本 假设你有一个脚本叫:/usr/local/bin/myscript. ,你想要每隔一小时就运行一次, Service 文件 第一步,创建一个service文件,根据你Linux的发 ...
- linux系统中清空文件内容的三种方法
1.使用vi/vim命令打开文件后,输入"%d"清空,后保存即可.但当文件内容较大时,处理较慢,命令如下: vim file_name :%d :wq 2.使用cat命令情况,命令 ...
最新文章
- 任正非致“背叛者”与给竞争对手捐款
- Linux安装jdk学习
- 基于VC++开发串口通信的方法
- 视频云直播:场景、技术及优化
- 图的储存方式,链式前向星最简单实现方式 (边集数组)
- 农业部部署农业大数据发展工作 评:对农业现代化很重要
- python安装不了是什么问题_安装不上python的模块怎么办?别怕,我这有妙招!
- 多线程学习笔记(十二)
- java项目环境搭建
- java中怎么创建栈_这个题如何用栈解呢?
- 【代码优化】坚持使用Override注解
- Linux驱动 | DS18B20驱动编程
- 不用 qlv 格式转换成 mp4 - 优雅的下载腾讯视(mp4 格式)
- TF-IDF入门与实例
- 一年级语文四季心田花开专项练习题
- 103.网络安全渗透测试—[权限提升篇1]—[Linux内核漏洞提权]
- 三维扫描仪的数据化时代
- 软件设计模式“单例模式”和“工厂模式”
- Oracle OCP学习——Catalog的配置与使用
- 第一百篇,真实可重现,详细实现昨日剩下的功能