android - MQTT Paho 客户端不会自动重新连接到代理

Question

如果连接丢失，我的 paho-mqtt 服务将无法重新连接到代理。
在连接丢失时，我使用 adb shell 从 Android 客户端 ping 两个代理，并从托管蚊子代理的服务器（Windows 10）和 Android 设备 ping 通。
我通过部署了 Android Things（最新版本）的 Raspberry Pi 3B 使用 LAN 连接到网络。LAN网络相当稳定。对于 Paho MQTT，我使用的是最新版本。
我注意到我的 MQTT 连接随机丢失。

fun connect(context: Context) {
    connectOptions.keepAliveInterval=30//seconds
    connectOptions.mqttVersion = MqttConnectOptions.MQTT_VERSION_3_1_1
    connectOptions.isAutomaticReconnect = true
    connectOptions.isCleanSession = false

    connectOptions.setWill(Global.HmiSrNo + "_out", "Disconnected".toByteArray(), 2, false)
    mqttAndroidClient = MqttAndroidClient(context, serverUri, clientId)
    try {
        val token = mqttAndroidClient.connect(connectOptions)
        token.actionCallback = object : IMqttActionListener {
            override fun onSuccess(asyncActionToken: IMqttToken)
            {
                subscribe(context)
                automicLight.set(true)
                issnackbarshown = true
                if(Global.connectivitylost)
                    wantToCloseDialog = true

            }
            override fun onFailure(asyncActionToken: IMqttToken, exception: Throwable) {
                //connectionStatus = false
                Log.i("Connection", "failure")
                // Give your callback on connection failure here
                exception.printStackTrace()
            }
        }
    } catch (e: MqttException) {
        // Give your callback on connection failure here
        e.printStackTrace()
    }
 }

建造等级

<service android:name="org.eclipse.paho.android.service.MqttService" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="com.google.android.things.permission.USE_PERIPHERAL_IO" />
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.WAKE_LOCK" />
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'
implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
repositories {
    maven {
        url "https://repo.eclipse.org/content/repositories/paho-releases/"
    }
}

标签： androidmqttpaho