Im Blogbeitrag Sonoff Wifi Smart Switch mit NODEMCU Firmware hatte ich die vorbereitenden Arbeiten beschrieben, um den Sonoff Smart Switch mit einer eigenen Firmware auszustatten. Ziel ist, den Sonoff Smart Switch von einem MQTT Client aus zu steuern. Das kann ein beliebiges Linux-Device, wie ein Raspberry Pi o.ä. sein, oder ein MQTT Client auf dem Smartphone.
Das grundsätzliche Vorgehen zum Start eines Anwendungsprogramms (credentials.lua, init.lua, sonoff.lua) auf dem ESP8266/NodeMCU wird hier als bekannt vorausgesetzt. In meinem Buch zu NodeMCU ist das im Detail beschrieben.
Ich verwende hier MyMQTT aus dem Google Play Store auf einem Android Smartphone. Es gibt Alternativen sowohl für Android als auch für iOS.
Um sich an den Datenaustausch über das MQTT-Protokoll heranzutasten, bietet sich die Verwendung eines freien Broker-Dienstes als Spielwiese an. Der CloudMQTT-Broker der schwedischen Firma 84codes AB ist eine solche Möglichkeit. CloudMQTT sind Mosquitto Server in der Cloud.
Zum Erstellen einer CloudMQTT-Instanz ist es erforderlich, unter http://www.cloudmqtt.com/ ein Konto einzurichten und sich für einen Kunden-Plan zu entscheiden. Als Testfeld nutze ich den freien Plan Cute Cat.
Die Anmeldung eines Kundenkontos erfolgt über eine eMail-Adresse, an die ein Link zur
Freischaltung verschickt wird. Nach dem Erzeugen einer CloudMQTT-Instanz werden die Informationen zur erzeugten Instanz angezeigt. Alle in der folgenden Abbildung gezeigten Daten werden vom System zugewiesen. Das trifft auch für den Usernamen und das Password zu.
Ist die brokerseitige Einrichtung abgeschlossen, dann kann der MQTT Client MyMQTT eingerichtet werden.Die folgenden Screenshots zeigen die von MyMQTT abonierten Mitteilungen (Subscribe), das Versenden von Mitteilungen zum Schalten des Sonoff Smart Switches und die Protokollierung auf dem Dashboard.
Mein MQTT Client abonniert durch die Angaben SONOFF/+/# alle gesendeten Sonoff-Mitteilungen. Zusätzlich sind alle Mitteilungen aus einem Netzwerk von Temperatursensoren abonniert (DHT11/+/#).
Gesendet wird von diesem MQTT-Client hier nur der Topic SONOFF/ESP8266-1878840/state mit 0 (Ausschalten) oder 1 (Einschalten) als Dateninhalt.
Im Dashboard können nun die abonnierten Mitteilungen verfolgt werden.
Der eingesetzte Sonoff Smart Switch meldet sich mit einer Client-ID in seinem Topic, die automatisch durch dessen Chip-ID erzeugt wird. Die Adressierung ist damit eindeutig.
Im wesentlichen kann der durch die versendeten Mitteilungen beeinflusste Schaltzustand verfolgt werden.
Gelegentlich wird dieser Vorgang durch eine periodische gesendete Mitteilung eines Sensors für Temperatur und Luftfeuchtigkeit unterbrochen.
Das Programm sonoff.lua steuert das Verhalten von Relais und LED des Sonoff Smart Switchs und stellt die Kommunikation über das WLAN zum MQTT-Broker sicher.
Es ist hier nur zur Ansicht aufgeführt und kann bei Bedarf von den folgenden Sites heruntergeladen werden:
-- Title : Subscribe data from cloudmqtt.com for sonoff module -- Date : 2016-08-04 -- Id : sonoff.lua -- Firmware: nodemcu_float_0.9.6-dev_20150704 -- Found at: http://git.agocontrol.com/hari/esp8266-lua-snippets/blob/master/mqtt.lua -- Modified: Claus Kuehnel -- Defined in credentials.lua -- CLIENTID, BROKER, BRPORT, BRUSER, BRPWD REL=6 -- GPIO12 (MTDI) LED=7 -- GPIO13 (MTCK) gpio.mode(REL, gpio.OUTPUT) gpio.mode(LED,gpio.OUTPUT) gpio.write(REL, gpio.LOW) gpio.write(LED, gpio.HIGH) state = 0 -- init mqtt client with keepalive timer 120sec m = mqtt.Client(CLIENTID, 120, BRUSER, BRPWD) m:lwt("SONOFF/"..CLIENTID.."/lwt", " now offline", 0, 0) m:connect(BROKER, BRPORT, 0, function(conn) print("Connected to MQTT:"..BROKER..":"..BRPORT.." as "..CLIENTID) -- subscribe topic with qos = 0 m:subscribe("SONOFF/".. CLIENTID .."/state",0, function(conn) print("subscribe success") end) -- on publish message receive event m:on("message", function(conn, topic, data) if data ~= nil then print(topic..":"..data) state = data if data == "0" then gpio.write(REL, gpio.LOW) gpio.write(LED, gpio.HIGH) else gpio.write(REL, gpio.HIGH) gpio.write(LED, gpio.LOW) end end end) -- reconnecting when offline m:on("offline", function(con) print ("Reconnecting to MQTT:" .. BROKER) -- print("Heap = " .. node.heap()) tmr.alarm(1, 1000, 0, function() m:close() m = nil dofile("sonoff.lua") end) end) tmr.stop(0) tmr.alarm(0, 60000, 1, function() sendmessage() end ) -- 60 sec end) function sendmessage() m:publish("SONOFF/"..CLIENTID.."/state", state,0,0, function(conn) end) end