{"id":15230,"date":"2020-08-30T09:02:05","date_gmt":"2020-08-30T07:02:05","guid":{"rendered":"http:\/\/blog.wenzlaff.de\/?p=15230"},"modified":"2021-11-22T17:14:07","modified_gmt":"2021-11-22T16:14:07","slug":"weil-heute-sonntag-ist-java-co2-mqtt-client","status":"publish","type":"post","link":"http:\/\/blog.wenzlaff.de\/?p=15230","title":{"rendered":"Weil heute Sonntag ist: Java CO2 MQTT Client"},"content":{"rendered":"

Weil heute Sonntag ist. „Freut euch immer<\/strong>„! Nun ein kleiner Java CO2 MQTT Client um auch auf allen Betriebssystemen mit Java die CO2 Daten zu empfangen. Nicht nur f\u00fcr den Raspberry Pi auch Mac und Windows (ungetestet;-)).<\/p>\n

Das selbstausf\u00fchrende JAR laden (siehe unten) und starten mit:<\/p>\n

java -jar TWCo2Monitor-0.0.1-SNAPSHOT-jar-with-dependencies.jar [PI-Rechner Name\/Adresse]<\/strong><\/p>\n

Hier mal eine Ausgabe auf einem Raspberry Pi W Zero:<\/p>\n

\"\"<\/a><\/p>\n

Der MQTT Client besteht nur aus ein paar Zeilen Java Code:<\/p>\n

\t\t\r\n\r\n                MqttClient client = new MqttClient(\"tcp:\/\/\" + server, generateClientId());\r\n\r\n\t\tSystem.out.println(\"Starte den CO2 MQTT-Client mit Server \" + server + \" und ID: \" + client.getClientId() + \" ...\");\r\n\r\n\t\tclient.setCallback(new MqttCallback() {\r\n\r\n\t\t\t@Override\r\n\t\t\tpublic void connectionLost(Throwable throwable) {\r\n\t\t\t}\r\n\r\n\t\t\t@Override\r\n\t\t\tpublic void messageArrived(String topic, MqttMessage nachricht) throws Exception {\r\n\r\n\t\t\t\tleseCo2(nachricht);\r\n\t\t\t}\r\n\r\n\t\t\tprivate void leseCo2(MqttMessage nachricht) {\r\n\r\n\t\t\t\tJSONObject jsonNachricht = new JSONObject(nachricht.toString());\r\n\r\n\t\t\t\ttry {\r\n\t\t\t\t\tJSONArray nachrichten = jsonNachricht.getJSONObject(\"messung\").getJSONArray(\"satz\");\r\n\t\t\t\t\tJSONObject satz = (JSONObject) nachrichten.get(1);\r\n\t\t\t\t\tint co2 = satz.getInt(\"co2\");\r\n\r\n\t\t\t\t\tSystem.out.println(\"CO2: \" + co2 + \" ppm\");\r\n\r\n\t\t\t\t\tCO2Bewertung.bewertungUBAausgeben(co2);\r\n\t\t\t\t\tCO2Bewertung.bewertungDINEN1377Ausgeben(co2);\r\n\r\n\t\t\t\t} catch (JSONException e) {\r\n\t\t\t\t\tSystem.err.println(e);\r\n\t\t\t\t}\r\n\t\t\t}\r\n\r\n\t\t\t@Override\r\n\t\t\tpublic void deliveryComplete(IMqttDeliveryToken t) {\r\n\t\t\t}\r\n\t\t});\r\n\r\n\t\tclient.connect();\r\n\r\n\t\tclient.subscribe(TOPIC);\r\n<\/pre>\n
Kurz, es muss nur eine Instanz vom MqttClient mit der Serverurl angelegt werden. Dann die Callback-Methode setCallback setzen. Dann braucht nur noch ein Connect und ein Subscribe des Topics (co2) erfolgen. Das ist schon alles. Es wird jetzt in einen Hintergrund Thread jeweis beim eintreffen einer MqttMessage der JSon String gelesen und ausgewertet.<\/p>\n
Als Abh\u00e4ngigkeiten brauch man nur den Paho-Client<\/a> und eine JSon-Lib:<\/p>\n
<dependencies>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.eclipse.paho<\/groupId>\r\n\t\t\t<artifactId>org.eclipse.paho.client.mqttv3<\/artifactId>\r\n\t\t\t<version>1.2.5<\/version>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.json<\/groupId>\r\n\t\t\t<artifactId>json<\/artifactId>\r\n\t\t\t<version>20200518<\/version>\r\n\t\t<\/dependency>\r\n\t<\/dependencies><\/pre>\n
Dann habe ich noch eine kleine Klasse f\u00fcr die DIN Norm und die Einsch\u00e4tzung der Werte gem. UBA geschrieben. Die bewertungUBAausgeben<\/em> Methode liefert auch noch die L\u00fcftungsampel<\/strong> zur\u00fcck.<\/p>\n
\/**\r\n\t * DIN EN 13779 ldt. Absolute CO2-Konzentration in der Innenraumluft (ppm).\r\n\t * \r\n\t * Quelle:\r\n\t * https:\/\/www.hamburg.de\/contentblob\/1016516\/7073fd694816ce7e8edd0eb82a2593e6\/data\/gesundheitliche-bewertung-co2.pdf\r\n\t * \r\n\t * @param co2\r\n\t *\/\r\n\tpublic static void bewertungDINEN1377Ausgeben(int co2) {\r\n\t\tif (co2 < 800) {\r\n\t\t\tSystem.out.println(\"Laut DIN EN 13779: Raumluft Kategorie: IDA 1 - Hohe Raumluftqualit\u00e4t\");\r\n\t\t} else if (co2 > 800 && co2 < 1000) {\r\n\t\t\tSystem.out.println(\"Laut DIN EN 13779: Raumluft Kategorie: IDA 2 - Mittlere Raumluftqualit\u00e4t\");\r\n\t\t} else if (co2 > 1000 && co2 < 1400) {\r\n\t\t\tSystem.out.println(\"Laut DIN EN 13779: Raumluft Kategorie: IDA 3 - M\u00e4\u00dfige Raumluftqualit\u00e4t\");\r\n\t\t} else {\r\n\t\t\tSystem.out.println(\"Laut DIN EN 13779: Raumluft Kategorie: IDA 4 - Niedrige Raumluftqualit\u00e4t\");\r\n\t\t}\r\n\t}\r\n\r\n\t\/**\r\n\t * Quelle:\r\n\t * https:\/\/www.hamburg.de\/contentblob\/1016516\/7073fd694816ce7e8edd0eb82a2593e6\/data\/gesundheitliche-bewertung-co2.pdf\r\n\t * \r\n\t * https:\/\/www.dguv.de\/medien\/ifa\/de\/pub\/rep\/pdf\/reports2013\/innenraumarbeitsplaetze\/kapitel_12_4_1.pdf\r\n\t * \r\n\t * @param co2\r\n\t *\/\r\n\tpublic static L\u00dcFTUNGSAMPEL bewertungUBAausgeben(int co2) {\r\n\t\tif (co2 < 1000) {\r\n\t\t\tSystem.out.println(\"Laut UBA GR\u00dcN: Hygienisch unbedenklich, keine weiteren Ma\u00dfnahmen\");\r\n\t\t\treturn L\u00dcFTUNGSAMPEL.GR\u00dcN;\r\n\t\t} else if (co2 > 1000 && co2 < 2000) {\r\n\t\t\tSystem.out.println(\"Laut UBA GELB: Hygienisch auff\u00e4llig, L\u00fcftungsma\u00dfnahmen erh\u00f6hen, L\u00fcftungsverhalten \u00fcberpr\u00fcfen und verbessern\");\r\n\t\t\treturn L\u00dcFTUNGSAMPEL.GELB;\r\n\t\t} else {\r\n\t\t\tSystem.out.println(\"Laut UBA ROT: Hygienisch inakzeptabel, Bel\u00fcftbarkeit des Raumes pr\u00fcfen ggf. weitergehende Ma\u00dfnahmen pr\u00fcfen\");\r\n\t\t\treturn L\u00dcFTUNGSAMPEL.ROT;\r\n\t\t}\r\n\t}\r\n<\/pre>\n
Das ganze Projekt kann von GitBucket geclont werden mit:
\n
\ngit clone https:\/\/itberater@bitbucket.org\/itberater\/mqttco2client.git<\/strong><\/p>\n
Oder man l\u00e4dt sich das Jar mit<\/p>\n
wget https:\/\/bitbucket.org\/itberater\/mqttco2client\/downloads\/TWCo2Monitor-0.0.1-SNAPSHOT-jar-with-dependencies.jar<\/strong><\/p>\n
auf den Rechner. Oder direkt aus der Web-Gui des Projekts<\/a>.<\/p>\n
Und hier die aktuellen Werte von Sonntag:<\/p>\n
\"\"<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
Weil heute Sonntag ist. „Freut euch immer„! Nun ein kleiner Java CO2 MQTT Client um auch auf allen Betriebssystemen mit Java die CO2 Daten zu empfangen. Nicht nur f\u00fcr den Raspberry Pi auch Mac und Windows (ungetestet;-)). Das selbstausf\u00fchrende JAR laden (siehe unten) und starten mit: java -jar TWCo2Monitor-0.0.1-SNAPSHOT-jar-with-dependencies.jar [PI-Rechner Name\/Adresse] Hier mal eine Ausgabe … <\/p>\n
\u201eWeil heute Sonntag ist: Java CO2 MQTT Client\u201c <\/span>weiterlesen<\/a><\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[220,4084,852,3897,5,3163,79,1023,2752],"tags":[527,4049,4041,2178,4061,2359,2548,2828,4048],"class_list":["post-15230","post","type-post","status-publish","format-standard","hentry","category-anleitung","category-co2","category-heimautomatisierung","category-java-programmierung","category-java","category-maven","category-programmierung","category-raspberry-pi","category-raspberry-pi-zero-w","tag-co2","tag-co2-werte","tag-co2-sensor","tag-java","tag-mh-z19b","tag-mqtt","tag-mqtt-client","tag-umwelt","tag-umweltbundesamt"],"_links":{"self":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/posts\/15230","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=15230"}],"version-history":[{"count":0,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/posts\/15230\/revisions"}],"wp:attachment":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=15230"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=15230"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=15230"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}