Java lernen durch Ausprobieren!

Diese Seite ist nicht editierbar. Sie können den Quelltext sehen, jedoch nicht verändern. Kontaktieren Sie den Administrator, wenn Sie glauben, dass hier ein Fehler vorliegt.
====== MQTT ======
<WRAP center round info 60%>
Das [[https://mqtt.org/|MQTT-Protokoll]] ermöglicht die Kommunikation mit MQTT-Servern, beispielsweise zur Steuerung von Komponenten im Smart Home. Die Klasse MqttClient der Online-IDE ermöglicht es, 
  * Kontakt mit einem MQTT-Server aufzubauen,
  * Topics beim Server zu abbonnieren und auf entsprechende Messages zu reagieren und
  * Nachrichten zu einem Topic an den Server zu senden.
</WRAP>

===== Demo 1: Implementieren des MqttHandler-Interfaces =====
<HTML>

<div class="java-online" style="height: 400px; width: 100%" data-java-online="{'withBottomPanel': false, 'id': 'mqtt1', 'enableFileAccess': true}">

<script type="text/plain" title="Test1.java">
import mqtt.*;

MqttClient client = new MqttClient("wss://broker.hivemq.com:8884/mqtt");
println("Verbindung aufgebaut!");

client.subscribe("chatgpt/demo/#",new MyMqttHandler());
   
client.publish("chatgpt/demo/test", "Hello MQTT!");

while (true); 

class MyMqttHandler implements MqttHandler {   
   public void onMessage(String topic, String message){
      println(message);
   }
}
</script>

</div>

</HTML>


===== Demo 2: Nutzen der Lambda-Syntax von Java =====
<HTML>

<div class="java-online" style="height: 300px; width: 100%" data-java-online="{'withBottomPanel': false, 'id': 'mqtt2', 'enableFileAccess': true}">

<script type="text/plain" title="Test1.java">
import mqtt.*;

MqttClient client = new MqttClient("wss://broker.hivemq.com:8884/mqtt");
println("Verbindung aufgebaut!");

client.subscribe("chatgpt/demo/#",(topic, message) -> {
      println(message);
   });
   
client.publish("chatgpt/demo/test", "Hello MQTT!");

while (true); 
</script>

</div>

</HTML>


===== Demo 3: Erben von MqttCLient und Überschreiben der onMessage-Methode =====
<HTML>

<div class="java-online" style="height: 400px; width: 100%" data-java-online="{'withBottomPanel': false, 'id': 'mqtt3', 'enableFileAccess': true}">

<script type="text/plain" title="Test1.java">
import mqtt.*;

MqttClient client = new MyMqttClient("wss://broker.hivemq.com:8884/mqtt");
println("Verbindung aufgebaut!");

client.subscribe("chatgpt/demo/#");
   
client.publish("chatgpt/demo/test", "Hello MQTT!");

while (true);

class MyMqttClient extends MqttClient {
   void onMessage(String topic, String message) {
      println(message);
   }
}</script>

</div>

</HTML>