org.eclipse.paho.client mqtt客户端连接超时

Posted zhangyy3

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了org.eclipse.paho.client mqtt客户端连接超时相关的知识,希望对你有一定的参考价值。

客户端订阅mqtt 的时候 显示超时。第二次重起服务可能就好了,但是可能会丢消息。

报错如下

org.eclipse.paho.client.mqttv3.MqttException: 等待来自服务器的响应时超时
        at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:31) ~[org.eclipse.paho.client.mqttv3-1.2.1.jar!/:na]
        at org.eclipse.paho.client.mqttv3.internal.ClientState.checkForActivity(ClientState.java:741) ~[org.eclipse.paho.client.mqttv3-1.2.1.jar!/:na]
        at org.eclipse.paho.client.mqttv3.internal.ClientComms.checkForActivity(ClientComms.java:816) ~[org.eclipse.paho.client.mqttv3-1.2.1.jar!/:na]
        at org.eclipse.paho.client.mqttv3.internal.ClientComms.checkForActivity(ClientComms.java:802) ~[org.eclipse.paho.client.mqttv3-1.2.1.jar!/:na]
        at org.eclipse.paho.client.mqttv3.TimerPingSender$PingTask.run(TimerPingSender.java:79) ~[org.eclipse.paho.client.mqttv3-1.2.1.jar!/:na]
        at java.util.TimerThread.mainLoop(Timer.java:555) ~[na:1.8.0_221]
        at java.util.TimerThread.run(Timer.java:505) ~[na:1.8.0_221]

  解决办法:

 

log.info("try connect to mqtt");
//调用connect 后,一定要再调用 一下token.waitForCompletion();这样应该就可以了。原因不明。
IMqttToken token = client.connect(connOpts);
token.waitForCompletion();
log.info("connect mqtt success");
client.subscribe(topic, 1, new MqttMsgListener());

以上是关于org.eclipse.paho.client mqtt客户端连接超时的主要内容,如果未能解决你的问题,请参考以下文章

如何导入org.eclipse.paho.client.mqttv3

GraphQL - Nullable 不是可重复的注释类型

MQTT(EMQX)

跟踪MQTT源码

Sprngboot 整合 mqtt 完整代码示例

Sprngboot 整合 mqtt 完整代码示例