【ESP32-C3-DevKitM-1】ESP32-C3连接MQTT服务器

怀揣少年梦 发表于 2021-7-30 10:42

MQTT是一种发布和订阅式的消息协议，它是基于TCP/IP协议上的。它所具备的特点就是轻量、简单、开放和易于实现。它其实是一个消息中间商，设备发布主题，设备再订阅主图，只要订阅和发布的TOPIC一致，我就把消息传过去。可以一对多。使用ESP32-C3来测试一下MQTT协议。

使用的硬件：ESP32-C3

客户端：MQTTX（如图）



程序是基于MQTT/TCP例程编写：

1、只需要配置要连接的MQTT服务器的URL即可，并且要设置wifi的密码和SSID。

我这里使用"mqtt://broker.emqx.io"

<ol start="2">
<li style="text-align:justify">下载，并打开监视器。</li>
<li style="text-align:justify">在MQTTX客户端创建连接，并订阅主题/topic/qos0。就可以在客户端发送消息给ESP32。效果如图所示。</li>
</ol>



 



 

        4、程序

<pre>
<code>/* MQTT (over TCP) Example

This example code is in the Public Domain (or CC0 licensed, at your option.)

Unless required by applicable law or agreed to in writing, this
software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
CONDITIONS OF ANY KIND, either express or implied.
*/

#include <stdio.h>
#include <stdint.h>
#include <stddef.h>
#include <string.h>
#include "esp_wifi.h"
#include "esp_system.h"
#include "nvs_flash.h"
#include "esp_event.h"
#include "esp_netif.h"
#include "protocol_examples_common.h"

#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "freertos/semphr.h"
#include "freertos/queue.h"

#include "lwip/sockets.h"
#include "lwip/dns.h"
#include "lwip/netdb.h"

#include "esp_log.h"
#include "mqtt_client.h"

static const char *TAG = "MQTT_EXAMPLE";

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

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;
// your_context_t *context = event->context;
switch (event->event_id) {
 case MQTT_EVENT_CONNECTED:// 建立连接成功
 ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED");
 // 发布主题
 msg_id = esp_mqtt_client_publish(client, "/topic/qos1", "data_3", 0, 1, 0);
 ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);
 //订阅TOPIC:/topic/qos0
 msg_id = esp_mqtt_client_subscribe(client, "/topic/qos0", 0);
 ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
 //订阅TOPIC:/topic/qos1
 msg_id = esp_mqtt_client_subscribe(client, "/topic/qos1", 1);
 ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
 //取消订阅TOPIC:/topic/qos1
 msg_id = esp_mqtt_client_unsubscribe(client, "/topic/qos1");
 ESP_LOGI(TAG, "sent unsubscribe successful, msg_id=%d", msg_id);
 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 = esp_mqtt_client_publish(client, "/topic/qos0", "data", 0, 0, 0);
 ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);
 break;
 case MQTT_EVENT_UNSUBSCRIBED:// 取消订阅
 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:// 客户端遇到错误
 ESP_LOGI(TAG, "MQTT_EVENT_ERROR");
 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(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;
}
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);
}

static void mqtt_app_start(void)
{
//定义一个MQTT客户端配置结构体，输入MQTT的url
esp_mqtt_client_config_t mqtt_cfg = {
 // .uri = CONFIG_BROKER_URL,
 .uri= "mqtt://broker.emqx.io"

};
#if CONFIG_BROKER_URL_FROM_STDIN
char line;

if (strcmp(mqtt_cfg.uri, "FROM_STDIN") == 0) {
 int count = 0;
 printf("Please enter url of mqtt broker\n");
 while (count < 128) {
 int c = fgetc(stdin);
 if (c == '\n') {
 line = '\0';
 break;
 } else if (c > 0 && c < 127) {
 line = c;
 ++count;
 }
 vTaskDelay(10 / portTICK_PERIOD_MS);
 }
 mqtt_cfg.uri = line;
 printf("Broker url: %s\n", line);
} else {
 ESP_LOGE(TAG, "Configuration mismatch: wrong broker url");
 abort();
}
#endif /* CONFIG_BROKER_URL_FROM_STDIN */
//通过esp_mqtt_client_init获取MQTT客户端结构体指针，参数为MQTT客户端配置结构体
esp_mqtt_client_handle_t client = esp_mqtt_client_init(&mqtt_cfg);
//注册MQTT事件
esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, mqtt_event_handler, client);
//开启MQTT功能
esp_mqtt_client_start(client);
}

void app_main(void)
{
ESP_LOGI(TAG, " Startup..");
ESP_LOGI(TAG, " Free memory: %d bytes", esp_get_free_heap_size());
ESP_LOGI(TAG, " IDF version: %s", esp_get_idf_version());

esp_log_level_set("*", ESP_LOG_INFO);
esp_log_level_set("MQTT_CLIENT", ESP_LOG_VERBOSE);
esp_log_level_set("MQTT_EXAMPLE", ESP_LOG_VERBOSE);
esp_log_level_set("TRANSPORT_TCP", ESP_LOG_VERBOSE);
esp_log_level_set("TRANSPORT_SSL", ESP_LOG_VERBOSE);
esp_log_level_set("TRANSPORT", ESP_LOG_VERBOSE);
esp_log_level_set("OUTBOX", ESP_LOG_VERBOSE);

ESP_ERROR_CHECK(nvs_flash_init());
ESP_ERROR_CHECK(esp_netif_init());
ESP_ERROR_CHECK(esp_event_loop_create_default());

/* This helper function configures Wi-Fi or Ethernet, as selected in menuconfig.
* Read "Establishing Wi-Fi or Ethernet Connection" section in
* examples/protocols/README.md for more information about this function.
*/
//连接WIFI
ESP_ERROR_CHECK(example_connect());

mqtt_app_start();
}
</code></pre>

freebsder 发表于 2021-7-30 16:17

C确实麻烦，前几年用java做mqtt，简直比C舒服太多了。

怀揣少年梦 发表于 2021-7-31 08:30

freebsder 发表于 2021-7-30 16:17
C确实麻烦，前几年用java做mqtt，简直比C舒服太多了。

膜拜大佬，小白只会C

damiaa 发表于 2021-8-16 11:07

谢谢分享！

页: [1]

电子工程世界-论坛's Archiver

【ESP32-C3-DevKitM-1】ESP32-C3连接MQTT服务器