Cómo usar MQTT y Json en el ESP8266 o ESP32

El programa principal queda, esencialmente, idéntico al ejemplo anterior. La única diferencia, es que hemos añadido la dependencia a la librería ArduinoJson.

#include <WiFi.h>
#include <AsyncMqttClient.h>
#include <ArduinoJson.h>

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

void setup(void)
{
  Serial.begin(115200);
  delay(500);

  WiFi.onEvent(WiFiEvent);
  InitMqtt();

  ConnectWiFi_STA();
}

void loop()
{
  PublishMqtt();

  delay(1000);
}

Lo que sí ha cambiado, lógicamente, es el fichero MQTT.hpp. Recordamos que en este fichero hemos agrupado la funcionalidad específica de nuestro proyecto en cuanto a MQTT.

Como vemos, en lugar de enviar un simple dato como en el ejemplo anterior, donde enviábamos el valor millis(), esta vez estamos enviando una cadena de texto codificada como Json.

En este Json estamos codificando un campo ‘data’ con el valor de millis(). Evidentemente, el Json podría ser cualquier otra cosa. Pero, para mostrar el uso y probar la comunicación, es suficiente.

Por otro lado, en la función de callback OnMqttReceived, estamos recibiendo el mensaje MQTT, decodificando el Json, y mostrando por puerto serial el campo ‘data’, que contiene el valor de millis() enviado.

#pragma once

const IPAddress MQTT_HOST(192, 168, 1, 150);
const int MQTT_PORT = 1883;

AsyncMqttClient mqttClient;

String GetPayloadContent(char* data, size_t len)
{
  String content = "";
  for(size_t i = 0; i < len; i++)
  {
    content.concat(data[i]);
  }
  return content;
}

void SuscribeMqtt()
{
  uint16_t packetIdSub = mqttClient.subscribe("hello/world", 0);
  Serial.print("Subscribing at QoS 2, packetId: ");
  Serial.println(packetIdSub);
}

void PublishMqtt()
{
  String payload = "";

  StaticJsonDocument<300> jsonDoc;
  jsonDoc["data"] = millis();
  serializeJson(jsonDoc, payload);

  mqttClient.publish("hello/world", 0, true, (char*)payload.c_str());
}

void OnMqttReceived(char* topic, char* payload, AsyncMqttClientMessageProperties properties, size_t len, size_t index, size_t total)
{
  Serial.print("Received on ");
  Serial.print(topic);
  Serial.print(": ");

  String content = GetPayloadContent(payload, len);

  StaticJsonDocument<200> doc;
  DeserializationError error = deserializeJson(doc, content);
  if(error) return;

  unsigned long data = doc["data"];
  Serial.print("Millis:");
  Serial.println(data);
}