写一段Android端MQTT代码

好的，以下是一段简单的Android端MQTT代码示例：

首先，在AndroidManifest.xml文件中添加以下权限：

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

然后，在Java文件中引入以下依赖库：

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

接下来，在需要使用MQTT的地方创建一个MqttAndroidClient对象，并设置相关参数（例如服务器地址、客户端ID、用户名、密码等）：

String serverUri = "tcp://mqtt.server.com:1883";
String clientId = "android-client-id";
String username = "username";
String password = "password";

MqttAndroidClient client = new MqttAndroidClient(context, serverUri, clientId);
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(password.toCharArray());

接着，连接MQTT服务器：

try {
    IMqttToken token = client.connect(options);
    token.setActionCallback(new IMqttActionListener() {
        @Override
        public void onSuccess(IMqttToken asyncActionToken) {
            // 连接成功
        }

        @Override
        public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
            // 连接失败
        }
    });
} catch (MqttException e) {
    e.printStackTrace();
}

连接成功后，可以进行相关操作，例如发布消息：

String topic = "my/topic";
String payload = "Hello MQTT!";
int qos = 1;

try {
    IMqttDeliveryToken token = client.publish(topic, payload.getBytes(), qos, false);
    token.setActionCallback(new IMqttActionListener() {
        @Override
        public void onSuccess(IMqttToken asyncActionToken) {
            // 发布成功
        }

        @Override
        public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
            // 发布失败
        }
    });
} catch (MqttException e) {
    e.printStackTrace();
}

以上便是一个简单的Android端MQTT代码示例。注意，在实际应用中，需要根据具体情况进行相关参数的设置，例如服务器地址、客户端ID、用户名、密码、Topic等。