求助:服务器连接mqtt服务器一直重连,现在也无法推送消息至mqtt

环境

  • EMQX 版本:mosquitto-2.0.12
  • 操作系统版本:OpenCloudOS 8.8
    异常信息:
    2025-08-29 10:14:46.331 WARN 886404 — [schedule-pool-1] io.renren.mqtt.MyMQTTCallback : mqtt reconnect times = 3 try again… mqtt重新连接时间 3
    2025-08-29 10:14:46.331 ERROR 886404 — [schedule-pool-1] io.renren.mqtt.MyMQTTCallback : mqtt断连异常

org.eclipse.paho.client.mqttv3.MqttException: Connect already in progress
at org.eclipse.paho.client.mqttv3.MqttAsyncClient.reconnect(MqttAsyncClient.java:1275)
at org.eclipse.paho.client.mqttv3.MqttClient.reconnect(MqttClient.java:711)
at io.renren.mqtt.MyMQTTCallback.lambda$connectionLost$0(MyMQTTCallback.java:127)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:842)

重连代码


推送结果
io.renren.mqtt.MyMQTTClient : 推送失败:Timed out waiting for a response from the server

你用的是 mosquitto,不是 EMQX…