MQTT-Beispiel für ESP32

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

const char* WIFI_SSID = "YOUR_WIFI";
const char* WIFI_PASS = "YOUR_WIFI_PASSWORD";
const char* TOPIC = "your-project/sensors/temperature";

// Root-CA-Zertifikat (PEM) des TLS-Zertifikats des Brokers
const char* ROOT_CA = R"PEM(
-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----
)PEM";

WiFiClientSecure net;
PubSubClient mqtt(net);

// Wird für jede Nachricht auf einem abonnierten Topic ausgeführt
void onMessage(char* topic, byte* payload, unsigned int length) {
  Serial.printf("%s: %.*s\n", topic, length, (char*)payload);
}

void connectMqtt() {
  while (!mqtt.connected()) {
    // Jeder Client braucht eine eindeutige Client-ID
    String id = "esp32-" + String((uint32_t)ESP.getEfuseMac(), HEX);
    // Benutzername und Passwort aus Ihrem ConnectMQ-Dashboard
    if (mqtt.connect(id.c_str(), "YOUR_USERNAME", "YOUR_PASSWORD")) {
      // Temperatur-Topic abonnieren
      mqtt.subscribe(TOPIC);
    } else {
      delay(2000);
    }
  }
}

void setup() {
  Serial.begin(115200);
  // Zuerst mit dem WLAN verbinden
  WiFi.begin(WIFI_SSID, WIFI_PASS);
  while (WiFi.status() != WL_CONNECTED) delay(500);
  net.setCACert(ROOT_CA);
  // Mit Ihrem privaten ConnectMQ-Broker auf Port 8883 verbinden
  mqtt.setServer("YOUR_BROKER_HOST", 8883);
  mqtt.setCallback(onMessage);
}

void loop() {
  // Bei Verbindungsabbruch automatisch neu verbinden
  if (!mqtt.connected()) connectMqtt();
  mqtt.loop();
  static unsigned long last = 0;
  if (millis() - last > 10000) {
    last = millis();
    // Messwert als JSON publizieren
    mqtt.publish(TOPIC, "{\"temperature\":21.5}");
  }
}