写一段完整的Android MQTT发送接收消息代码

很抱歉，由于您的问题涉及技术开发，我可以回答。以下是Android上实现MQTT协议的基本步骤以及示例代码：

1. 首先，你需要添加MQTT的依赖库。例如，在build.gradle中添加以下代码：

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

2. 然后，在你的Android应用程序中创建一个MqttAndroidClient对象。例如，在onCreate方法中添加以下代码：

MqttAndroidClient mqttAndroidClient = new MqttAndroidClient(context, brokerUrl, clientId);

其中，context是你的应用程序上下文，brokerUrl是MQTT代理服务器的URL，clientId是你想要MqttClient使用的标识符。

3. 接下来，你需要使用MqttConnectOptions对象来配置连接选项。例如，你可以使用以下代码创建一个MqttConnectOptions对象并设置选项：

MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
mqttConnectOptions.setCleanSession(true);
mqttConnectOptions.setAutomaticReconnect(true);
mqttConnectOptions.setWill(mqttTopic, lastWill.getBytes(), qos, true);

在这里，cleanSession选项设置为true以创建一个新的会话，在MqttClient断开连接时，将自动重新连接，最后遗嘱消息将在客户端掉线时发送。

4. 接下来，使用mqttAndroidClient.connect()方法尝试连接到MQTT代理服务器。例如，在onCreate方法中添加以下代码：

mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 连接成功
    }

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

在这里，当连接成功时，调用onSuccess方法；当连接失败时，调用onFailure方法。

5. 连接成功后，你可以使用MqttAndroidClient对象来发布和订阅MQTT主题。例如，使用mqttAndroidClient.subscribe()方法订阅主题，在onSuccess方法中添加以下代码：

mqttAndroidClient.subscribe(topicName, qos, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 订阅成功
    }

    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
        // 订阅失败
    }
});

在这里，当订阅成功时，调用onSuccess方法；当订阅失败时，调用onFailure方法。

6. 发布主题时，使用mqttAndroidClient.publish()方法。例如，在onSuccess方法中，添加以下代码向主题发布消息：

mqttAndroidClient.publish(topicName, payload.getBytes(), qos, retained, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 发布成功
    }

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

在这里，payload是需要发送的消息内容，retained表示消息是否持久化存储。

7. 最后，在退出应用程序或不需要MQTT连接时使用mqttAndroidClient.disconnect()方法断开连接。例如，在onDestroy方法中，添加以下代码：

mqttAndroidClient.disconnect();

这就是Android上实现MQTT协议的基本步骤以及示例代码。注意，这里只是提供了基本的代码示例，你需要按照自己的需求进行修改和优化。