ESP32-C6 na Prática: Comunicação MQTT

// Definicao de variaveis
#define topic_led "esp32/led/vermelho"  // Tópico MQTT para o LED Vermelho
#define broker_default "broker.emqx.io" // Endereço do Broker MQTT - Se desejar utilizar outro, substitua este pelo endereço do seu broker
#define mqtt_tcp_port_default 1883      // Porta do Broker MQTT TCP
#define mqtt_ws_port_default 8084       // Porta do Broker MQTT WebSocket emqx
#define id_mqtt "esp32c6_guilherme"     // ID do cliente MQTT - Pode ser alterado, mas deve ser único para cada cliente conectado ao broker

// Definição dos Tópicos MQTT
const char* topic_led_vermelho = topic_led;

// Configuração do Broker MQTT
const int mqtt_port = mqtt_tcp_port_default;
const char* idMqtt = id_mqtt;
String mqtt_server = broker_default;
int mqtt_ws_port = mqtt_ws_port_default;

// Função para lidar com eventos do WebSocket
void onWebSocketEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len) {
  switch (type) {
    case WS_EVT_CONNECT:
      Serial.printf("WebSocket client #%lu connected from %s\n", client->id(), client->remoteIP().toString().c_str());
      client->text("mqtt_server=" + mqtt_server + ";mqtt_port=" + String(mqtt_ws_port) + ";topic_led_vermelho=" + String(topic_led_vermelho));
      break;
    case WS_EVT_DISCONNECT:
      Serial.printf("WebSocket client #%lu disconnected\n", client->id());
      break;
    case WS_EVT_DATA:
      {
        String msg = "";
        for (size_t i = 0; i < len; i++) {
          msg += (char)data[i];
        }
        Serial.println("Mensagem recebida via WebSocket: " + msg);
        mqtt_server = msg.substring(msg.indexOf("mqtt_server=") + 12, msg.indexOf(";mqtt_port="));
        mqtt_ws_port = msg.substring(msg.indexOf("mqtt_port=") + 10).toInt();


        Serial.println("Novo servidor MQTT: " + mqtt_server);
        Serial.println("Nova porta WebSocket MQTT: " + String(mqtt_ws_port));
        mqtt.disconnect();
        break;
      }
    default:
      break;
  }
}

/*-------------------------------------------------------------------------------
  Tarefa para ler o estado do botão e publicar a mensagem no tópico MQTT
 *---------------------------------------------------------------------------*/
void taskBotao(void* parameter) {
  for (;;) {
    button.update();                                           // Atualiza o estado do botão
    if (button.wasPressed()) {                                 // Verifica se o botão foi pressionado
      Serial.println("Botão pressionado");                    
      ledState = !ledState;                                    // Inverte o estado do LED
      String msg = ledState ? "ON" : "OFF";                    
      mqtt.publish(topic_led_vermelho, msg.c_str(), false);    // Publica a mensagem no tópico do LED Vermelho
    }
    vTaskDelay(pdMS_TO_TICKS(100));                            // Aguarda 100 ms antes de verificar novamente
  }
}

// Função de conexao ao Broker MQTT
void connectMQTT() {
  while (!mqtt.connected()) {                                                        
    Serial.println("Conectando ao broker: " + mqtt_server + ":" + String(mqtt_port));
    mqtt.setServer(mqtt_server.c_str(), mqtt_port);


    if (mqtt.connect(idMqtt)) {
      Serial.println("Conectado!");


      // Assinar os tópicos dos LEDs
      mqtt.subscribe(topic_led_vermelho);


      // Imprime a mensagem no monitor serial
      Serial.println("Assinado nos tópicos: ");
      Serial.println(topic_led_vermelho);
    } else {
      Serial.print("Falha, código: ");  // Imprime a mensagem no monitor serial
      Serial.println(mqtt.state());     // Imprime o código de erro no monitor serial
      delay(5000);                      // Aguarda 5 segundos e tenta novamente
    }
  }
}
// Callback para processar mensagens recebidas do MQTT
void callback(char* topic, byte* message, unsigned int length) {
  String msg = "";                   // Cria uma string para armazenar a mensagem
  for (int i = 0; i < length; i++){  // Percorre a mensagem recebida
    msg += (char)message[i];         // Concatena os caracteres da mensagem
  }


  // Imprime a mensagem recebida no monitor serial - Log
  Serial.print("Mensagem recebida no tópico: ");
  Serial.println(topic);
  Serial.print("Conteúdo: ");
  Serial.println(msg);


  // Verifica se a mensagem é para o LED vermelho
  if (strcmp(topic, topic_led_vermelho) == 0){  // Compara o tópico recebido com o tópico do LED Vermelho
      if (msg == "ON") {
        setLED(true);
      } else if (msg == "OFF") {
        setLED(false);
      }
  }
}

function salvarConfiguracoes() {
        mqtt_server = document.getElementById("mqtt_server").value;
        mqtt_port = document.getElementById("mqtt_port").value;


        if (!mqtt_server || !mqtt_port) {
          alert("Por favor, preencha o Broker MQTT e a Porta WebSocket MQTT.");
          return;
        }
        if (websocket && websocket.readyState === WebSocket.OPEN) {
          websocket.send(`mqtt_server=${mqtt_server};mqtt_port=${mqtt_port}`);
          console.log("Configurações salvas via WebSocket");
          iniciarClienteMQTT();
        } else {
          console.warn("WebSocket não conectado");
        }
      }

function iniciarClienteMQTT() {
        if (mqttClient && mqttClient.connected) {
          mqttClient.end(); // desconecta se já estava conectado
        }


        mqttClient = mqtt.connect(`wss://${mqtt_server}:${mqtt_port}/mqtt`);


        mqttClient.on("connect", () => {
          document.getElementById("status").textContent = "Conectado!";
          mqttClient.subscribe(topic_led_vermelho);
        });


        mqttClient.on("message", (topic, message) => {
          console.log(`Mensagem: ${message.toString()} do tópico: ${topic}`);
          if (topic === topic_led_vermelho) {
            atualizarEstado(message.toString());
          }
        });
      }
function toggleLed(element) {
        const comando = element.checked ? "ON" : "OFF";
        mqttClient.publish(topic_led_vermelho, comando);
      }