MQTT我这边遇到一个问题, 大概第4~6次调用会报错:。什么原因？-[阿里云_云淘科技]

匿名 • 2023年12月10日下午3:25 • 阿里云

MQTT我这边遇到一个问题, 当我们的云服务比较快速(2~3次/秒)的调用mqtt发布p2p消息时, 大概第4~6次调用会报错:
org.eclipse.paho.client.mqttv3.MqttException: 客户机未连接

没有clientId重复的问题, 我们的代码也是照着SDK的demo写的. 使用的是Signature鉴权模式.

以下为热心网友提供的参考意见

这个问题可能是由于MQTT客户端在快速调用时，连接没有正确建立或者断开导致的。你可以尝试以下方法解决这个问题：

增加连接超时时间。在创建MQTT客户端时，可以设置connectTimeout参数来增加连接超时时间。例如：

MqttClient client = new MqttClient("tcp://your-mqtt-broker:1883", MqttClient.generateClientId());
client.setConnectTimeout(30 * 1000); // 设置连接超时时间为30秒

使用异步回调处理连接事件。在创建MQTT客户端时，可以设置MqttCallback接口的实现类，用于处理连接、消息接收等事件。例如：

client.setCallback(new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
        // 处理连接丢失事件
    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // 处理消息到达事件
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        // 处理消息发送完成事件
    }
});