Download as PDF, PPTX
Uploaded byChristian Götz
MQTT with Java - a protocol for IoT and M2M communication
The document discusses MQTT, a lightweight messaging protocol ideal for IoT and M2M communications, focusing on its advantages over HTTP in terms of efficiency for constrained devices and unreliable networks. It covers the architecture of MQTT, its features such as quality of service, last will and testament, and persistent sessions, along with various client implementations in Java and other languages. The document also highlights use cases and provides a demo of MQTT in action.
MQTT with Java - a protocol for IoT and M2M communication
- 1. MQTT with Java -a protocol for IoT and M2M communication ! Christian Götz, dc-square
- 2.
- 3. M2M IoT IoE WoT Web of Things Internetof Things Internet of Everything Machine to Machine communication Ubicomp Ubiquitous computing CPS Cyper Physical Systems Pervasive Computing
- 4. Technology that connects Devices overwired or wireless communication
- 5.
- 6. Hi, I’m ChristianGötz author & speaker building solutions CEO & co-founder developer @goetzchr
- 7. IoT is happeningnow WHY?
- 8. 6,5 per person DEVICESoutnumber people 0,0 15,0 30,0 45,0 60,0 2003 2010 2015 2020 50,0 25,0 12,5 0,5 6,0 19,5 33,0 46,5 60,0 2003 2010 2015 2020 7,67,36,86,3 250 new every sec http://blogs.cisco.com/news/cisco-connections-counter/ http://www.cisco.com/web/about/ac79/docs/innov/IoT_IBSG_0411FINAL.pdf 2020 in billions people devices
- 9. Open Hardware iseverywhere Raspberry Pi is a trademark of the Raspberry Pi Foundation
- 10. Screenshot from JavaOne2013 Java back to the roots
- 11. Screenshot from JavaOne2013 Java back to the roots
- 12. HTTP is notsuitable WHY?
- 13. Request/Response Point-2-Point widelyknown HTTP is too verbose
- 14.
- 15. Constrained devices Bi-directional Scalability Unreliable Networks PushMessaging Security … there are more ;) IoT HTTP IoT challenges
- 16. MQTT is agood fit WHY?
- 20.
- 21.
- 22. Temperaturfühler MQTT-Broker Laptop Mobiles Endgerät publish:“21°C“ publish: “21°C“ publish: “21°C“ subscribe subscribe
- 23.
- 24.
- 25.
- 26.
- 27.
- 28. On top ofTCP Simple Publish/Subscribe Architecture BinaryMinimal Overhead Designed for unreliable networks Data agnostic MQTT facts
- 29. - Establishing 1stConnection (compensated after 5,5 min) + Reconnect + Maintaining Connection + Receiving Messages + Sending Messages less battery better throughput MQTT (with SSL) vs HTTPS + Less Overhead + Persistent Sessions + Pub/Sub Architecture Source: http://stephendnicholas.com/archives/1217
- 30. 1999 2010 20132014 Arlen Nipper & Andy Stanford-Clark invent MQTT royalty free OASIS TC formed MQTT becomes Standard MQTT history
- 31. Push instead ofPoll Minimal Bandwidth is important Mobile meets Enterprise Unreliable networks Constrained devices Low Latency MQTT use cases
- 32. MQTT real worldusage https://www.facebook.com/notes/facebook- engineering/building-facebook-messenger/ 10150259350998920
- 33. Quality of Service RetainedMessages Last Will and Testament Persistent Sessions Heartbeats Topic Wildcards MQTT features
- 34. MQTT features Qualityof Services QoS 1 QoS 2 QoS 0 B B B
- 35. MQTT features LastWill and Testament B Connect LWT device123/status: „offline“ B dropped device123/status: „offline“
- 36. MQTT features w/oRetained Messages B device1/temp: „23,0“ device1 every 5 min device2 device1/temp: „23,0“ Delay <= 5min
- 37. MQTT features RetainedMessages B device1/temp: „23,0“ R device1 every 5 min device2 device1/temp: „23,0“ R No Delay!
- 38. MQTT features PersistentSessions B Connect Subscribe device/+/status device/12/status: „1“ 1st B Re-Connect device/12/status: „1“ 2nd
- 39. MQTT-SN Overview Gateway MQTT-Broker MQTT-SNMQTT / -SN • UDP instead of TCP • Topic is just an ID (Preregister/Register) • Sleeping Clients • Different types of Gateways • Discovery Mechanisms Devices B
- 40.
- 41. MQTT Security Protocol Username/Password Transport TLS, clientcertificate authentification Broker fine-grained authentication, 3rd party integration
- 42.
- 43. MQTT Broker Mosquitto OpenSource Ideal for constraint devices Supports Bridging Written in C
- 44. MQTT Broker HiveMQ Highperformance broker Open Plugin System for Java Clustering Bridging Scalable to > 100.000 connections Native Websocket support
- 45.
- 46. MQTT Broker PublicBroker www.mqttdashboard.com
- 47.
- 48.
- 49. Open Source “Reference Implementation” Manylanguages: Java, Javascript, Lua, C, C++, Go, Python Active Community JS Library uses MQTT over Websockets Paho facts
- 50. MqttClient client =new MqttClient( "tcp://localhost:1883", //URI "publisher", //Client ID new MemoryPersistence()); //Persistence Paho Init Connection
- 51. MqttClient client =new MqttClient(...); ! MqttConnectOptions connOptions = new MqttConnectOptions(); ! connOptions.setKeepAliveInterval(120); connOptions.setWill("my/status", "offline".getBytes(), 2, true); connOptions.setCleanSession(false); connOptions.setUserName("user"); connOptions.setPassword(„pass".toCharArray( )); ! client.connect(connOptions); Paho Init Connection
- 52. ! ! client.publish("my/topic/123",//topic "Hello!".getBytes(), //message 1, //QoS false);//retained ! ! client.disconnect(); Paho Synchronous API
- 53. final MqttClient client= new MqttClient(...); client.setCallback(new MqttCallback() { @Override public void connectionLost(Throwable cause) {} ! @Override public void messageArrived(String topic, MqttMessage message)throws Exception { System.out.println(new String(message.getPayload())); } ! @Override public void deliveryComplete(IMqttDeliveryToken token) {} }); ! client.connect(); client.subscribe("#"); Paho Synchronous API
- 54. MqttAsyncClient client =new MqttAsyncClient(...); client.connect(null, new IMqttActionListener() { @Override public void onSuccess(IMqttToken asyncActionToken) { try { client.publish(...); } catch (MqttException e) {} } @Override public void onFailure(IMqttToken asyncActionToken, Throwable exception) {} }); ! client.disconnect(); Paho Asynchronous API
- 55.
- 56. Open Source 3 APIStyles Automatic Reconnect Maven Central Less active Community FuseSource facts
- 57. MQTT mqtt =new MQTT(); mqtt.setHost("localhost", 1883); mqtt.setClientId("publisher"); mqtt.setCleanSession(true); mqtt.setWillTopic("publisher/status"); mqtt.setWillMessage("offline"); mqtt.setKeepAlive((short) 60); mqtt.setUserName("mqtt-client"); mqtt.setPassword("mqtt"); FuseSource Init Connection
- 58. BlockingConnection connection = mqtt.blockingConnection(); ! connection.connect(); ! connection.publish( "publisher/status",// topic "online".getBytes(StandardCharsets.UTF_8), QoS.AT_MOST_ONCE, false); FuseSource Blocking API
- 59. FutureConnection connection = mqtt.futureConnection(); ! Future<Void>f1 = connection.connect(); f1.await(); ! Future<Void> f2 = connection.publish( "publisher/status", "online".getBytes(), QoS.AT_LEAST_ONCE, true); ! f2.await(); ! Future<Void> f3 = connection.disconnect(); f3.await(); FuseSource Future API
- 60. CallbackConnection connection =mqtt.callbackConnection(); connection.connect(new Callback<Void>() { public void onSuccess(Void v) { connection.publish( "publisher/status", "online".getBytes(), QoS.AT_LEAST_ONCE, false, new Callback<Void>() { public void onSuccess(Void v) {} public void onFailure(Throwable value){} }); } ! public void onFailure(Throwable value) {} }); FuseSource Callback API
- 61.
- 62. Demo from deviceto the web with MQTT https://github.com/dc-square/mqtt-with-paho-eclipsecon2013 available on
- 63. Demo Under thehood
- 64.