Потеряно соединение (32109) - java.io.EOFException
Я использовал eclipse MQTT для подключения к серверу MQTT.
Я могу подключиться к серверу успешно, но когда я публикую сообщение, я получил эту ошибку
Соединение потеряно
msg: соединение потеряно
loc: потеря соединения: java.io.EOFException
excep: соединение потеряно (32109) - java.io.EOFException
Я искал эту проблему. но я не могу найти верный ответ! какая-то ссылка, которую я основал здесь { здесь, здесь, здесь,... }
Мой код:
private final String DEFAULT_HOST = "edge-mqtt.facebook.com";
private final int DEFAULT_PORT = 443;
public void connect(String protogle) throws Exception {
this.broker = protogle + "://"+ DEFAULT_HOST + ":" + DEFAULT_PORT;
this.mqttClient = new MqttClient(broker,getMqttClientId() ,new MemoryPersistence() );
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
connOpts.setKeepAliveInterval( MQTT_KEEPALIVE);
connOpts.setUserName( getMqttUsername() );
connOpts.setPassword( getMqttPassword().toCharArray() );
//connOpts.setMqttVersion( 3 );//some times it have an error
//connOpts.setSocketFactory(SSLTunnelSocketFactory.getInstance());
Logger.w("Connecting to broker: "+broker);
Logger.w("isConnected:"+mqttClient.isConnected());
try {
IMqttToken cn = mqttClient.connectWithResult(connOpts);
Logger.w("connected");
}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);
return;
}
this.mqttClient.setCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable me) {
Logger.w("Connection lost");
System.out.println("msg "+me.getMessage());
System.out.println("loc "+me.getLocalizedMessage());
System.out.println("cause "+me.getCause());
System.out.println("excep "+me);
}
@Override
public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
Logger.w("message Arrived");
}
@Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
Logger.w("deliverd--------");
try {
MqttDeliveryToken token = (MqttDeliveryToken) iMqttDeliveryToken;
String h = token.getMessage().toString();
Logger.w("deliverd message :"+h);
} 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);
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
И опубликовать метод:
private void publish(String topic , String payload , int qosLevel) throws Exception {
Logger.w("start publishing :");
//payload = Helper.zlib_encode(payload);
topic = mapTopic(topic);
MqttMessage message = new MqttMessage();
message.setPayload(payload.getBytes("UTF-8") );
message.setQos(0);
mqttClient.publish(topic , message);
Logger.w("publised------------------");
}
выход:
Connecting to broker: ssl://edge-mqtt.facebook.com:443
isConnected:false
connected
start publishing :
deliverd--------
publised------------------
deliverd message : //my message
Connection lost
msg : Connection lost
loc : Connection lost
cause : java.io.EOFException
excep : Connection lost (32109) - java.io.EOFException
Eclipse Paho Log:
============== Connection options ==============
CleanSession : true
SocketFactory : sun.security.ssl.SSLSocketFactoryImpl@6c010ee9
MqttVersion : 3
KeepAliveInterval : 60
ConTimeout : 30
UserName : . . .
SSLProperties : null
WillDestination : null
==========================================
2017-10-19 09:42:02,182 INFO [MQTT Call: Bahram091547759 ] [MqttConnectionResultHandler ] - insta connected
2017-10-19 09:42:02,187 INFO [JavaFX Application Thread ] [MqttEventHandler ] - About to resubscribe to all requested topics
2017-10-19 09:42:08,559 INFO [JavaFX Application Thread ] [MqttAsyncConnection ] - Publishing message on topic "k.,". Payload size = "3"
2017-10-19 09:42:08,739 ERROR [MQTT Rec: Bahram091547759 ] [MqttCallbackHandler ] - Connection insta lost
Connection lost (32109) - java.io.EOFException
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java: 146)
at java.lang.Thread.run(Unknown Source)
Caused by: java.io.EOFException
at java.io.DataInputStream.readByte(Unknown Source)
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMess age(MqttInputStream.java:65)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:107)
... 1 more
5 ответов
Если это кому-нибудь поможет... У меня было то же исключение и я исправил его, убедившись, что был сгенерирован уникальный идентификатор клиента (с MqttAsyncClient.generateClientId()), как указано здесь: https://github.com/eclipse/paho.mqtt.java/issues/207
Javadoc для connectWithResult рекомендует позвонить setCallback(MqttCallback) до подключения, чтобы сообщения, предназначенные для клиента, можно было принимать сразу после подключения клиента.
Попробуйте переместить mqttClient.setCallback позвоните в вашем исходном коде.
Также попробуйте запустить вашу программу с java -Djavax.net.debug=all
Недавно я работал с этим. Я столкнулся с той же проблемой: ошибка 32109 сразу после успешного подключения.
Это проблема, о которой сообщалось в репозитории Пахо.
Я обновил свою библиотеку с:
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.1'
к:
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.2'
И это исправляет.
Попробуйте уменьшить время поддержания активности до 15 секунд и установите ConnectionTimeout на 30
connOpts.setKeepAliveInterval(15);
connOpts.setConnectionTimeout(30);
Я исправил ошибку Подробнее см. Здесь: https://github.com/eclipse/paho.mqtt.java/issues/207