Witam.
Używam środowiska InteliJ oraz zaciągnąłem bibliotekę do MQTT stąd:
https://github.com/fusesource/mqtt-client/blob/master/readme.md
Na początku testowy program który po uruchomieniu się powinien połączyć się z serwerem i umieścić na nim dane. Sam serwer jest skonfigurowany tak:
Mój kod:
Po 5 sekundach od uruchomienia środowisko zwraca mi to:
Exception in thread "MQTT Task" java.lang.IllegalArgumentException: port out of range:-1
at java.base/java.net.InetSocketAddress.checkPort(InetSocketAddress.java:143)
at java.base/java.net.InetSocketAddress.<init>(InetSocketAddress.java:224)
at org.fusesource.hawtdispatch.transport.TcpTransport$2.run(TcpTransport.java:458)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
i nic się nie wysyła do serwera. Prosze o podpowiedź.
Dodano po 1 [godziny] 36 [minuty]:
Problem rozwiązany:
Użyłem:
mqtt.setClientId("nazwa");
a powinienem:
mqtt.setUserName("nazwa");
Poprawnie kod powinien wyglądać tak:
Używam środowiska InteliJ oraz zaciągnąłem bibliotekę do MQTT stąd:
https://github.com/fusesource/mqtt-client/blob/master/readme.md
Na początku testowy program który po uruchomieniu się powinien połączyć się z serwerem i umieścić na nim dane. Sam serwer jest skonfigurowany tak:
Mój kod:
Kod: Java
Po 5 sekundach od uruchomienia środowisko zwraca mi to:
Exception in thread "MQTT Task" java.lang.IllegalArgumentException: port out of range:-1
at java.base/java.net.InetSocketAddress.checkPort(InetSocketAddress.java:143)
at java.base/java.net.InetSocketAddress.<init>(InetSocketAddress.java:224)
at org.fusesource.hawtdispatch.transport.TcpTransport$2.run(TcpTransport.java:458)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
i nic się nie wysyła do serwera. Prosze o podpowiedź.
Dodano po 1 [godziny] 36 [minuty]:
Problem rozwiązany:
Użyłem:
mqtt.setClientId("nazwa");
a powinienem:
mqtt.setUserName("nazwa");
Poprawnie kod powinien wyglądać tak:
Kod: Java