Paho MQTT客户端遇连接断开时无法自动重连到Broker问题咨询

• 依赖版本兼容bug：使用的org.eclipse.paho.client.mqttv3:1.2.5与org.eclipse.paho.android.service:1.1.1存在已知的自动重连触发失效问题，LAN静态接入场景下网络状态无变化时，重连逻辑不会主动启动。
• 回调监听缺失：仅配置了首次连接的回调，未注册MQTT全局状态回调，无法监听连接断开事件、自动重连执行状态，重连成功后也无对应订阅恢复逻辑。
• 配置项缺失：未配置连接超时、最大重连间隔参数，默认指数退避策略会将重连间隔拉长到数小时，且未配置电源锁，设备休眠时TCP连接易被系统回收。
• 服务进程易被回收：MqttService未做前台保活配置，长时间运行时会被Android Things系统主动回收，自动重连逻辑随之失效。

1. 调整依赖版本 #

使用经过验证的兼容版本组合，避免已知bug：

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.0'
implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'

2. 补充全局状态回调 #

注册MqttCallbackExtended监听连接全生命周期状态，新增重连兜底逻辑：

// 在初始化mqttAndroidClient后、调用connect前添加回调
mqttAndroidClient.setCallback(object : MqttCallbackExtended {
    override fun connectComplete(reconnect: Boolean, serverURI: String?) {
        // 重连成功后恢复订阅
        if(reconnect) {
            subscribe(context)
            // 原有连接成功后的业务逻辑
            automicLight.set(true)
            issnackbarshown = true
            if(Global.connectivitylost)
                wantToCloseDialog = true
        }
    }

    override fun connectionLost(cause: Throwable?) {
        Log.e("MQTT", "连接断开", cause)
        // 兜底手动触发重连，避免系统自动重连失效
        if(!mqttAndroidClient.isConnected) {
            try {
                mqttAndroidClient.connect(connectOptions)
            } catch (e: MqttException) {
                e.printStackTrace()
            }
        }
    }

    override fun messageArrived(topic: String?, message: MqttMessage?) {
        // 原有消息接收处理逻辑
    }

    override fun deliveryComplete(token: IMqttDeliveryToken?) {
        // 原有消息发送完成处理逻辑
    }
})

3. 完善连接配置 #

补充必要的连接参数，添加电源锁避免TCP连接被回收：

// 在原有connectOptions配置基础上新增
connectOptions.connectionTimeout = 10 // 连接超时时间10秒
connectOptions.maxReconnectDelay = 30000 // 最大重连间隔30秒，避免指数退避时间过长

// 申请电源锁
val powerManager = context.getSystemService(Context.POWER_SERVICE) as PowerManager
val wakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "MQTT:ServiceLock")
wakeLock.acquire(12*60*60*1000L /*12小时，可根据业务调整*/)

4. 服务前台保活 #

将MqttService设置为前台服务，避免被系统回收：

// 在Service的onCreate方法中添加，适配Android 8.0+通知渠道
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
    val channel = NotificationChannel("mqtt_service", "MQTT运行服务", NotificationManager.IMPORTANCE_LOW)
    val notifyManager = context.getSystemService(NotificationManager::class.java)
    notifyManager.createNotificationChannel(channel)
}
val notify = NotificationCompat.Builder(context, "mqtt_service")
    .setContentTitle("MQTT连接服务")
    .setContentText("后台运行中")
    .setSmallIcon(R.mipmap.ic_launcher)
    .build()
startForeground(1001, notify)

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