ESP32 web 对接华为云平台--MQTT协议

news2024/9/27 17:36:30

文章目录

  • 前言
  • 一、MQTT协议
  • 二、如何使用MQTT协议对接华为云
    • 1.注册华为云账号
    • 2.设备接入中创建资源空间
    • 3.如何连接
    • 4.通过MQTT.fx工具做初步对接
      • 4.1 设置连接信息
      • 4.2 连接平台
    • 5.查看平台设备信息
  • 三. 设备测对接平台
    • 1.ESP测引入MQTT库
    • 2.编码
      • 2.1前端编码修改
      • 2.2 后端接口修改
    • 3.MQTT编码
    • 4.添加编译文件
    • 5.正常编译烧写
    • 6. 结果展示
  • 总结

前言

今天这篇文章，对于刚接触物联网协议或者刚接触ESP这款模组并且想对接云平台的人特别有帮助。还希望大家耐心的看完。
在今天的实验里面，你需要有三个概念。
第一什么是MQTT协议，
第二 MQTT协议又是如何连接的，
第三点如何在官方的web demo上添加后端服务和前端页面的接口，实验在线MQTT数据传输。

一、MQTT协议

MQTT协议是一个物联网协议，简单来说就是设备和云平台之间的一种通信传输方式，就好比，在中国大家用中国话来交流，在美国用美国话交流。这就对应着两种通信协议。具体的细节，我的建议还是去百度看看。对于初学者，有这个通信的概念即可。

二、如何使用MQTT协议对接华为云

1.注册华为云账号

这个就不说了，去百度找华为云的官方，免费注册。

2.设备接入中创建资源空间

这个可以百度一下华为云设备接入MQTT设备注册

3.如何连接

首先，我们要参考文档 。在这个文档里面，我们可以看到，我们连接的时候需要填写设备ID，用户名和密码。
在这里插入图片描述

其次，怎么获取这一套数据，是目前我们要思考的问题。好在官方直接给出了加密运算的方式。参数计算链接

在下图中，重点关注设备ID和密钥，密钥是在你创建设备的时候就有的
在这里插入图片描述

注意上图和下图的设备ID不一样，这是因为我想要告诉大家这个密钥在什么地方，单独创建了一下。

在这里插入图片描述

通过下面的页面，我们填入上述的设备ID和密钥，获取新的三元素，我们就可以对接设备。

在这里插入图片描述

4.通过MQTT.fx工具做初步对接

4.1 设置连接信息

在这里插入图片描述

4.2 连接平台

在这里插入图片描述

5.查看平台设备信息

在这里插入图片描述

三. 设备测对接平台

1.ESP测引入MQTT库

官方的MQTT demo路径 /esp/esp-idf/examples/protocols/mqtt

在上述的方案中，我们已经完成了电脑模拟设备对接的过程。接下来，我们要用我们的ESP模组完成云平台的对接。还是用之前的web demo。

2.编码

2.1前端编码修改

注意我是将Chart.vue中的内容注释掉替换成了下面的内容

<template>
  <v-container>
    <v-layout text-xs-center wrap>
      <v-flex xs12 sm6 offset-sm3>
        <v-card hover>
          <v-card-title style="font-weight: 800; font-size: 18px">
            阿里云平台数据发送测试
          </v-card-title>
          <div style="width: 90%; margin: 0 auto; padding: 20px">
            <v-text-field
              v-model="mesdata"
              label="测试数据"
              hint="输入测试数据"
            ></v-text-field>
            <v-btn
              block
              color="success"
              size="large"
              type="submit"
              @click="submitdata"
            >
              提交
            </v-btn>
          </div>
        </v-card>
      </v-flex>
    </v-layout>
  </v-container>
</template>

<script>
export default {
  data() {
    return {
      mesdata: null,
    };
  },
  methods: {
    submitdata() {
      this.$ajax
        .post("/api/v1/mqtt/echo", {
          data: this.mesdata,
        })
        .then((data) => {
          console.log(data);
        })
        .catch((error) => {
          console.log(error);
        });
      this.mesdata = "";
    },
  },
  destroyed() {},
  mounted() {},
};
</script>

2.2 后端接口修改

加入一个后端接口,方便前端界面传输数据

// mqtt_send_data_toserver 是我自己封装的一个发送函数,代码都会给大家
extern void mqtt_send_data_toserver(char *message);
static esp_err_t mqtt_echo_handler(httpd_req_t *req)
{
    int total_len = req->content_len;
    int cur_len = 0;
    char message[256] = {0};
    char *buf = ((rest_server_context_t *)(req->user_ctx))->scratch;
    int received = 0;
    if (total_len >= SCRATCH_BUFSIZE)
    {
        /* Respond with 500 Internal Server Error */
        httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "content too long");
        return ESP_FAIL;
    }
    while (cur_len < total_len)
    {
        received = httpd_req_recv(req, buf + cur_len, total_len);
        if (received <= 0)
        {
            /* Respond with 500 Internal Server Error */
            httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to post control value");
            return ESP_FAIL;
        }
        cur_len += received;
    }
    buf[total_len] = '\0';

    cJSON *root = cJSON_Parse(buf);
    //注意这里,这边是为了解析前端页面的数据
    strcpy(message, cJSON_GetObjectItem(root, "data")->valuestring);
    cJSON_Delete(root);
    httpd_resp_sendstr(req, "Post control value successfully");
    mqtt_send_data_toserver(message);
    return ESP_OK;
}

在start_rest_server 函数中添加下面的代码 (注册解析前端方法到系统中)

    httpd_uri_t mqtt_post_uri = {
        .uri = "/api/v1/mqtt/echo",
        .method = HTTP_POST,
        .handler = mqtt_echo_handler,
        .user_ctx = rest_context};
    httpd_register_uri_handler(server, &mqtt_post_uri);

3.MQTT编码


/*
 * SPDX-FileCopyrightText: 2022-2023 Espressif Systems (Shanghai) CO LTD
 *
 * SPDX-License-Identifier: Apache-2.0
 */

#include <stdio.h>
#include <stdint.h>
#include <stddef.h>
#include <string.h>
#include "esp_system.h"
#include "nvs_flash.h"
#include "esp_event.h"
#include "esp_netif.h"
#include "cJSON.h"
#include "esp_log.h"
#include "mqtt_client.h"

#define CLIENTID ""
#define USERNAME ""
#define PASSWORD ""
#define SERVERURL "mqtt://121.36.42.100:1883"

#define PUSHTOPIC "$oc/devices/你的设备ID/sys/properties/report"

esp_mqtt_client_handle_t mqtt_client;

static const char *MQTTTAG = "MQTT";

static void log_error_if_nonzero(const char *message, int error_code)
{
    if (error_code != 0)
    {
        ESP_LOGE(MQTTTAG, "Last error %s: 0x%x", message, error_code);
    }
}

void mqtt_send_data_toserver(char *message)
{
    int msg_id;
    char obj_name[10] = {0};
    double rounded = 0;

    cJSON *root = cJSON_CreateObject();
    // 创建数组对象
    cJSON *array = cJSON_CreateArray();
    // 创建对象
    cJSON *obj = cJSON_CreateObject();
    cJSON_AddStringToObject(obj, "service_id", "echo");
    cJSON *values = cJSON_CreateObject();
    cJSON_AddStringToObject(values, "read", message);
    cJSON_AddItemToObject(obj, "properties", values);
    // 将对象添加到数组中
    cJSON_AddItemToArray(array, obj);

    // 将数组添加到根节点中
    cJSON_AddItemToObject(root, "services", array);

    const char *sys_info = cJSON_Print(root);
    ESP_LOGI(MQTTTAG, "%s", sys_info);
    msg_id = esp_mqtt_client_publish(mqtt_client, PUSHTOPIC, sys_info, 0, 1, 1);

    free((void *)sys_info);
    cJSON_Delete(root);

    return;
}

static void mqtt5_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data)
{
    ESP_LOGD(MQTTTAG, "Event dispatched from event loop base=%s, event_id=%" PRIi32, base, event_id);
    esp_mqtt_event_handle_t event = event_data;
    esp_mqtt_client_handle_t client = event->client;
    int msg_id;

    switch ((esp_mqtt_event_id_t)event_id)
    {
    case MQTT_EVENT_CONNECTED:
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_CONNECTED");
        mqtt_send_data_toserver("sadsadsadas");
        break;
    case MQTT_EVENT_DISCONNECTED:
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_DISCONNECTED");
        esp_mqtt_client_reconnect(client);

        break;
    case MQTT_EVENT_SUBSCRIBED:
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);

        break;
    case MQTT_EVENT_UNSUBSCRIBED:
        /* 退订绑定的服务，目前先不处理 */
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);

        break;
    case MQTT_EVENT_PUBLISHED:
        /* 推送绑定的事件 */
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
        break;
    case MQTT_EVENT_DATA:
        /* 数据下发，先不处理 */
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_DATA");

        break;
    case MQTT_EVENT_ERROR:
        ESP_LOGI(MQTTTAG, "MQTT_EVENT_ERROR return code %d", event->error_handle->connect_return_code);
        if (event->error_handle->error_type == MQTT_ERROR_TYPE_TCP_TRANSPORT)
        {
            log_error_if_nonzero("reported from esp-tls", event->error_handle->esp_tls_last_esp_err);
            log_error_if_nonzero("reported from tls stack", event->error_handle->esp_tls_stack_err);
            log_error_if_nonzero("captured as transport's socket errno", event->error_handle->esp_transport_sock_errno);
            ESP_LOGI(MQTTTAG, "Last errno string (%s)", strerror(event->error_handle->esp_transport_sock_errno));
        }
        break;
    default:
        ESP_LOGI(MQTTTAG, "Other event id:%d", event->event_id);
        break;
    }
}

int mqtt5_app_start(void)
{

    esp_mqtt_client_config_t mqtt_cfg = {
        .broker.address.uri = SERVERURL,
        .credentials.client_id = CLIENTID,
        .credentials.username = USERNAME,
        .credentials.authentication.password = PASSWORD,
        .network.disable_auto_reconnect = true};

    ESP_LOGI(MQTTTAG, "MQTT Server url:%s Client Id %s", mqtt_cfg.broker.address.uri, mqtt_cfg.credentials.client_id);
    mqtt_client = esp_mqtt_client_init(&mqtt_cfg);
    if (mqtt_client == NULL)
    {
        return 1;
    }

    /* The last argument may be used to pass data to the event handler, in this example mqtt_event_handler */
    esp_mqtt_client_register_event(mqtt_client, ESP_EVENT_ANY_ID, mqtt5_event_handler, NULL);
    esp_mqtt_client_start(mqtt_client);

    return 0;
}

4.添加编译文件

在这里插入图片描述

5.正常编译烧写

这个就不再叙述了,查看以往的案例

6. 结果展示

平台端的显示

在这里插入图片描述

网页端的发送 (注意 我是修改的Chart.vue 这个文件的内容)

在这里插入图片描述

后台日志显示 (按照这个报文形势发送)

在这里插入图片描述

{
    "services": [{
            "service_id": "echo",
            "properties": {
                "read": "xxxxx"
            }
        }
    ]
}

总结

今天完成了ESP 对接华为云的案例,里面还是有点弯弯绕的.有疑问就提出来,我都会回复.
后面再有好玩的案例,再发出来看.

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

28.HarmonyOS App(JAVA)多页签的实现（Tab）

28.HarmonyOS App(JAVA)多页签的实现（Tab）

HarmonyOS App(JAVA)多页签的实现&#xff08;Tab&#xff09; 页面可左右滑动&#xff0c;点击界面1,2,3切换到对应界面 PageSlider的创建和使用 在layout目录下的xml文件中创建PageSlider。 <PageSlider ohos:id"$id:page_slider" ohos:height"300vp&…
阅读更多...
UCSF DOCK 分子对接详细案例（01）- rigid, fixed anchor, flexible dock

UCSF DOCK 分子对接详细案例（01）- rigid, fixed anchor, flexible dock

欢迎浏览我的CSND博客&#xff01; Blockbuater_drug …点击进入 文章目录 前言一、操作环境二、研究背景三、受体-配体结构文件准备3.1准备文件夹DOCK_workdir, 下载晶体结构3.1.1 来自湿实验的受体配体共晶结构&#xff1a;3.1.2 来自深度学习和语言模型推理预测的蛋白结构&a…
阅读更多...
DDS数据分发服务——提升汽车领域数据传输效率

DDS数据分发服务——提升汽车领域数据传输效率

1.引言 随着智能化技术的快速发展&#xff0c;汽车行业正经历着一场革命性的变革。如今的分布式系统变得越来越复杂且庞大&#xff0c;对网络通信基数要求在功能和性能层面越来越高。数据分发服务&#xff08;DDS&#xff09;作为一项先进的数据传输解决方案&#xff0c;在汽车…
阅读更多...
Linux---进程信号

Linux---进程信号

一、信号的概念 信号是一种向目标进程发送通知消息的机制 信号的特性(可以结合红绿灯、防空警报等生活样例来理解) 1、在信号没有出现之前&#xff0c;我们就已经知道如何去处理信号&#xff0c;即我们认识信号 2、信号是异步产生的&#xff0c;即我们不知道它具体何时产生 3、…
阅读更多...
使用el-form之表单校验自动定位到报错位置问题,，提升用户体验

使用el-form之表单校验自动定位到报错位置问题,，提升用户体验

需求描述 由于需要填写的表单项太多&#xff0c;提交的时候校验不通过&#xff0c; 如果没填写的表单项在最上面&#xff0c;用户看不到不知道发生了啥&#xff0c; 所以需要将页面滚动定位到第一个报错的表单项位置&#xff0c;提升用户体验实现步骤 1. 给form表单添加ref …
阅读更多...
LangChain---大型语言模型(LLM)的标准接口和编程框架

LangChain---大型语言模型(LLM)的标准接口和编程框架

1.背景说明 公司在新的一年规划中突然提出要搞生成式AI(GenAI)的相关东西&#xff0c;在公司分享的参考资料中了解到了一些相关的信息&#xff0c;之所以想到使用LangChain&#xff0c;是因为在应用中遇到了瓶颈问题&#xff0c;除了已经了解和研究过的OpenAI的ChatGpt&#xf…
阅读更多...
Python实现EMV工具判断信号：股票技术分析的工具系列（2）

Python实现EMV工具判断信号：股票技术分析的工具系列（2）

Python实现EMV工具判断信号&#xff1a;股票技术分析的工具系列&#xff08;2&#xff09; 介绍算法解释&#xff1a;优势&#xff1a;劣势&#xff1a; 代码rolling函数介绍核心代码计算 EMV 完整代码 介绍 先看看官方介绍&#xff1a; EMV(简易波动指标&#xff09; 用法 1.…
阅读更多...
MySQL 多表查询 连接查询 内连接

MySQL 多表查询 连接查询 内连接

介绍 内连接查询是两张表中交集的部分 连接模式 隐式内连接 SELECT 字段列表 FROM 表1,表2 WHERE 条件显式内连接 SELECT 字段列表 FROM 表1 [INNER] JOIN 表2 ON 连接条件案例 有两张表一个表为学生表&#xff0c;另一个表为班级表&#xff0c;现在需要查询学生时候在查…
阅读更多...
【Excel PDF 系列】EasyExcel + iText 库实现 Excel 转换 PDF

【Excel PDF 系列】EasyExcel + iText 库实现 Excel 转换 PDF

你知道的越多&#xff0c;你不知道的越多 点赞再看&#xff0c;养成习惯 如果您有疑问或者见解&#xff0c;欢迎指教&#xff1a; 企鹅&#xff1a;869192208 文章目录 前言转换前后效果引入 pom 配置代码实现定义 ExcelDataVo 对象主方法EasyExcel 监听器 前言 最近遇到生成 …
阅读更多...
【Java程序员面试专栏 算法思维】六 高频面试算法题：动态规划

【Java程序员面试专栏 算法思维】六 高频面试算法题：动态规划

一轮的算法训练完成后，对相关的题目有了一个初步理解了，接下来进行专题训练，以下这些题目就是汇总的高频题目，本篇主要聊聊回溯算法，主要就是排列组合问题，所以放到一篇Blog中集中练习 题目关键字解题思路时间空间零钱兑换动态规划+双重循环dp[i]表示兑换金额为i元的最少…
阅读更多...
基于springboot+vue的中医慢性病食疗系统

基于springboot+vue的中医慢性病食疗系统

后端语言&#xff1a;java 框架&#xff1a;springboot/ssm 数据库&#xff1a;mysql5.7 数据库工具&#xff1a;Navicat 前端技术&#xff1a;vue.jsElementUi 开发工具 idea/eclipse/都可以为设计一个安全便捷&#xff0c;并且使用户更好获取中医药膳慢性病食疗平台&#xf…
阅读更多...
Mamba与MoE架构强强联合，Mamba-MoE高效提升LLM计算效率和可扩展性

Mamba与MoE架构强强联合，Mamba-MoE高效提升LLM计算效率和可扩展性

论文题目&#xff1a; MoE-Mamba: Efficient Selective State Space Models with Mixture of Experts 论文链接&#xff1a; https://arxiv.org/abs/2401.04081 代码仓库&#xff1a; GitHub - llm-random/llm-random 作为大型语言模型&#xff08;LLM&#xff09;基础架构的后…
阅读更多...
腾讯云优惠代金券领取的3个渠道入口，不看后悔！

腾讯云优惠代金券领取的3个渠道入口，不看后悔！

腾讯云代金券领取渠道有哪些&#xff1f;腾讯云官网可以领取、官方媒体账号可以领取代金券、完成任务可以领取代金券&#xff0c;大家也可以在腾讯云百科蹲守代金券&#xff0c;因为腾讯云代金券领取渠道比较分散&#xff0c;腾讯云百科txybk.com专注汇总优惠代金券领取页面&am…
阅读更多...
华为数通方向HCIP-DataCom H12-821题库(多选题：01-20)

华为数通方向HCIP-DataCom H12-821题库(多选题：01-20)

第01题 如图BGP下有如下配置，下面哪些描述是错误的? [HUAWEI-bgp] timer keepalive 30 hold 90 [HUAWEI-bgp] peer 1.1.1.2 timer keepalive 10 hold 30A、Timer 取最小值，所以最终结果是 peer1.1.1.2 的 timer值取 keepalive 10 hold 30 B、Peer 配置优先，所以最终结果是…
阅读更多...
【Maven】Maven 基础教程（三）：build、profile

【Maven】Maven 基础教程（三）：build、profile

《Maven 基础教程》系列&#xff0c;包含以下 3 篇文章&#xff1a; Maven 基础教程&#xff08;一&#xff09;&#xff1a;基础介绍、开发环境配置Maven 基础教程&#xff08;二&#xff09;&#xff1a;Maven 的使用Maven 基础教程&#xff08;三&#xff09;&#xff1a;b…
阅读更多...
开源视频转码器HandBrake

开源视频转码器HandBrake

什么是 HandBrake &#xff1f; HandBrake 是一款适用于 Linux、Mac 和 Windows的开源视频转码器。HandBrake 可以处理大多数常见的视频文件和格式&#xff0c;包括消费者和专业摄像机创建的文件、手机和平板电脑等移动设备的文件、游戏和计算机屏幕录制的文件&#xff0c;以及…
阅读更多...
【数据结构】实现栈

【数据结构】实现栈

大家好&#xff0c;我是苏貝&#xff0c;本篇博客带大家了解栈&#xff0c;如果你觉得我写的还不错的话&#xff0c;可以给我一个赞&#x1f44d;吗&#xff0c;感谢❤️ 目录 一 .栈的概念及结构二 .栈的实现栈的结构体初始化销毁栈顶插入栈顶删除显示栈顶元素是否为空栈的大…
阅读更多...
Android 签名机制

Android 签名机制

V1是内部文件单个签 但是增加apk文件目录下面随意增加文件并不会有影响,它只关心meta-info文件 mf汇总清单的各个文件sha256 V2 整个APK文件,按文件进行hash 那么便不能随便在这里面增加文件了,增加了签名分块&#xff08;不然签名信息存哪里&#xff09;这里涉及一个文件概念 …
阅读更多...
记录一次架构优化处理性能从3千-＞3万

记录一次架构优化处理性能从3千-＞3万

0.背景 优化Kafka消费入Es&#xff0c;适配600台设备上报数据&#xff0c;吞吐量到达2万每秒 1.环境配置 2.压测工具 3.未优化之前的消费逻辑 4.优化之后的消费流程 5.多线程多ESclient 6.修改ES配置&#xff0c;增加kafka分区&#xff0c;增加线程&#xff0c;提升吞吐量 7.…
阅读更多...
DiskMirror-spring-boot-starter 技术|

DiskMirror-spring-boot-starter 技术|

DiskMirror-spring-boot-starter 技术 diskMirror 实现了 SpringBoot 的 starter 能够集成到 SpringBoot 中。 DiskMirror 的 starter&#xff0c;通过引入此类&#xff0c;可以直接实现 diskMirror 在 SpringBoot 中的自动配置&#xff0c;接下来我们将使用案例逐步的演示 d…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023