无法使用 Eclipse Paho 客户机连接到 MQTT 代理

Question

我可以使用 Python 绑定连接到我的 MQTT 代理，但我正在尝试用 Java 重现同样的事情，似乎有成功的 SSH 握手，但在发送 MQTT 连接消息后没有响应。可能是什么原因？

我的代码：

package com.daniel.qa.common.services.mqtt;
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 javax.net.ssl.*;
import java.net.Socket;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Arrays;
import java.util.logging.*;
public class MqttTest {

public static void setDebugLevel(Level newLvl) {
Logger rootLogger = LogManager.getLogManager().getLogger("");
rootLogger.addHandler(new ConsoleHandler());
Handler[] handlers = rootLogger.getHandlers();
rootLogger.setLevel(newLvl);
for (Handler h : handlers) {
h.setLevel(newLvl);
}
}

public static void main(String[] args) {
setDebugLevel(Level.FINEST);
String topic = "MQTT Examples";
String content = "Message from MqttPublishSample";
int qos = 1;
String broker = "ssl://super-car.na.mqtt.daniel.com:8883";
MemoryPersistence persistence = new MemoryPersistence();
try {
// Create a trust manager that does not validate certificate chains
TrustManager[] trustAllCerts = new TrustManager[]{
new X509ExtendedTrustManager() {
@Override
public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
}
@Override
public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
}
@Override
public X509Certificate[] getAcceptedIssuers() {
return null;
}
@Override
public void checkClientTrusted(X509Certificate[] x509Certificates, String s, Socket socket) throws CertificateException {
}
@Override
public void checkServerTrusted(X509Certificate[] x509Certificates, String s, Socket socket) throws CertificateException {
}
@Override
public void checkClientTrusted(X509Certificate[] x509Certificates, String s, SSLEngine sslEngine) throws CertificateException {
}
@Override
public void checkServerTrusted(X509Certificate[] x509Certificates, String s, SSLEngine sslEngine) throws CertificateException {
}
}
};
// Install the all-trusting trust manager
System.setProperty("jdk.tls.client.protocols", "TLSv1");
SSLContext sc = SSLContext.getInstance("TLS");
sc.init(null, trustAllCerts, new java.security.SecureRandom());
MqttClient sampleClient = new MqttClient(broker, "pahoClientId", persistence);
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
connOpts.setSocketFactory(sc.getSocketFactory());
System.out.println("Connecting to broker: " + broker);
sampleClient.connect(connOpts);
System.out.println("Connected");
System.out.println("Publishing message: " + content);
MqttMessage message = new MqttMessage(content.getBytes());
message.setQos(qos);
sampleClient.publish(topic, message);
System.out.println("Message published");
sampleClient.disconnect();
System.out.println("Disconnected");
System.exit(0);
} 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();
} catch (NoSuchAlgorithmException | KeyManagementException e) {
e.printStackTrace();
}
}
}

最精细级别的日志：

2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient MqttAsyncClient FINE： pahoClientId： ClientID=pahoClientId ServerURI=ssl：//super-car.na.mqtt.akamai.com:8883 持久性类型=org.eclipse.paho.client.mqttv3.persist.MemoryPersistence@4d49af10 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient MqttAsyncClient FINE： pahoClientId： ClientID=pahoClientId ServerURI=ssl：//super-car.na.mqtt.akamai.com:8883 持久性类型=org.eclipse.paho.client.mqttv3.persist.MemoryPersistence@4d49af10 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore FINE： pahoClientId： <> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore FINE： pahoClientId： <> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.ClientState Finer： pahoClientId： 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.ClientState Finer： pahoClientId： 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.ClientState restoreState FINE： pahoClientId：> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.ClientState restoreState FINE： pahoClientId：> 连接到代理： ssl://super-car.na.mqtt.akamai.com:8883 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient connect FINE： pahoClientId： cleanSession=true connectionTimeout=30 TimekeepAlive=60 用户名=空密码=[空] 将=[空] 用户上下文=空 callback=null 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient connect FINE： pahoClientId： cleanSession=true connectionTimeout=30 TimekeepAlive=60 用户名=空密码=[空] 将=[空] 用户上下文=空 callback=null 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModules FINE： pahoClientId： URI=ssl：//super-car.na.mqtt.akamai.com:8883 Jan 11， 2018 5：16：26 PM org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModules FINE： pahoClientId： URI=ssl：//super-car.na.mqtt.akamai.com:8883 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModule FINE： pahoClientId： URI=ssl：//super-car.na.mqtt.akamai.com:8883 Jan 11， 2018 5：16：26 PM org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModule FINE： pahoClientId： URI=ssl：//super-car.na.mqtt.akamai.com:8883 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModules 罚款：paho客户端 ID：<2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.MqttAsyncClient createNetworkModules 罚款：paho客户端 ID：<2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.ClientComms connect FINE： pahoClientId： state=CONNECTING 2018-1-11 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.ClientComms connect FINE： pahoClientId： state=CONNECTING 2018-1-11 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore open FINE： pahoClientId：> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore open FINE： pahoClientId：> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.ClientComms connectBG：run 罚款：paho客户端 ID：> 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.Token waitForFinish FINE： pahoClientId： key=null wait max=-1 token=key=null ，topics= ，用户上下文=org.eclipse.paho.client.mqttv3.MqttAsyncClient@5db45159 ，isComplete=false ，isNotified=false ，exception=null ，操作回调=org.eclipse.paho.client.mqttv3.internal.ConnectActionListener@6107227e 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.ClientComms connectBG：run 罚款：paho客户端 ID：> 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.Token waitForFinish FINE： pahoClientId： key=null wait max=-1 token=key=null ，topics= ，用户上下文=org.eclipse.paho.client.mqttv3.MqttAsyncClient@5db45159 ，isComplete=false ，isNotified=false ，exception=null ，操作回调=org.eclipse.paho.client.mqttv3.internal.ConnectActionListener@6107227e 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore getOutoutstanding DelTokens FINE： pahoClientId：> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.Token waitForResponse FINE： pahoClientId：>key=null timeout=-1 sent=false complete=false hasException=false response=null token=key=null ，topics= ，用户上下文=org.eclipse.paho.client.mqttv3.MqttAsyncClient@5db45159 ，isComplete=false ，isNotified=false ，exception=null ，操作回调=org.eclipse.paho.client.mqttv3.internal.ConnectActionListener@6107227e2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore getOutoutstanding DelTokens FINE： pahoClientId：> 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.Token waitForResponse FINE： pahoClientId：>key=null timeout=-1 sent=false complete=false hasException=false response=null token=key=null ，topics= ，用户上下文=org.eclipse.paho.client.mqttv3.MqttAsyncClient@5db45159 ，isComplete=false ，isNotified=false ，exception=null ，操作回调=org.eclipse.paho.client.mqttv3.internal.ConnectActionListener@6107227e 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.Token waitForResponse FINE： pahoClientId： key=null wait max=-1 2018年1月11日 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con message=CONNECT clientId pahoClientId keepAliveInterval 60 1月 11， 2018 5：16：26 PM org.eclipse.paho.client.mqttv3.internal.Token waitForResponse FINE： pahoClientId： key=null wait max=-1 2018-1-1 下午05：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con message=CONNECT clientId pahoClientId keepAliveInterval 60 2018-1-11 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 下午5：16：26 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 5：16：26 PM org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule 启动 FINE： pahoClientId： 连接到主机 super-car.na.mqtt.akamai.com 端口 8,883 超时 0 2018-1-11下午05：16：26 org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule start FINE： pahoClientId：连接到主机 super-car.na.mqtt.akamai.com 端口 8,883 timeout 0 Jan 11， 2018 5：16：28 PM org.eclipse.paho.client.mqttv3.internal.CommsReceiver start FINE： pahoClientId： 从 2018 年 1 月 11 日下午 5：16：28 开始 org.eclipse.paho.client.mqttv3.internal.CommsReceiver start FINE： pahoClientId： 从 2018 年 1 月 11 日下午 5：16：28 开始 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： paho客户端 ID：网络读取消息 2018-1-11下午05：16：28 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： paho客户端 ID：网络读取消息 2018-1-11下午05：16：28 org.eclipse.paho.client.mqttv3.internal.ClientState get FINE： pahoClientId：等待 60,000 毫秒的新工作或空间 飞行窗口 2018-1-11下午05：16：28 org.eclipse.paho.client.mqttv3.internal.ClientState get FINE： pahoClientId：等待 60,000 毫秒的新工作或空间 飞行窗口 2018年1月11日 下午5：16：30 org.eclipse.paho.client.mqttv3.internal.ClientComms internalSend FINE： pahoClientId： internalSend key=Con message=CONNECT clientId pahoClientId keepAliveInterval 60 token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 下午5：16：30 org.eclipse.paho.client.mqttv3.internal.ClientComms 内部发送罚款： pahoClientId： 内部发送密钥=Con 消息=连接 clientId pahoClientId keepAliveInterval 60 token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 下午5：16：28 org.eclipse.paho.client.mqttv3.internal.CommsCallback run 罚款：paho客户端 ID：等待工作可用 2018-1-11 下午05：16：28 org.eclipse.paho.client.mqttv3.internal.CommsCallback run FINE： paho客户端ID： 等待工作可用 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState send FINE： pahoClientId： 挂起发送密钥=0 消息 CONNECT clientId pahoClientId 保持活动间隔 60 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState send FINE： pahoClientId： 挂起发送密钥=0 消息 CONNECT clientId pahoClientId 保持活动间隔 60 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con message=CONNECT clientId pahoClientId 保持活动间隔 60 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con message=CONNECT clientId pahoClientId 保持活动间隔 60 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore saveToken FINE： pahoClientId： key=Con token=org.eclipse.paho.client.mqttv3.MqttToken@767dab68 1月 11， 2018 下午 5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsSender run FINE： pahoClientId： network send key=Con msg=CONNECT clientId pahoClientId keepAliveInterval 60 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsSender run FINE： pahoClientId： network send key=Con msg=CONNECT clientId pahoClientId 保持活动间隔 60 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.wire.MqttOutputStream write罚款：空：500 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.wire.MqttOutputStream write 罚款：空：500 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState notifySent FINE： pahoClientId： key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState notifySent FINE： pahoClientId： key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifySent FINE： pahoClientId：> key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifySent FINE： pahoClientId：> key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState get FINE： pahoClientId：等待 60,000 毫秒的新工作或空间 飞行窗口 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState get FINE： pahoClientId：等待 60,000 毫秒的新工作或空间 飞行窗口 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： pahoClientId：由于 IOException 而停止 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： pahoClientId：由于 IOException 而停止 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientComms shutdownConnection 罚款：paho客户端 ID：状态=断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientComms shutdownConnection 罚款：paho客户端 ID：状态=断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback stop FINE： paho客户端 ID： 停止 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback stop FINE： paho客户端 ID： 停止 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback stop FINE： paho客户端 ID：通知工作可用并等待运行 2018 年 1 月 11 日 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsCallback stop 罚款：paho客户端 ID：通知工作可用并等待运行 2018 年 1 月 11 日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback run 罚款：paho客户端 ID：通知空间可用 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback run FINE： paho客户端 ID： 通知空间可用 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsCallback stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsReceiver stop FINE： paho客户端 ID： 停止 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver stop FINE： paho客户端 ID： 停止 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsReceiver stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsTokenStore quiesce FINE： pahoClientId： resp=Client 当前正在断开连接 (32102) 1 月 11 日， 2018 5：16：31 下午 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore quiesce FINE： pahoClientId： resp=Client 当前正在断开连接 (32102) 1 月 11 日， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.ClientComms handleOldTokens FINE： pahoClientId：> 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientComms handleOldTokens 罚款：paho客户端 ID：> 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState resolveOldTokens 罚款：paho客户端 ID：原因连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState resolveOldTokens 罚款：paho客户端 ID：原因连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore getOutoutstanding Tokens FINE： pahoClientId：> 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore getOutoutstanding Tokens FINE： pahoClientId：> 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore removeToken 罚款：pahoClientId：key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore removeToken 罚款：pahoClientId：key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState disconnected FINE： pahoClientId： 已断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState disconnected FINE： pahoClientId： 已断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState clearState FINE： pahoClientId：> 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState clearState FINE： pahoClientId：> 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore clear FINE： paho客户端 ID：> 0 个代币 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsTokenStore clear FINE：paho客户端 ID：> 0 个代币 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsSender stop FINE： paho客户端 ID： 停止发件人 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsSender stop FINE： paho客户端 ID： 停止发件人 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState notifyQueueLock 罚款：paho客户端 ID：通知队列锁持有者 2018-1-1-1 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.ClientState notifyQueueLock 罚款：paho客户端 ID：通知队列锁持有者 2018-1-1-1 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.ClientState get FINE： pahoClientId：没有未完成的流量，也没有连接 2018 年 1 月 11 日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.ClientState get 罚款：pahoClientId：没有未完成的流量，未连接 1 月 11 日， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsSender 运行精细：pahoClientId：获取返回空值的消息，停止} 1 月 11 日， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsSender 运行精细：pahoClientId：获取返回空值的消息，停止} 1 月 11 日， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsSender 运行精细： paho客户端 ID： <2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsSender run FINE： pahoClientId： <2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsSender stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.CommsSender stop FINE： paho客户端ID： 停止 Jan 11， 2018 5：16：31 PM org.eclipse.paho.client.mqttv3.internal.ClientComms shutdownConnection 罚款：pahoClientId：状态=断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.ClientComms shutdownConnection 罚款：pahoClientId：状态=断开连接 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback handleActionComplete FINE： pahoClientId： 回调和通知 key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback handleActionComplete FINE： pahoClientId： 回调和通知 key=Con 2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifyComplete FINE： pahoClientId：>key=Con response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifyComplete FINE： pahoClientId：>key=Con response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback fireActionEvent 罚款：pahoClientId：调用成功密钥=Con 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.CommsCallback fireActionEvent 罚款：pahoClientId：调用成功密钥=Con 2018-1-11 下午05：16：31 org.eclipse.paho.client.mqttv3.internal.Token markComplete FINE： pahoClientId：>key=null response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.Token markComplete FINE： pahoClientId：>key=null response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifyComplete FINE： pahoClientId：>key=null response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.Token notifyComplete FINE： pahoClientId：>key=null response=null excep=连接丢失 (32109) - java.io.EOFException 2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： pahoClientId： <2018年1月11日 下午5：16：31 org.eclipse.paho.client.mqttv3.internal.CommsReceiver run FINE： pahoClientId：

2018-1-11下午05：16：31 org.eclipse.paho.client.mqttv3.internal.Token 等待响应 罚款： paho客户端 ID： 失败，出现异常连接 丢失 (32109) - java.io.EOFException at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java：138) at java.lang.Thread.run(Thread.java：748) 由以下原因引起： java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java：267) atorg.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java：56) 在 org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java：100) ...1 更多

连接丢失 (32109) - java.io.EOFException at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java：138) at java.lang.Thread.run(Thread.java：748) 由以下原因引起： java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java：267) at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java：56) 在 org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java：100) ...1 更多

进程已完成，退出代码为 0

Answer 1

问题是 MQTT 版本 - 在第一个 Java 版本中，我有较旧的库 - mqtt-client 0.4.0 - 它有 MQTT 3.1，而代理不支持它，所以当注意到它时它正在终止 SSL 连接。当我切换到更新的(org.eclipse.paho.client.mqttv3 1.0.2，MQTT 3.1.1)时，连接成功。