mirror of
https://gitee.com/beecue/fastbee.git
synced 2025-12-19 01:15:54 +08:00
99 lines
3.7 KiB
C
99 lines
3.7 KiB
C
/******************************************************************************
|
||
* 作者：kerwincui
|
||
* 时间：2021-06-08
|
||
* 邮箱：164770707@qq.com
|
||
* 源码地址：https://gitee.com/kerwincui/wumei-smart
|
||
* author: kerwincui
|
||
* create: 2021-06-08
|
||
* email：164770707@qq.com
|
||
* source:https://github.com/kerwincui/wumei-smart
|
||
******************************************************************************/
|
||
#include "mqtt_ssl.h"
|
||
|
||
static const char *TAG = "MQTTS";
|
||
|
||
extern const uint8_t client_cert_pem_start[] asm("_binary_client_crt_start");
|
||
extern const uint8_t client_cert_pem_end[] asm("_binary_client_crt_end");
|
||
extern const uint8_t client_key_pem_start[] asm("_binary_client_key_start");
|
||
extern const uint8_t client_key_pem_end[] asm("_binary_client_key_end");
|
||
|
||
static esp_err_t mqtt_event_handler(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, "/topic/qos0", 0);
|
||
ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
|
||
|
||
msg_id = esp_mqtt_client_subscribe(client, "/topic/qos1", 1);
|
||
ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
|
||
|
||
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");
|
||
break;
|
||
default:
|
||
ESP_LOGI(TAG, "Other event id:%d", event->event_id);
|
||
break;
|
||
}
|
||
return ESP_OK;
|
||
}
|
||
|
||
static void mqtt_app_start(void)
|
||
{
|
||
const esp_mqtt_client_config_t mqtt_cfg = {
|
||
.uri = BROKEN_SSL_URL,
|
||
.event_handle = mqtt_event_handler,
|
||
.client_cert_pem = (const char *)client_cert_pem_start,
|
||
.client_key_pem = (const char *)client_key_pem_start,
|
||
};
|
||
|
||
ESP_LOGI(TAG, "[APP] Free memory: %d bytes", esp_get_free_heap_size());
|
||
esp_mqtt_client_handle_t client = esp_mqtt_client_init(&mqtt_cfg);
|
||
esp_mqtt_client_start(client);
|
||
}
|
||
|
||
void mqtt_ssl_start(void)
|
||
{
|
||
ESP_LOGI(TAG, "[APP] Startup..");
|
||
ESP_LOGI(TAG, "[APP] Free memory: %d bytes", esp_get_free_heap_size());
|
||
ESP_LOGI(TAG, "[APP] 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("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());
|
||
|
||
mqtt_app_start();
|
||
}
|