如何为MQTT Paho-Android的Publish方法设置超时时间？

由于MqttAndroidClient本身没有直接的setTimeToWait方法，你可以通过以下两种方式实现发布超时控制：

1. 结合IMqttToken与超时定时器 #

MqttAndroidClient的publish方法会返回IMqttToken对象，我们可以基于这个对象搭配超时逻辑来判断发布是否超时。

方式A：Kotlin协程实现（推荐） #

利用协程的withTimeoutOrNull方法，在指定时间内等待发布完成，超时则取消操作：

// 假设已完成MQTT连接，在协程作用域内执行发布
fun publishWithCoroutineTimeout(topic: String, payload: String, timeoutMillis: Long = 5000) = lifecycleScope.launch {
    val publishToken = mqttClient.publish(topic, payload.toByteArray(), 1, false)
    
    val isSuccess = withTimeoutOrNull(timeoutMillis) {
        publishToken.waitForCompletion()
        true
    }

    when (isSuccess) {
        true -> {
            // 发布成功逻辑
        }
        null -> {
            // 超时处理：取消发布操作，标记失败
            publishToken.cancel()
            // 执行超时后的业务逻辑，如提示用户
        }
    }
}

方式B：Handler定时器实现 #

通过Handler.postDelayed设置超时任务，同时监听IMqttActionListener的回调，完成或失败时取消超时任务：

fun publishWithHandlerTimeout(topic: String, payload: String, timeoutMillis: Long = 5000) {
    val publishToken = mqttClient.publish(topic, payload.toByteArray(), 1, false)
    val handler = Handler(Looper.getMainLooper())
    val timeoutRunnable = Runnable {
        if (!publishToken.isComplete) {
            publishToken.cancel()
            // 超时处理逻辑
        }
    }

    // 启动超时定时器
    handler.postDelayed(timeoutRunnable, timeoutMillis)

    // 设置发布回调
    publishToken.actionCallback = object : IMqttActionListener {
        override fun onSuccess(asyncActionToken: IMqttToken?) {
            handler.removeCallbacks(timeoutRunnable)
            // 发布成功逻辑
        }

        override fun onFailure(asyncActionToken: IMqttToken?, exception: Throwable?) {
            handler.removeCallbacks(timeoutRunnable)
            // 发布失败逻辑（如网络异常）
        }
    }
}

2. 配置基础通讯超时参数（辅助优化） #

虽然这不是直接针对发布操作的超时，但可以通过MqttConnectOptions配置连接和心跳超时，减少无限等待的场景：

val options = MqttConnectOptions().apply {
    userName = BuildConfig.MQTT_USERNAME
    password = BuildConfig.MQTT_PASSWORD.toCharArray()
    isCleanSession = false
    isAutomaticReconnect = false
    connectionTimeout = 10 // 连接超时，单位：秒
    keepAliveInterval = 30 // 心跳间隔，单位：秒
}

注意事项 #

• 调用publishToken.cancel()会终止当前发布操作，避免不必要的资源占用
• 使用Handler时，需在页面销毁（如onDestroy）时移除未执行的Runnable，防止内存泄漏
• 协程方式更贴合Kotlin项目的代码风格，且无需手动管理定时器生命周期

内容的提问来源于stack exchange，提问作者M. Usman Khan