Using The JavaScript MQTT Client With Websockets

Hello Steve, I also got that error message on my website. I ran my website a year ago but this year is not good at all. When I try to check the MQTT response, I got that message. Please inform me if there is something I can do for solving this issue. Thanks.

I am using the MQTT client for sending and receiving. The below code is used in my system and your javascript MQTT client WebSockets using on my laptop for receiving the message and show on GUI.

package org.eclipse.paho.sample.mqttv3app;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import io.moquette.interception.AbstractInterceptHandler;
import io.moquette.interception.messages.InterceptPublishMessage;

public class MqttPublishSample {

class PublisherListener extends AbstractInterceptHandler{
@Override
public void onPublish(InterceptPublishMessage message){
System.out.println(“message ” + message.getPayload().array());
}
}

public static void main(String[] args) throws InterruptedException {

// Creating a MQTT Client using Eclipse Paho
String topic = “news”;
String content = “I am client from laptop”;
int qos = 1;
String broker = “tcp://0.0.0:1883”;
String clientId = “ClientId”+broker;

MemoryPersistence persistence = new MemoryPersistence();//Gets the specified data out of the persistent store.

try {

/*****************************************PAHO CLIENT START*************************/
@SuppressWarnings(“resource”)
//Create an MqttClient that can be used to communicate with an MQTT server.
MqttClient sampleClient = new MqttClient(broker, clientId, persistence);//construtor of two parameter..

//Connecting to the server(establishing the connection)
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
connOpts.setAutomaticReconnect(true);
connOpts.setCleanSession(true);
connOpts.setConnectionTimeout(10);

System.out.println(“Laptop-client connecting to broker PC: ” + broker);
sampleClient.setCallback( new MessageCallBack(){

public void connectionLost(Throwable cause) {
// After the connection is lost, it usually reconnects here
System.out.println(“disconnect，you can reconnect”);
}

public void messageArrived(String topic, MqttMessage message) throws Exception {
// The messages obtained after subscribe will be executed here
System.out.println(“Received message topic:” + topic);
System.out.println(“Received message Qos:” + message.getQos());
System.out.println(“Received message content:” + new String(message.getPayload()));
}

public void deliveryComplete(IMqttDeliveryToken token) {
System.out.println(“deliveryComplete———” + token.isComplete());
}
});

sampleClient.connect(connOpts);
System.out.println(“*********PC-client connected to broker**********”);

sampleClient.subscribe(topic);//received message

//System.out.println(“paho-client publishing message: ” + content);
MqttMessage message = new MqttMessage(content.getBytes());
message.setQos(qos);
sampleClient.publish(“service_execution”, message);//sent message
sampleClient.publish(topic, message);

System.out.println(“PC-client successsfully subscribed to broker”);
Thread.sleep(10000);

} catch(MqttException me) {
System.out.println(“reason “+me.getReasonCode());
System.out.println(“msg “+me.getMessage());
System.out.println(“loc “+me.getLocalizedMessage());
System.out.println(“cause “+me.getCause());
System.out.println(“excep “+me);
me.printStackTrace();
}
}
}

Hi Steve:
Thanks for your reply. I folllowed your indications about testing your script against public broker.
I used your websockets-3.htm file with server:test.mosquitto.org and port:8080, but error message appears:”Connection Failed-Retrying”.
I installed MQTTLens browser extension and using same server and port it connects without problems and I can publish&subscribe (the only rare thing I observed was that hostname was configured to tcp://, if I selected to ws:// , then it automatically changed again to tcp://)
So, I don´t know what I am doing wrong with your websockets-3.htm… Any help will be welcome

I am also having this problem. When i refresh the page on my phone I get the error “onConnectionLost:AMQJS0008I Socket closed.” displaying in the console on my PC browser.