{"id":7194,"date":"2016-07-07T21:00:41","date_gmt":"2016-07-07T19:00:41","guid":{"rendered":"http:\/\/blog.wenzlaff.de\/?p=7194"},"modified":"2023-08-20T14:55:13","modified_gmt":"2023-08-20T12:55:13","slug":"paho-mqtt","status":"publish","type":"post","link":"http:\/\/blog.wenzlaff.de\/?p=7194","title":{"rendered":"Besser als Fussball: MQTT Java Client mit Paho"},"content":{"rendered":"

Fussball<\/a>? Wie kann man per Java einen MQTT Client mit Paho<\/a> schreiben, der z.B. die Anzahl Flugzeuge in Hannover anzeigt? Und das innerhalb der ersten Halbzeit<\/a>, da nur 2 Klassen ben\u00f6tigt werden.<\/p>\n

Mein Raspberry Pi sendet an den \u00f6ffentlichen Testserver test.mosquitto.org<\/strong> unter den Topic \/Anzahl\/Flugzeuge\/Hannover<\/strong> alle 5 Minuten die aktuelle Anzahl, so das dieses Beispiel jeder nachvollziehen kann.<\/p>\n

Hier die Architektur: <\/p>\n

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

Wir brauchen zuerst ein Eclipse Maven Projekt mit Java 1.8 mit dieser pom.xml<\/strong> und einen Eintrag des Paho Repo, da es in Maven Central nicht vorhanden ist:<\/p>\n

\r\n<project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n\txsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\">\r\n\t<modelVersion>4.0.0<\/modelVersion>\r\n\t<groupId>de.wenzlaff.mqtt.client<\/groupId>\r\n\t<artifactId>de.wenzlaff.mqtt.client<\/artifactId>\r\n\t<version>0.0.1-SNAPSHOT<\/version>\r\n\r\n\t<repositories>\r\n\t\t<repository>\r\n\t\t\t<id>Eclipse Paho Repo<\/id>\r\n\t\t\t<url>https:\/\/repo.eclipse.org\/content\/repositories\/paho-releases\/<\/url>\r\n\t\t<\/repository>\r\n\t<\/repositories>\r\n\r\n\t<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.0.2<\/version>\r\n\t\t<\/dependency>\r\n\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.slf4j<\/groupId>\r\n\t\t\t<artifactId>slf4j-api<\/artifactId>\r\n\t\t\t<version>1.7.13<\/version>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.slf4j<\/groupId>\r\n\t\t\t<artifactId>slf4j-log4j12<\/artifactId>\r\n\t\t\t<version>1.7.13<\/version>\r\n\t\t<\/dependency>\r\n\t<\/dependencies>\r\n\r\n<\/project><\/pre>\n
Dann eine FlugClient.java<\/strong> Klasse:<\/p>\n
\r\npackage de.wenzlaff.mqtt.client;\r\n\r\nimport java.util.UUID;\r\n\r\nimport org.eclipse.paho.client.mqttv3.MqttClient;\r\nimport org.eclipse.paho.client.mqttv3.MqttException;\r\nimport org.slf4j.Logger;\r\nimport org.slf4j.LoggerFactory;\r\n\r\n\/**\r\n * MQTT Flug Client.\r\n * \r\n * @author Thomas Wenzlaff\r\n *\r\n *\/\r\npublic class FlugClient {\r\n\r\n\tprivate static final Logger LOG = LoggerFactory.getLogger(FlugClient.class);\r\n\r\n\t\/** Die URI des Servers der abgefragt wird. *\/\r\n\tprivate static final String SERVER_URI = \"tcp:\/\/test.mosquitto.org\";\r\n\r\n\t\/** Der Topic auf den die Flugdaten ankommen. *\/\r\n\tprivate static final String FLUG_TOPIC = \"\/Anzahl\/Flugzeuge\/Hannover\";\r\n\r\n\tpublic static void main(String[] args) throws Exception {\r\n\r\n\t\tstartClientEndlos();\r\n\t}\r\n\r\n\tprivate static void startClientEndlos() throws MqttException {\r\n\r\n\t\tLOG.info(\"Starte MQTT Flug Client ...\");\t\t\r\n\r\n\t\tMqttClient client = new MqttClient(SERVER_URI, generateClientId());\r\n\r\n\t\tclient.setCallback(new LogCallback());\r\n\r\n\t\tclient.connect();\r\n\r\n\t\tclient.subscribe(FLUG_TOPIC);\r\n\t}\r\n\r\n\tprivate static String generateClientId() {\r\n\t\treturn UUID.randomUUID().toString();\r\n\t}\r\n}\r\n<\/pre>\n
Dann noch eine MQTT Callback Klasse mit Namen LogCallback.java<\/strong>. Hier ein einfaches Beispiel das nur per Log4j auf der Konsole loggt:<\/p>\n
\r\npackage de.wenzlaff.mqtt.client;\r\n\r\nimport org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;\r\nimport org.eclipse.paho.client.mqttv3.MqttCallback;\r\nimport org.eclipse.paho.client.mqttv3.MqttMessage;\r\nimport org.slf4j.Logger;\r\nimport org.slf4j.LoggerFactory;\r\n\r\n\/**\r\n * Callback Klasse die nur die Nachrichten loggt.\r\n * \r\n * @author Thomas Wenzlaff\r\n *\r\n *\/\r\nclass LogCallback implements MqttCallback {\r\n\r\n\tprivate static final Logger LOG = LoggerFactory.getLogger(LogCallback.class);\r\n\r\n\tpublic void connectionLost(Throwable throwable) {\r\n\t}\r\n\r\n\tpublic void messageArrived(String t, MqttMessage m) throws Exception {\r\n\t\tString nachricht = m.toString().replaceAll(\"#\", \"\");\r\n\r\n\t\tLOG.info(\"{}\", nachricht);\r\n\t}\r\n\r\n\tpublic void deliveryComplete(IMqttDeliveryToken t) {\r\n\t}\r\n\r\n}<\/pre>\n
Es kann aber auch leicht erweitert werden, einfach das Interface MqttCallback in einer Callback Klasse implementieren. Die ankommenden Meldungen werden in der messageArrived<\/strong> Methode behandelt.<\/p>\n
Wenn wir nun die FlugClient<\/strong> Klasse starten, wird auf der Konsole alle 5 Minuten die Anzahl Flugzeuge in Hannover in einem eigenen Thread ausgegeben:<\/p>\n
\r\nINFO  FlugClient - Starte MQTT Flug Client ...\r\nINFO  LogCallback - 12 Flugzeuge im Umkreis Flughafen Hannover sichtbar via ADSB am Thu Jul 07 2016 19:57:13 GMT+0200 (CEST) mit Raspberry Pi\r\nINFO  LogCallback - 13 Flugzeuge im Umkreis Flughafen Hannover sichtbar via ADSB am Thu Jul 07 2016 20:02:13 GMT+0200 (CEST) mit Raspberry Pi\r\nINFO  LogCallback - 15 Flugzeuge im Umkreis Flughafen Hannover sichtbar via ADSB am Thu Jul 07 2016 20:07:13 GMT+0200 (CEST) mit Raspberry Pi\r\nINFO  LogCallback - 14 Flugzeuge im Umkreis Flughafen Hannover sichtbar via ADSB am Thu Jul 07 2016 20:12:13 GMT+0200 (CEST) mit Raspberry Pi\r\n...\r\n<\/pre>\n
Da ich beim Senden der Anzahl die retained messages<\/strong> (aufbewahrte Nachrichten) auf true gesetzt habe, kommt gleich beim Start des Client die letzte Meldung.
\nD.h. das sind Nachrichten mit gesetztem Retain-Flag. Meldet sich ein neuer Teilnehmer am Topic an, erh\u00e4lt er als Erstes die letzte Nachricht, die mit diesem Flag im Topic eingetroffen ist. Das gilt auch bei Abonnements mit Wildcards, die das betreffende Topic enthalten.<\/p>\n
Die Flugdaten werden \u00fcbrigens von einem eigenen Raspberry Pi mit node-RED von IBM an den Testserver, Twitter, Debug-Konsole und ThinkSpeak gesendet, hier der Flow:<\/p>\n
\"node-red-flow\"<\/a><\/p>\n
Wer das mal ausprobiert hat, kann gerne einen Like<\/strong> oder Kommentar hinterlassen. <\/p>\n
Oder doch besser Fu\u00dfball<\/a>?<\/p>\n","protected":false},"excerpt":{"rendered":"
Fussball? Wie kann man per Java einen MQTT Client mit Paho schreiben, der z.B. die Anzahl Flugzeuge in Hannover anzeigt? Und das innerhalb der ersten Halbzeit, da nur 2 Klassen ben\u00f6tigt werden. Mein Raspberry Pi sendet an den \u00f6ffentlichen Testserver test.mosquitto.org unter den Topic \/Anzahl\/Flugzeuge\/Hannover alle 5 Minuten die aktuelle Anzahl, so das dieses Beispiel … <\/p>\n
\u201eBesser als Fussball:  MQTT Java Client mit Paho\u201c <\/span>weiterlesen<\/a><\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_import_markdown_pro_load_document_selector":0,"_import_markdown_pro_submit_text_textarea":"","footnotes":""},"categories":[220,5,2520,1023],"tags":[1298,2549,116,584,2550,2178,1370,56,2359,2548,2473,2547],"class_list":["post-7194","post","type-post","status-publish","format-standard","hentry","category-anleitung","category-java","category-node-red","category-raspberry-pi","tag-anzahl","tag-broker","tag-client","tag-flug","tag-fussball","tag-java","tag-java-1-8","tag-java-client","tag-mqtt","tag-mqtt-client","tag-node-red","tag-paho"],"_links":{"self":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/posts\/7194","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=7194"}],"version-history":[{"count":0,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=\/wp\/v2\/posts\/7194\/revisions"}],"wp:attachment":[{"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=7194"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=7194"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/blog.wenzlaff.de\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=7194"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}