Ich benutze Paho um mqtt Nachrichten zu senden und zu empfangen. Bis jetzt war es kein Problem, die Nachrichten zu senden, ich empfange sie mit Moskito.
Nun möchte ich die Nachrichten mit einem Java-Client lesen, und mir ist aufgefallen, dass es weniger Dokumentation über den Empfang der Nachrichten gibt.
Ich habe die MqttCallback-Schnittstelle implementiert, aber ich konnte immer noch nicht herausfinden, wie ich eine Nachricht eines Themas lesen kann, das ich abonniert habe.
Dies ist bisher mein Quellcode, ich kann die Nachrichten mit mosquitto_sub lesen.
%Vor%Sie schließen den Client, bevor der Broker Zeit hat, die Nachricht zurückzusenden.
Sie brauchen auch nicht 2 Instanzen des Clients, Sie können nur mit einem senden und empfangen.
Ich habe Ihren Code ein wenig bearbeitet, er wird jetzt weiterlaufen und Nachrichten empfangen, bis Sie ihn beenden.
%Vor% BEARBEITEN: hinzugefügt das fehlende client.setCallback(this)