MQTT Relaiskarte mit UI
Dieser Code steuert ein Relais über einen ESP8266 (Wemos D1 Mini) mit MQTT und einer Weboberfläche.
Funktionen:
Relaissteuerung per MQTT:
- Der ESP8266 verbindet sich mit einem MQTT-Broker.
- Nachrichten an das Thema
Relaiskarte1/Relaismit den Wertentrueoderfalseschalten das Relais ein bzw. aus.
Weboberfläche:
- Die integrierte Webseite zeigt den aktuellen Relaisstatus an.
- Über einen Button kann das Relais ein- und ausgeschaltet werden.
- Der Relaisstatus und die Beschriftung des Buttons werden automatisch aktualisiert, ohne dass die Seite neu geladen werden muss.
Statusabfrage:
- Eine zusätzliche URL
/statusliefert den aktuellen Status des Relais im JSON-Format. Diese wird genutzt, um die Weboberfläche dynamisch zu aktualisieren.
- Eine zusätzliche URL
Pin-Belegung:
- D1 (GPIO5): Steuerung des Relais.
- HIGH: Relais ist eingeschaltet.
- LOW: Relais ist ausgeschaltet.
Voraussetzungen:
- Ein MQTT-Broker, der unter der angegebenen IP-Adresse und Zugangsdaten erreichbar ist.
- Ein Wemos D1 Mini oder ein anderer ESP8266 mit installiertem Arduino-Code.
Vorteile:
- Kombination von MQTT und einer modernen Weboberfläche.
- Automatische Aktualisierung des Status auf der Webseite.
- Flexibel anpassbar für andere Projekte oder Hardware.
Dieser Code ist ideal, um smarte Relaissteuerungen in Hausautomationen zu integrieren!
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
// WLAN Konfiguration
const char* ssid = "WLAN-SSID";
const char* password = "WLAN-Passwort";
// MQTT Konfiguration
const char* mqtt_server = "192.168.x.xxx";
const int mqtt_port = 1885;
const char* mqtt_user = "MQTT-User";
const char* mqtt_password = "MQTT-Passwort";
String device_name = "Relaiskarte1";
String topic_relais = device_name + "/Relais";
String topic_ip = device_name + "/IP";
// Relais-Pin
const int relaisPin = D1;
// Globale Variablen
WiFiClient espClient;
PubSubClient client(espClient);
WiFiServer webServer(80);
String ip_address = "";
bool relaisStatus = false; // Relaisstatus speichern
void setup() {
Serial.begin(115200);
delay(100);
// Relais-Pin konfigurieren
pinMode(relaisPin, OUTPUT);
digitalWrite(relaisPin, LOW);
// WLAN verbinden
connectWiFi();
// MQTT-Client konfigurieren
client.setServer(mqtt_server, mqtt_port);
client.setCallback(callback);
// Webserver starten
webServer.begin();
Serial.println("Webserver gestartet!");
// IP-Adresse ermitteln
ip_address = WiFi.localIP().toString();
}
void loop() {
if (!client.connected()) {
reconnectMQTT();
}
client.loop();
handleWebServer();
}
void connectWiFi() {
WiFi.begin(ssid, password);
Serial.print("Verbinde mit WLAN...");
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println(" verbunden!");
Serial.print("IP-Adresse: ");
Serial.println(WiFi.localIP());
}
void reconnectMQTT() {
while (!client.connected()) {
Serial.print("Verbinde mit MQTT...");
String clientId = "Relaiskarte-" + String(ESP.getChipId());
if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {
Serial.println(" verbunden!");
// Themen abonnieren
client.subscribe(topic_relais.c_str());
Serial.println("Thema abonniert: " + topic_relais);
// IP-Adresse veröffentlichen
client.publish(topic_ip.c_str(), ip_address.c_str(), true);
} else {
Serial.print(" Fehler, rc=");
Serial.print(client.state());
Serial.println(" Neuer Versuch in 5 Sekunden...");
delay(5000);
}
}
}
void callback(char* topic, byte* payload, unsigned int length) {
String receivedTopic = String(topic);
String message = "";
for (unsigned int i = 0; i < length; i++) {
message += (char)payload[i];
}
Serial.println("MQTT Nachricht erhalten:");
Serial.println("Thema: " + receivedTopic);
Serial.println("Nachricht: " + message);
if (receivedTopic == topic_relais) {
if (message == "true") {
relaisStatus = true;
digitalWrite(relaisPin, HIGH);
Serial.println("Relais eingeschaltet (true)");
} else if (message == "false") {
relaisStatus = false;
digitalWrite(relaisPin, LOW);
Serial.println("Relais ausgeschaltet (false)");
} else {
Serial.println("Ungültige Nachricht erhalten.");
}
}
}
void handleWebServer() {
WiFiClient client = webServer.available();
if (client) {
Serial.println("Webserver-Verbindung hergestellt");
String request = client.readStringUntil('\r');
client.flush();
if (request.indexOf("GET /toggle") != -1) {
// Toggle Relaisstatus
relaisStatus = !relaisStatus;
digitalWrite(relaisPin, relaisStatus ? HIGH : LOW);
Serial.println(relaisStatus ? "Relais eingeschaltet" : "Relais ausgeschaltet");
}
if (request.indexOf("GET /status") != -1) {
// Status zurückgeben
client.println("HTTP/1.1 200 OK");
client.println("Content-Type: application/json");
client.println();
client.print("{\"status\":");
client.print(relaisStatus ? "true" : "false");
client.println("}");
return;
}
// Weboberfläche anzeigen
client.println("HTTP/1.1 200 OK");
client.println("Content-Type: text/html");
client.println();
client.println("<html>");
client.println("<h1>Relaissteuerung</h1>");
client.println("<p>Name: " + device_name + "</p>");
client.println("<p>IP: " + ip_address + "</p>");
client.println("<p>Relaisstatus: <span id=\"status\">" + String(relaisStatus ? "Eingeschaltet" : "Ausgeschaltet") + "</span></p>");
client.println("<button onclick=\"toggleRelais()\">Relais <span id=\"button-label\">" + String(relaisStatus ? "Ausschalten" : "Einschalten") + "</span></button>");
client.println("");
client.println("</html>");
delay(1);
Serial.println("Webseite gesendet");
}
}