Cómo usar MQTT en el ESP8266/ESP32

Nuestro sketch principal queda sencillo y fácil de entender. Aquí hay algunas llamadas a funciones definidas en los ficheros, que veremos a continuación.

Pero, en resumen, en el setup iniciamos el WiFi y la comunicación MQTT. Por otro lado, en el ‘loop’, gestionamos los mensajes recibidos por MQTT, a la vez que enviamos el valor de ‘millis()‘. Sencillo.

#include <WiFi.h>
#include <SPIFFS.h>
#include <PubSubClient.h>

#include "config.h"  // Sustituir con datos de vuestra red
#include "MQTT.hpp"
#include "ESP32_Utils.hpp"
#include "ESP32_Utils_MQTT.hpp"

void setup(void)
{
  Serial.begin(115200);
  SPIFFS.begin();

  ConnectWiFi_STA(true);

  InitMqtt();
}

void loop()
{
  HandleMqtt();

  PublisMqtt(millis());

  delay(1000);
}

Por su parte, el fichero “ESP32_Utils_MQTT.hpp” contiene funciones que genéricas para comunicación en MQTT. Al igual que los otros ficheros ‘Utils’ que hemos usado, está pensado para contener código que podéis reusar entre proyectos con poca o ninguna modificación.

Aquí tenemos estas funciones para InitMqtt(), ConnectMqtt(), y HandleMqtt()

void InitMqtt() 
{
  mqttClient.setServer(MQTT_BROKER_ADRESS, MQTT_PORT);
  SuscribeMqtt();
  mqttClient.setCallback(OnMqttReceived);
}

void ConnectMqtt()
{
  while (!mqttClient.connected())
  {
    Serial.print("Starting MQTT connection...");
    if (mqttClient.connect(MQTT_CLIENT_NAME))
    {
      SuscribeMqtt();
    }
    else
    {
      Serial.print("Failed MQTT connection, rc=");
      Serial.print(mqttClient.state());
      Serial.println(" try again in 5 seconds");

      delay(5000);
    }
  }
}

void HandleMqtt()
{
  if (!mqttClient.connected())
  {
    ConnectMqtt();
  }
  mqttClient.loop();
}

Finalmente, en el fichero ‘MQTT.hpp’ hemos definido las funciones que sí son específicas de tu proyecto. En estas funciones está “la chicha” del proyecto, y deberemos adaptarlas en función de las características del mismo.

Así, tenemos en primer lugar las definiciones de la dirección del broker, el puerto (por defecto 1883 está bien), y el nombre del cliente. Recordad que dos clientes con el mismo nombre no deben conectarse al mismo broker.

Por otro lado, tenemos la función SuscribeMqtt que se encarga de sindicar al ESP8266/ESP32 a los topic que queramos escuchar. La función PublisMqtt emite un mensaje por MQTT, en este caso simplemente un número long. Finalmente, la función OnMqttReceived se ejecuta al recibir un mensaje por MQTT y, en este ejemplo, simplemente muestra el contenido por puerto serie.

const char* MQTT_BROKER_ADRESS = "192.168.1.150";
const uint16_t MQTT_PORT = 1883;
const char* MQTT_CLIENT_NAME = "ESP8266Client_1";

WiFiClient espClient;
PubSubClient mqttClient(espClient);

void SuscribeMqtt()
{
  mqttClient.subscribe("hello/world");
}

String payload;
void PublisMqtt(unsigned long data)
{
  payload = "";
  payload = String(data);
  mqttClient.publish("hello/world", (char*)payload.c_str());
}

String content = "";
void OnMqttReceived(char* topic, byte* payload, unsigned int length) 
{
  Serial.print("Received on ");
  Serial.print(topic);
  Serial.print(": ");

  content = "";  
  for (size_t i = 0; i < length; i++) {
    content.concat((char)payload[i]);
  }
  Serial.print(content);
  Serial.println();
}