Paho MQTT中connectionLost方法始终不触发的问题排查

我之前踩过类似的坑，咱们来一步步拆解可能的原因和解决办法：

1. 最常见的坑：MqttClient是局部变量导致被GC回收 #

你在connect()方法里局部创建了MqttClient对象，当方法执行完毕后，这个对象很可能被Java的垃圾回收机制回收掉——没有了客户端实例，回调线程自然没法触发connectionLost方法。

解决办法是把MqttClient改成类级别的成员变量，让它的生命周期和你的应用组件（比如服务、类实例）保持一致：

// 把MqttClient提升为类成员变量
private MqttClient mqttClient;
private MqttCallback callback; // 同时确保callback也是类成员，避免被GC

public void connect() throws MqttException {
    MqttConnectOptions options = new MqttConnectOptions();
    options.setUserName("user");
    options.setPassword("pass".toCharArray());
    options.setAutomaticReconnect(true);
    
    // 避免重复创建客户端实例
    if (mqttClient == null || !mqttClient.isConnected()) {
        mqttClient = new MqttClient("tcp://broker:8884", MqttClient.generateClientId(), handlerPahoDirs());
        mqttClient.setCallback(callback);
        mqttClient.connect(options);
        mqttClient.subscribe(this.topic);
    }
}

2. 自动重连开启后的回调触发逻辑冲突 #

你设置了options.setAutomaticReconnect(true)，这时候Paho客户端会在后台自动尝试重连，默认情况下：

• 客户端不会立即触发connectionLost，而是先尝试自动重连
• 只有当自动重连多次失败（达到内部重试阈值）后，才会触发connectionLost

如果这时候你在connectionLost里手动调用connect()，会和自动重连逻辑冲突，反而可能导致回调异常或不触发。建议：

• 要么关闭自动重连（setAutomaticReconnect(false)），完全手动处理重连
• 要么保留自动重连，去掉connectionLost里的手动connect()调用，让客户端自己处理重连

3. 心跳间隔太长导致检测延迟 #

Paho默认的心跳间隔是60秒，也就是说，客户端需要等60秒才会检测到连接丢失。如果你在调试时刚断开网络就立刻看回调，自然看不到触发。

可以缩短心跳间隔来加快检测速度：

// 设置心跳间隔为10秒，加快连接丢失的检测
options.setKeepAliveInterval(10);

4. 回调对象本身被回收 #

如果你的callback对象也是局部创建的（比如在某个方法里new了MqttCallback的匿名内部类），同样会被GC回收，导致回调无法触发。确保callback也是类成员变量，保持生命周期稳定。

内容的提问来源于stack exchange，提问作者FearX