ESP32 + MCP over MQTT：从 0 到 1 打造情感陪伴智能体

| - CMakeLists.txt| - sdkconfig| - main| --- main.c| --- CMakeLists.txt

# The following lines of boilerplate have to be in your project's# CMakeLists in this exact order for cmake to work correctlycmake_minimum_required(VERSION 3.16)set(CMAKE_EXPORT_COMPILE_COMMANDS ON)
include($ENV{IDF_PATH}/tools/cmake/project.cmake)project(main)

CONFIG_MQTT_PROTOCOL_5=yCONFIG_ESP_WIFI_SOFTAP_SUPPORT=n

#include <stdio.h>
#include "freertos/FreeRTOS.h"#include "freertos/event_groups.h"#include "freertos/task.h"
#include "esp_log.h"#include "esp_mac.h"#include "esp_system.h"#include "esp_wifi.h"#include "mqtt_client.h"#include "nvs_flash.h"
#define PIN_NUM_SCLK 21#define PIN_NUM_MOSI 47#define PIN_NUM_MISO -1
#define LCD_H_RES 240
static EventGroupHandle_t s_wifi_event_group;static int                s_retry_num = 0;static esp_mqtt_client_handle_t client;
static const char *WIFI_SSID     = "wifi_ssid";static const char *WIFI_PASSWORD = "wifi_password";static const char *MQTT_BROKER =    "mqtts://xxyyzzz:8883";static const char *username = "user";static const char *password = "password";static const char *cert =    "-----BEGIN CERTIFICATE-----\n"    "MIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\n"    "MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\n"    "d3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\n"    "QTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\n"    "MRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\n"    "b20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n"    "9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\n"    "CSDMAZOnTjC3U/dDxGkAV53ijSLdhwZAAIEJzs4bg7/fzTtxRuLWZscFs3YnFo97\n"    "nh6Vfe63SKMI2tavegw5BmV/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n"    "43C/dxC//AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\n"    "T19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr/y7vrTC0LUq7dBMtoM1O/4\n"    "gdW7jVg/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\n"    "BgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH/BAUwAwEB/zAdBgNVHQ4EFgQUA95QNVbR\n"    "TLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\n"    "DQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY/Esr\n"    "hMAtudXH/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp/2PV5Adg\n"    "06O/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\n"    "PnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\n"    "YSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\n"    "CAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n"    "-----END CERTIFICATE-----";
static void event_handler(void *arg, esp_event_base_t event_base,                          int32_t event_id, void *event_data){    if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_START) {        esp_wifi_connect();    } else if (event_base == WIFI_EVENT &&               event_id == WIFI_EVENT_STA_DISCONNECTED) {        if (s_retry_num < 5) {            esp_wifi_connect();            s_retry_num++;            ESP_LOGI("wifi sta", "retry to connect to the AP");        } else {            xEventGroupSetBits(s_wifi_event_group, BIT1);        }        ESP_LOGI("wifi sta", "connect to the AP fail");    } else if (event_base == IP_EVENT && event_id == IP_EVENT_STA_GOT_IP) {        ip_event_got_ip_t *event = (ip_event_got_ip_t *) event_data;        ESP_LOGI("wifi sta", "ip: " IPSTR ", mask: " IPSTR ", gateway: " IPSTR,                 IP2STR(&event->ip_info.ip), IP2STR(&event->ip_info.netmask),                 IP2STR(&event->ip_info.gw));        s_retry_num = 0;        xEventGroupSetBits(s_wifi_event_group, BIT0);    }}
int wifi_init_sta(void){    s_wifi_event_group = xEventGroupCreate();
    ESP_ERROR_CHECK(esp_netif_init());    ESP_ERROR_CHECK(esp_event_loop_create_default());
    esp_netif_create_default_wifi_sta();    wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();    ESP_ERROR_CHECK(esp_wifi_init(&cfg));
    esp_event_handler_instance_t instance_any_id;    esp_event_handler_instance_t instance_got_ip;
    ESP_ERROR_CHECK(esp_event_handler_instance_register(        WIFI_EVENT, ESP_EVENT_ANY_ID, &event_handler, NULL, &instance_any_id));    ESP_ERROR_CHECK(esp_event_handler_instance_register(        IP_EVENT, IP_EVENT_STA_GOT_IP, &event_handler, NULL, &instance_got_ip));
    wifi_config_t wifi_config = {        .sta = {            .threshold.authmode = WIFI_AUTH_WPA2_PSK,            .sae_pwe_h2e = WPA3_SAE_PWE_BOTH,            .sae_h2e_identifier = "",        },    };    strcpy((char *) wifi_config.sta.ssid, WIFI_SSID);    strcpy((char *) wifi_config.sta.password, WIFI_PASSWORD);    ESP_ERROR_CHECK(esp_wifi_set_mode(WIFI_MODE_STA));    ESP_ERROR_CHECK(esp_wifi_set_config(WIFI_IF_STA, &wifi_config));    ESP_ERROR_CHECK(esp_wifi_start());
    ESP_LOGI("wifi sta", "wifi init finished.");
    EventBits_t bits = xEventGroupWaitBits(s_wifi_event_group, BIT0 | BIT1,                                           pdFALSE, pdFALSE, portMAX_DELAY);
    if (bits & BIT0) {        ESP_LOGI("wifi sta", "connected to ap SSID: %s", CONFIG_WIFI_SSID);    } else if (bits & BIT1) {        ESP_LOGI("wifi sta", "Failed to connect to SSID: %s", CONFIG_WIFI_SSID);    } else {        ESP_LOGE("wifi sta", "UNEXPECTED EVENT");    }
    return 0;}
static void mqtt5_event_handler(void *handler_args, esp_event_base_t base,                                int32_t event_id, void *event_data){    char *TAG = "mqtt5";    ESP_LOGD(TAG, "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;
    ESP_LOGD(TAG, "free heap size is %" PRIu32 ", minimum %" PRIu32,             esp_get_free_heap_size(), esp_get_minimum_free_heap_size());    ESP_LOGI(TAG, "event_id=%" PRIi32, event_id);
    switch ((esp_mqtt_event_id_t) event_id) {    case MQTT_EVENT_CONNECTED:        msg_id = esp_mqtt_client_publish(client, "emqx/esp32",                                         "Hi EMQX I'm ESP32 ^^", 0, 1, 0);        ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);        break;    case MQTT_EVENT_DISCONNECTED:    case MQTT_EVENT_SUBSCRIBED:    case MQTT_EVENT_PUBLISHED:    case MQTT_EVENT_DATA:        break;    case MQTT_EVENT_UNSUBSCRIBED:        esp_mqtt_client_disconnect(client);        break;    case MQTT_EVENT_ERROR:        ESP_LOGI(TAG, "MQTT5 return code is %d",                 event->error_handle->connect_return_code);        if (event->error_handle->error_type == MQTT_ERROR_TYPE_TCP_TRANSPORT) {            ESP_LOGI(TAG, "Last errno string (%s)",                     strerror(event->error_handle->esp_transport_sock_errno));        }        break;    default:        ESP_LOGI(TAG, "Other event id:%d", event->event_id);        break;    }}
int mqtt_init(void){    esp_mqtt_client_config_t mqtt5_cfg = {        .broker.address.uri                  = MQTT_BROKER,        .session.protocol_ver                = MQTT_PROTOCOL_V_5,        .network.disable_auto_reconnect      = true,        .credentials.username                = username,        .credentials.authentication.password = password,        .broker.verification.certificate     = cert,    };
    client = esp_mqtt_client_init(&mqtt5_cfg);    esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID,                                   mqtt5_event_handler, NULL);    esp_mqtt_client_start(client);    return 0;}
void app_main(void){    esp_err_t ret = nvs_flash_init();    if (ret == ESP_ERR_NVS_NO_FREE_PAGES ||        ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {        ESP_ERROR_CHECK(nvs_flash_erase());        ret = nvs_flash_init();    }    ESP_ERROR_CHECK(ret);
    wifi_init_sta();    mqtt_init();
    while (1) {        vTaskDelay(pdMS_TO_TICKS(3000));        int msg_id = esp_mqtt_client_publish(client, "emqx/esp32",                                             "Hi EMQX I'm ESP32 ^^", 0, 1, 0);        ESP_LOGI("mqtt", "sent publish successful, msg_id=%d", msg_id);    }}

idf_component_register(SRCS "main.c"                    PRIV_REQUIRES mqtt esp_wifi nvs_flash                    INCLUDE_DIRS ".")

static const char *WIFI_SSID     = "wifi_ssid";static const char *WIFI_PASSWORD = "wifi_password";static const char *MQTT_BROKER =    "mqtts://xxyyzzz:8883";static const char *username = "user";static const char *password = "password";

idf.py build idf.py flash monitor