Reconfigurar clientes MQTT después de HiveMQ: ejemplos para ESP32, Python, Node.js y Node-RED

Sacar un cliente de HiveMQ Cloud Serverless cambia cuatro cosas: el hostname, las credenciales, el client ID y, a veces, los ajustes de confianza de TLS. Tus topics, tus payloads y la lógica de tu aplicación siguen igual. Este artículo muestra exactamente qué cambiar en los clientes más habituales, con ejemplos de antes y después usando como destino un broker privado de ConnectMQ.

El proceso general está en la guía de migración de HiveMQ Serverless.

Qué cambia y qué se mantiene

Fíjate en el puerto de WebSocket seguro: los dashboards de navegador suelen tener 8884 escrito en el código, mientras que ConnectMQ usa 8084. Revisa en la consola de HiveMQ los valores exactos que usaba tu clúster.

ESP32 con Arduino y PubSubClient

Antes (HiveMQ Cloud):

const char* MQTT_HOST = "abc123.s1.eu.hivemq.cloud";
const char* MQTT_USER = "hivemq-user";
const char* MQTT_PASS = "hivemq-pass";
String clientId = "sensor-" + WiFi.macAddress();

Después (ConnectMQ):

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

const char* MQTT_HOST = "broker.connectmq.com";
const int   MQTT_PORT = 8883;
const char* MQTT_USER = "YOUR_USERNAME";
const char* MQTT_PASS = "YOUR_PASSWORD";
const char* CLIENT_ID_BASE = "YOUR_CLIENT_ID";

// ISRG Root X1 (Let's Encrypt): pega el PEM de letsencrypt.org/certificates
static const char ROOT_CA[] PROGMEM = R"EOF(
-----BEGIN CERTIFICATE-----
...ISRG Root X1...
-----END CERTIFICATE-----
)EOF";

WiFiClientSecure net;
PubSubClient mqtt(net);

void connectMqtt() {
  String mac = WiFi.macAddress();
  mac.replace(":", "");
  String clientId = String(CLIENT_ID_BASE) + "_" + mac;   // ID emitido + sufijo único
  while (!mqtt.connected()) {
    if (mqtt.connect(clientId.c_str(), MQTT_USER, MQTT_PASS)) {
      mqtt.publish("site1/esp32/status", "online", true);  // vuelve a publicar el estado retenido
      mqtt.subscribe("site1/esp32/cmd");
    } else {
      delay(5000);
    }
  }
}

void setup() {
  // ... conecta primero el Wi-Fi ...
  net.setCACert(ROOT_CA);
  mqtt.setServer(MQTT_HOST, MQTT_PORT);
  mqtt.setBufferSize(1024);
  connectMqtt();
}

void loop() {
  if (!mqtt.connected()) connectMqtt();
  mqtt.loop();
}

Si tu firmware para HiveMQ usaba setInsecure(), aprovecha para verificar los certificados correctamente. Tienes más detalles en ESP32 MQTT con SSL. Recuerda que el ESP32 necesita la hora correcta para algunas pilas TLS; sincroniza NTP antes de conectarte.

Python con paho-mqtt 2.x

Antes:

client.username_pw_set("hivemq-user", "hivemq-pass")
client.connect("abc123.s1.eu.hivemq.cloud", 8883)

Después:

# pip install "paho-mqtt>=2.0"
import os, ssl
import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, reason_code, properties):
    print("Connected:", reason_code)
    client.subscribe("site1/#", qos=1)

client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2,
                     client_id=os.environ["MQTT_CLIENT_ID"] + "_ingest",
                     protocol=mqtt.MQTTv5)
client.username_pw_set(os.environ["MQTT_USERNAME"], os.environ["MQTT_PASSWORD"])
client.tls_set(cert_reqs=ssl.CERT_REQUIRED)   # el almacén de CA del sistema confía en Let's Encrypt
client.on_connect = on_connect
client.on_message = lambda c, u, m: print(m.topic, m.payload.decode())
client.connect("broker.connectmq.com", 8883)
client.loop_forever()

Suscribirse en on_connect es importante: restaura las suscripciones tras cada reconexión, de modo que el cliente nunca depende del estado de sesión almacenado en un broker. Consulta paho-mqtt en Python y reconexión con paho-mqtt.

Node.js con MQTT.js

// npm install mqtt
const mqtt = require("mqtt");

const client = mqtt.connect("mqtts://broker.connectmq.com:8883", {
  // antes: mqtts://abc123.s1.eu.hivemq.cloud:8883
  username: process.env.MQTT_USERNAME,
  password: process.env.MQTT_PASSWORD,
  clientId: `${process.env.MQTT_CLIENT_ID}_api`,
  protocolVersion: 5,
  reconnectPeriod: 2000,
});

client.on("connect", () => client.subscribe("site1/+/telemetry", { qos: 1 }));
client.on("message", (topic, payload) => console.log(topic, payload.toString()));
client.on("error", (err) => console.error("MQTT error:", err.message));

Para un dashboard en el navegador, usa wss://broker.connectmq.com:8084/mqtt con las mismas opciones. Consulta MQTT.js con Node.js y MQTT sobre WebSocket.

Node-RED

En Node-RED, todos los nodos MQTT comparten un único nodo de configuración del broker, así que la migración suele ser una sola edición:

1. Abre cualquier nodo mqtt in o mqtt out y haz clic en el lápiz junto al servidor.
2. Pestaña Connection: pon Server en broker.connectmq.com, Port en 8883, marca Use TLS y selecciona una configuración TLS que verifique el certificado del servidor. Pon Protocol en MQTT V5 si usas funciones de MQTT 5.
3. Client ID: introduce tu client ID emitido con un sufijo, por ejemplo YOUR_CLIENT_ID_nodered.
4. Pestaña Security: introduce el nuevo usuario y la nueva contraseña.
5. Haz Deploy y comprueba que los nodos muestran connected.

Si el nodo sigue mostrando "connecting", consulta Node-RED MQTT no conecta y Node-RED MQTT con TLS.

Clientes de línea de comandos de mosquitto

mosquitto_sub -h broker.connectmq.com -p 8883 --capath /etc/ssl/certs \
  -u YOUR_USERNAME -P YOUR_PASSWORD -i YOUR_CLIENT_ID_cli \
  -t 'site1/#' -v

En Windows o macOS, usa --cafile con un bundle PEM que contenga ISRG Root X1 en lugar de --capath.

Solución de problemas de conexión

Facilita el próximo cambio

Ya que vas a editar todos los clientes, traslada el hostname, el puerto, las credenciales y el client ID a una configuración que pueda actualizarse en remoto: un archivo de configuración, variables de entorno, un servicio de aprovisionamiento o un payload de ajustes por OTA. Así, rotar credenciales o cambiar de broker en el futuro será un envío de configuración, no un proyecto de firmware.

Puedes probar cualquiera de estos ejemplos ahora mismo contra un broker gratuito en app.connectmq.com.

Preguntas frecuentes

¿Tengo que cambiar mis topics al dejar HiveMQ Cloud?

No. Los topics, los payloads y los niveles de QoS siguen igual. Solo cambian los ajustes de conexión.

¿Por qué ConnectMQ exige un client ID concreto?

Vincular los client IDs a las credenciales impide que otro inquilino o una credencial filtrada suplanten a tus dispositivos. Aun así, puedes ejecutar muchos clientes con un mismo conjunto de credenciales añadiendo un sufijo único.

¿El puerto 8883 es el mismo en ambos brokers?

Sí, MQTT sobre TLS usa el 8883 en los dos. El puerto de WebSocket seguro es distinto: ConnectMQ usa el 8084 con la ruta /mqtt.

¿Puedo seguir usando setInsecure en el ESP32?

Se conectará, pero se salta la verificación del servidor y expone los dispositivos a suplantaciones. Usa en su lugar el certificado ISRG Root X1.