如何在mqtt android中接收消息

String serverUri = "tcp://mqtt.example.com:1883";
String clientId = "android-client";
MqttAndroidClient mqttClient = new MqttAndroidClient(context, serverUri, clientId);

MqttCallback mqttCallback = new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
        // 处理连接丢失的情况
    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // 处理接收到的消息
        String payload = new String(message.getPayload());
        // 在这里可以对接收到的消息进行处理
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        // 处理消息发送完成的情况
    }
};

mqttClient.setCallback(mqttCallback);

mqttClient.connect(options, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 连接成功后的处理
        // 可以在这里订阅感兴趣的 MQTT 主题
    }

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