MQTT

Der Raspberry Pi muss wie folgt eingerichtet werden. Dazu habe ich die Schritte von Thomas Varnish befolgt. Diese gebe ich zum Teil auf deutsch wieder . Die grau hinterlegten Textpassagen habe ich von seiner Seite übernommen.

Quelle: https://www.instructables.com/id/How-to-Use-MQTT-With-the-Raspberry-Pi-and-ESP8266/, Thomas Varnish, Stand 25.07.2020

Raspberry Pi Mosquitto einrichten:

Als erstes bietet es sich immer an, das System upzudaten.

sudo apt-get update

sudo apt-get upgrade

Wenn das geschafft ist, muss das Programm "mosquitto" und die zugehörigen Client-Pakete "mosquitto-clients packages" installiert werden.

sudo apt-get install mosquitto -y

sudo apt-get install mosquitto-clients -y

Der Broker (Pi) kann noch so konfiguriert werden, dass er immer mit Authentifikation arbeitet. Das habe ich in meinem Beispiel nicht getan.

"When you've finished installing these two packages, we are going to need to configure the broker. The mosquitto broker's configuration file is located at /etc/mosquitto/mosquitto.conf, so open this with your favourite text editor. If you don't have a favourite text editor or don't know how to use any of the command line editors, I'll be using nano so you can follow along:

sudo nano /etc/mosquitto/mosquitto.conf

At the bottom of this file, you should see the line:

include_dir /etc/mosquitto/conf.d

Delete this line. Add the following lines to the bottom of the file.

allow_anonymous false

password_file /etc/mosquitto/pwfile

listener 1883

Hier zeige ich euch, wie ihr einen Wemos über Wlan mit dem Raspberry Pi verbinden könnt. Der Pi hat dabei die IP Adresse 192.168.0.21 und der Wemos 192.168.0.12 in meinem Testaufbau.

Node Red Code:

In der Arduino Software müsst ihr folgende Bibliothek verwenden: PubSubCLient von Nick O'Leary

Am Wemos ist derzeit nur ein Spannungsteiler am A0 (Analog Eingang) dran, mit dem ich die Spannung runterbreche. Die Massen von USB-Kabel (Spannungsversorgung des Wemos) und dem Ausgang des Solarladereglers sind verbunden (beides vom gleichen Gerät).

Anschlüsse:

A0 -- Mittelpunkt Spannungsteiler

Arduino Code Beispiel:

#include <ESP8266WiFi.h>#include <PubSubClient.h> const char* SSID = "SSID";const char* PSK = "Passwort";const char* MQTT_BROKER = "IP des IO Brokers/Raspberry Pi";bool D1_ = false;bool D2_ = false;bool D3_ = false;bool D1_Alt = true;bool D2_Alt = true;bool D3_Alt = true;WiFiClient espClient;PubSubClient client(espClient); void setup() { pinMode(D1,INPUT_PULLUP); pinMode(D2,INPUT_PULLUP); pinMode(D3,INPUT_PULLUP); pinMode(LED_BUILTIN, OUTPUT); Serial.begin(115200); setup_wifi(); client.setServer(MQTT_BROKER, 1883); client.setCallback(callback); } void setup_wifi() { WiFi.begin(SSID, PSK); while (WiFi.status() != WL_CONNECTED) { delay(100); } Serial.println(WiFi.localIP());}void loop() { if (!client.connected()) { while (!client.connected()) { client.connect("ESP8266Client"); client.subscribe("W1/A1"); client.subscribe("W1/A2"); client.subscribe("W1/ADC"); client.subscribe("W1/Status"); delay(100); } } client.loop(); Tasterabfrage();}void callback(char* topic, byte* payload, unsigned int length) { String msg; for (byte i = 0; i < length; i++) { char tmp = char(payload[i]); msg += tmp; } //Serial.println(msg); // Serial.println(topic); if (strcmp(topic,"W1/A1")==0) { if(msg== "An") { digitalWrite(LED_BUILTIN,LOW); client.publish("W1/A1_", "An"); } else if(msg== "Aus") { digitalWrite(LED_BUILTIN,HIGH); client.publish("W1/A1_", "Aus"); } }
if (strcmp(topic,"W1/ADC")==0) { float num = analogRead(A0)/38.8; char cstr[10]; if(num > 26.01 || num < 0.8) num = 0.00; dtostrf(num, 1, 2,cstr); client.publish("W1/ADC0", cstr); } if (strcmp(topic,"W1/Status")==0) { char cstr[10]; long rssi = WiFi.RSSI(); itoa(rssi, cstr, 10); client.publish("W1/Empfang1", cstr); float num = analogRead(A0)/38.8; if(num > 26.01 || num < 0.8) num = 0.00; dtostrf(num, 1, 2,cstr); client.publish("W1/ADC0", cstr);
if(digitalRead(D4)) { client.publish("W1/A1_", "Aus"); } else { client.publish("W1/A1_", "An"); } } }
void Tasterabfrage(){ D1_ = digitalRead(D1); D2_ = digitalRead(D2); D3_ = digitalRead(D3); delay(50);
if(D1_ != D1_Alt) { if(D1_) { client.publish("W1/Q1", "An"); } else { client.publish("W1/Q1", "Aus"); } D1_Alt = D1_; } if(D2_ != D2_Alt) { if(D2_) { client.publish("W1/Q2", "An"); } else { client.publish("W1/Q2", "Aus"); } D2_Alt = D2_; } if(D3_ != D3_Alt) { if(D3_) { client.publish("W1/Q3", "An"); } else { client.publish("W1/Q3", "Aus"); } D3_Alt = D3_; }}

Google Sites

Report abuse