基于koltlin的paho实现mqtt

您好！基于 Kotlin 的 Paho 实现 MQTT，以下是一个简单的示例代码：

import org.eclipse.paho.client.mqttv3.*
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence

class MqttClientSample(private val broker: String, private val clientId: String) {

    private lateinit var client: MqttClient

    fun connect() {
        val persistence = MemoryPersistence()
        client = MqttClient(broker, clientId, persistence)
        val options = MqttConnectOptions()
        options.isCleanSession = true
        options.connectionTimeout = 10
        options.keepAliveInterval = 60
        client.connect(options)
    }

    fun publish(topic: String, message: String) {
        val mqttMessage = MqttMessage(message.toByteArray())
        mqttMessage.qos = 2
        client.publish(topic, mqttMessage)
    }

    fun subscribe(topic: String, callback: IMqttMessageListener) {
        client.subscribe(topic, 2, callback)
    }

    fun disconnect() {
        client.disconnect()
    }
}

以上代码中，我们使用 Eclipse Paho 客户端库实现了一个 MQTT 客户端，包含 `connect()`、`publish()`、`subscribe()` 和 `disconnect()` 方法，分别用于连接到 MQTT 服务器、发布消息、订阅主题和断开连接。其中，`subscribe()` 方法使用了回调函数 `IMqttMessageListener`，用于处理收到的消息。

示例代码中的 `MqttClientSample` 类使用了 Kotlin 的类构造函数，接受两个参数 `broker` 和 `clientId`，分别表示 MQTT 服务器的地址和客户端的唯一标识符。在 `connect()` 方法中，我们创建了一个 `MqttClient` 实例，使用了 `MemoryPersistence` 存储，然后设置了一些连接选项，最后调用了 `connect()` 方法连接到 MQTT 服务器。在 `publish()` 方法中，我们创建了一个 `MqttMessage` 对象，并设置了消息内容和 QoS 等级，然后调用了 `publish()` 方法发布消息。在 `subscribe()` 方法中，我们调用了 `subscribe()` 方法订阅主题，并指定了 QoS 等级和回调函数。在 `disconnect()` 方法中，我们调用了 `disconnect()` 方法断开连接。

需要注意的是，以上代码中的 MQTT 客户端是同步的，如果需要异步处理消息，可以使用 `MqttAsyncClient` 类。另外，由于 MQTT 是基于 TCP 的协议，因此需要在 Android 应用程序中使用时，需要在 AndroidManifest.xml 文件中添加网络权限：

<uses-permission android:name="android.permission.INTERNET" />