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

本示例将演示如何在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);

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

参数描述
broker代理数据结构，包含与代理的连接信息
clientIdclientId标识客户端ID
返回描述
无无

二、写入username与password

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

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

参数描述
broker代理数据结构，包含与代理的连接信息
username用户名
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 stuffsmqtt_set_alive(broker, mqtt_keepalive);broker->socketid = socket_id;broker->mqttsend = send_packet;return 0;
}

四、建立MQTT连接

int mqtt_connect(mqtt_broker_handle_t* broker);

参数描述
broker代理数据结构，包含与代理的连接信息
返回描述
1成功
0连接错误
-1输入输出错误

五、订阅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 设备接入文档:

例如设备属性上报，代码示例如下:

static int packPublishReq(char *jsonBuffer)//打包发布请求
{cJSON *jsRet = NULL;cJSON *jsArray = NULL;int ackLen = 0;jsRet = cJSON_CreateObject();if(jsRet){   jsArray = cJSON_CreateArray();cJSON_AddItemToObject(jsRet, "services", jsArray);{cJSON *arrayObj_1 = cJSON_CreateObject();cJSON_AddItemToArray(jsArray, arrayObj_1);cJSON_AddStringToObject(arrayObj_1, "service_id", "Temperature");cJSON *arrayObj_2 = cJSON_CreateObject();cJSON_AddItemToObject(arrayObj_1, "properties", arrayObj_2);cJSON_AddStringToObject(arrayObj_2, "temp", Temperature.temp);cJSON_AddStringToObject(arrayObj_2, "humi", Temperature.humi);cJSON_AddStringToObject(arrayObj_2, "led",  Temperature.ON_OFF);cJSON_AddStringToObject(arrayObj_1,"event_time", Temperature.timestamp);}char *databuf = cJSON_PrintUnformatted(jsRet);if(databuf) {if( jsonBuffer ) {ackLen = strlen(databuf);memcpy( jsonBuffer, databuf,ackLen);}tls_mem_free(databuf);}cJSON_Delete(jsRet); }return ackLen;
}

华为IoT平台配置(以导出模型model.zip直接导入即可）

登录

设备接入华为云平台之前，需要在平台注册用户账号，华为云地址：

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

创建产品

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

接入协议（端口号）：MQTT 1883

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

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

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

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

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

服务ID：Temperature(必须一致)

服务类型：senser(可自定义)

在“Temperature”的下拉菜单下点击“添加属性”填写相关信息“temp”，“humi”，“led”。

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

注册设备

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

修改代码中设备信息

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

在wifi_connecter.h修改wifi热点信息

示例代码编译烧录代码后，按下开发板的RESET按键:

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

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

注意：！！！需要将libemqtt.h下！！！
MQTT_CONF_USERNAME_LENGTH 修改为64
MQTT_CONF_PASSWORD_LENGTH 修改为64+8
clientid[50]修改为clientid[64]

为了能让大家更好的学习鸿蒙（HarmonyOS NEXT）开发技术，这边特意整理了《鸿蒙开发学习手册》（共计890页），希望对大家有所帮助：https://qr21.cn/FV7h05

《鸿蒙开发学习手册》：

如何快速入门：https://qr21.cn/FV7h05

  1. 基本概念
  2. 构建第一个ArkTS应用
  3. ……

开发基础知识：https://qr21.cn/FV7h05

  1. 应用基础知识
  2. 配置文件
  3. 应用数据管理
  4. 应用安全管理
  5. 应用隐私保护
  6. 三方应用调用管控机制
  7. 资源分类与访问
  8. 学习ArkTS语言
  9. ……

基于ArkTS 开发：https://qr21.cn/FV7h05

  1. Ability开发
  2. UI开发
  3. 公共事件与通知
  4. 窗口管理
  5. 媒体
  6. 安全
  7. 网络与链接
  8. 电话服务
  9. 数据管理
  10. 后台任务(Background Task)管理
  11. 设备管理
  12. 设备使用信息统计
  13. DFX
  14. 国际化开发
  15. 折叠屏系列
  16. ……

鸿蒙开发面试真题（含参考答案）：https://qr18.cn/F781PH

鸿蒙开发面试大盘集篇（共计319页）：https://qr18.cn/F781PH

1.项目开发必备面试题
2.性能优化方向
3.架构方向
4.鸿蒙开发系统底层方向
5.鸿蒙音视频开发方向
6.鸿蒙车载开发方向
7.鸿蒙南向开发方向

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/589922.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Express框架搭建项目 node.js

Express框架搭建项目 node.js

文章目录 引言Express框架介绍express安装环境准备写一个简单的项目展示 文章总结 引言 Express是一个基于Node.js平台的轻量级Web应用框架&#xff0c;它提供了简洁的API和丰富的功能&#xff0c;使得开发者能够快速地构建Web服务器和API。本文将带领大家从零开始&#xff0c…
阅读更多...
自动驾驶之心规划控制笔记

自动驾驶之心规划控制笔记

Search-based Path Planning Methods Path Finding Problem 一般来说指标有距离，耗费时间，能量，或者多目标。 左图是拓扑地图，蓝色的点就是顶点，绿色的线是连接关系。最后得到的是一个从哪里走的一个最优，并非精细解。 右图是栅格地图，这个搜索出来的是在相对分辨率比…
阅读更多...
【c语言】自定义类型：联合体(公用体)【详解】

【c语言】自定义类型：联合体(公用体)【详解】

联合体 联合体类型的声明 像结构体⼀样&#xff0c;联合体也是由⼀个或者多个成员构成&#xff0c;这些成员可以不同的类型。但是编译器只为最⼤的成员分配⾜够的内存空间。联合体的特点是所有成员共⽤同⼀块内存空间。所以联合体也叫&#xff1a;共用体。 给联合体其中⼀个成…
阅读更多...
《极客时间TonyBai go语言第一课》学习笔记

《极客时间TonyBai go语言第一课》学习笔记

文章目录 前置篇显式组合并发 入门篇Go 包的初始化次序![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/1388d0d1bddd4a37b98eba5fcb41fc4d.png)初始化一个项目 大纲 前置篇 显式 在 C 语言中&#xff0c;下面这段代码可以正常编译并输出正确结果&#xff1a; #i…
阅读更多...
ubuntu安装sublime3并设置中文

ubuntu安装sublime3并设置中文

安装Sublime Text 3 在Ubuntu上安装Sublime Text 3可以通过以下步骤进行&#xff1a; 打开终端。 导入Sublime Text 3的GPG密钥&#xff1a; wget -qO- https://download.sublimetext.com/sublimehq-pub.gpg | sudo apt-key add - 添加Sublime Text 3的存储库&#xff1a; …
阅读更多...
v-text 和v-html

v-text 和v-html

接下来&#xff0c;我讲介绍一下v-text和v-html的使用方式以及它们之间的区别。 使用方法 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8" /><meta name"viewport" content"widthdevice-widt…
阅读更多...
ssm023实验室耗材管理系统设计与实现+jsp

ssm023实验室耗材管理系统设计与实现+jsp

实验室耗材管理系统的设计与实现 摘 要 互联网发展至今&#xff0c;无论是其理论还是技术都已经成熟&#xff0c;而且它广泛参与在社会中的方方面面。它让信息都可以通过网络传播&#xff0c;搭配信息管理工具可以很好地为人们提供服务。针对实验室耗材信息管理混乱&#xff…
阅读更多...
对一个类中具有相似名称的属性值进行操作

对一个类中具有相似名称的属性值进行操作

一、问题描述 对于一个类&#xff0c;要依次取得相似的属性名称进行相关操作&#xff0c;如果逐个get(),set()会非常麻烦&#xff0c;例如将属性值逐个求和后放入list。写代码时&#xff0c;首先需要声明一个Integer变量&#xff0c;然后使用去赋值&#xff0c;非常麻烦。类似…
阅读更多...
《深入Linux内核架构》第3章 内存管理（6）

《深入Linux内核架构》第3章 内存管理（6）

目录 3.5.7 内核中不连续页的分配 3.5.8 内核映射 本节讲解vmalloc, vmap&#xff0c;kmap原理。 3.5.7 内核中不连续页的分配 kmalloc函数&#xff1a;分配物理地址和虚拟地址都连续的内存。 kmalloc基于slab&#xff0c;而slab基于伙伴系统。 void *vmalloc(unsigned lon…
阅读更多...
5.Python数据分析—Pandas数据结构详讲

5.Python数据分析—Pandas数据结构详讲

5.Python数据分析—Pandas数据结构详讲 摘要个人简介简介Series定义和特点创建方法属性和方法 DataFrame定义和特点创建方法数据获取和操作 索引对象种类和应用作用和管理 摘要 Pandas是一个开源的Python数据分析库&#xff0c;提供了高性能、易用的数据结构和数据分析工具。它…
阅读更多...
大屏可视化项目示例--基于Vue3+vite2+echart+mock+axios+dataV

大屏可视化项目示例--基于Vue3+vite2+echart+mock+axios+dataV

图例&#xff1a; 项目环境&#xff1a; Vite、Echarts、Npm、Node、axios、mock、vue3、dataV。 项目地址&#xff1a; IofTV-Screen-Vue3: &#x1f525;(IofTV-Screen Vue3版本)一个基于 vue3、vite、Echart 框架的物联网可视化&#xff08;大屏展示&#xff09;模板&…
阅读更多...
php运行python脚本失败怎么解决

php运行python脚本失败怎么解决

假设有文件&#xff1a;php_test.php python_test.py 在php文件中运行Python&#xff1a; exec("python python_test.py", $array, $ret); 如果运行Python出错并不能保存在数组array中&#xff0c;因此应该把标准错误重定向到文件中&#xff0c;以上代码改写如下&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023