android 在Thread中使用mqtt 代码

以下是在 Thread 中使用 MQTT 的示例代码：

public class MqttThread extends Thread {

    private MqttClient mqttClient;

    @Override
    public void run() {
        super.run();

        String broker = "tcp://mqtt.eclipse.org:1883";
        String clientId = MqttClient.generateClientId();
        try {
            mqttClient = new MqttClient(broker, clientId);
            mqttClient.connect();
            mqttClient.subscribe("topic/test", new IMqttMessageListener() {
                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    // 收到消息
                }
            });
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    public void disconnect() {
        if (mqttClient != null && mqttClient.isConnected()) {
            try {
                mqttClient.disconnect();
            } catch (MqttException e) {
                e.printStackTrace();
            }
        }
    }
}

在 `run` 方法中，我们创建了一个 MQTT 客户端，并连接到 MQTT 服务器。然后订阅了一个主题，并设置了回调函数来处理收到的消息。

需要注意的是，由于 Thread 是多线程的，因此在 Thread 中进行耗时操作是可以的。但是，我们需要手动调用 `disconnect` 方法来断开 MQTT 客户端的连接，否则可能会导致连接一直保持，直到程序退出。