ESP32通过MQTT协议连接OneNet平台上报信息

ESP32通过MQTT协议连接OneNet平台上报信息

引用

CSDN

1.

https://blog.csdn.net/u011574457/article/details/141157655

本文将详细介绍如何使用ESP32通过MQTT协议连接OneNet平台并上报信息。文章将从OneNet平台操作和ESP32代码实现两个方面进行讲解，帮助读者快速掌握这一技术。

一、OneNet平台操作

1. 创建产品

在OneNet平台上，首先需要创建一个产品。进入"产品开发"页面，选择"创建产品"，产品品类可以随意选择，智能化方式选择"设备接入"。

2. 创建设备

创建设备时，需要在"设备管理"页面选择"创建设备"。在创建设备时，需要选择之前创建的产品，并为设备命名。

3. 设置物模型

物模型相当于定义需要上报的信息。在"产品开发"页面，选择"功能定义"，然后"设置物模型"。点击"新建自定义功能点"，填写需要上报的数据格式及信息。完成后记得保存。

4. 制作Token

Token相当于密码，需要使用OneNet官方提供的Token计算工具。需要的数据包括产品ID、设备ID、未来时间戳和access_key。

计算Token的参数如下：

• res : products/{产品id}/devices/{设备名字}
• et : 未来时间戳（unix格式）
• key: access_key

二、ESP32代码实现

1. 头文件定义

#ifndef __MQTT_H
#define __MQTT_H
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "mqtt.h"
#include "mqtt_client.h"
#include "esp_log.h"

// 具体参数需要根据OneNet文档进行设置
#define ESP_MQTT_URI "mqtt://mqtts.heclouds.com"
#define ESP_MQTT_PORT 1883
#define ESP_CLIENT_ID  "test" // 设备id
#define ESP_PRODUCT_ID "产品ID" // 产品id
#define ESP_MQTT_TOKEN "复制自己生成的Token" // TOKEN
#define ONENET_TOPIC_SUB "$sys/产品ID/设备ID/thing/property/post/reply"  // 订阅主题
#define ONENET_TOPIC_PUBLISH "$sys/产品ID/设备ID/thing/property/post" // 上报主题

// MQTT状态定义
typedef enum {
    MQTT_STATE_ERROR = -1,
    MQTT_STATE_UNKNOWN = 0,
    MQTT_STATE_INIT,
    MQTT_STATE_CONNECTED,
    MQTT_STATE_WAIT_TIMEOUT,
} mqtt_client_state_t;

static const char *TAG = "MQTT"; // LOG头
esp_mqtt_client_handle_t client; // MQTT句柄
bool mqtt_connect_flag=false; // 连接标志位 是否连接成功
static mqtt_client_state_t mqtt_sta = MQTT_STATE_UNKNOWN; // MQTT状态

// MQTT初始化函数声明
void mqtt_app_init(void);
// MQTT发布消息函数声明
int mqtt_data_publish(const char* theme, const char* value);
// MQTT状态获取函数声明
mqtt_client_state_t mqtt_get_sta();
#endif

2. 函数实现

2.1 初始化函数

void mqtt_app_init(void)
{
    // 结构体赋值
    esp_mqtt_client_config_t mqtt_cfg = {
        .uri = ESP_MQTT_URI, // 域名
        .port = ESP_MQTT_PORT, // 端口
        .client_id = ESP_CLIENT_ID, // 设备id
        .username = ESP_PRODUCT_ID, // 产品id
        .password = ESP_MQTT_TOKEN, // TOKEN
    };
    // 初始化
    client = esp_mqtt_client_init(&mqtt_cfg);
    // 注册回调
    esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, mqtt_event_handler, client);
    // 启动
    esp_mqtt_client_start(client);
}

2.2 回调函数

static esp_err_t mqtt_event_handler_cb(esp_mqtt_event_handle_t event)
{
    esp_mqtt_client_handle_t client = event->client;
    int msg_id;
    switch (event->event_id) {
        case MQTT_EVENT_CONNECTED:
            ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED");
            msg_id = esp_mqtt_client_subscribe(client, ONENET_TOPIC_SUB, 0);
            ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
            if(msg_id != -1)
            {
                mqtt_connect_flag=true;
                mqtt_sta =MQTT_STATE_CONNECTED;
            }
            else
            {
                mqtt_connect_flag=false;
                mqtt_sta =MQTT_STATE_UNKNOWN;
            }
            break;
        case MQTT_EVENT_DISCONNECTED:
            ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED");
            break;
        case MQTT_EVENT_SUBSCRIBED:
            ESP_LOGI(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);
            msg_id = mqtt_data_publish("mylog","suss");
            ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);
            mqtt_connect_flag=true;
            mqtt_sta =MQTT_STATE_CONNECTED;
            break;
        case MQTT_EVENT_UNSUBSCRIBED:
            mqtt_connect_flag=false;
            mqtt_sta =MQTT_STATE_UNKNOWN;
            ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);
            break;
        case MQTT_EVENT_PUBLISHED:
            ESP_LOGI(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
            break;
        case MQTT_EVENT_DATA:
            ESP_LOGI(TAG, "MQTT_EVENT_DATA");
            printf("TOPIC=%.*s\r\n", event->topic_len, event->topic);
            printf("DATA=%.*s\r\n", event->data_len, event->data);
            break;
        case MQTT_EVENT_ERROR:
            mqtt_sta = MQTT_STATE_ERROR;
            ESP_LOGI(TAG, "MQTT_EVENT_ERROR");
            break;
        default:
            ESP_LOGI(TAG, "Other event id:%d", event->event_id);
            break;
    }
    return ESP_OK;
}

static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) {
    ESP_LOGD(TAG, "Event dispatched from event loop base=%s, event_id=%d", base, event_id);
    mqtt_event_handler_cb(event_data);
}

2.3 上报函数

int mqtt_data_publish(const char* theme, const char* value)
{
    char data_str[256];
    int msg_id=-1;
    // 使用sprintf格式化字符串 组装ONENET数据包   
    snprintf(data_str, sizeof(data_str), "{\"id\": \"123\",\"version\": \"1.0\",\"params\":{\"%s\":{\"value\":\"%s\"}}}", theme, value);
    if(mqtt_connect_flag==true)
    {
        msg_id = esp_mqtt_client_publish(client, ONENET_TOPIC_PUBLISH,data_str, 0, 0, 0);
        ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);
        // 检查发布结果
        if (msg_id != -1)
        {
            ESP_LOGI(TAG, "Sent publish successful, msg_id=%d", msg_id);
        }
        else
        {
            ESP_LOGE(TAG, "Failed to publish message");
        }
    }
    else
    {
        ESP_LOGW(TAG, "MQTT client is not connected");
    }
    return msg_id;
}

2.4 OneNet物模型上报数据格式

示例：

{
    "id": "123",
    "version": "1.0",
    "params": {
        "Power": {
            "value": "12345",
            "time": 1706673129818
        },
        "temp": {
            "value": 23.6,
            "time": 1706673129818
        }
    }
}