安卓通过EMQX接收消息

要在安卓应用程序中使用 EMQX 接收消息，需要使用 MQTT Android 客户端库。以下是在安卓应用程序中使用 EMQX 接收消息的步骤：

1. 在 build.gradle 文件中添加 MQTT Android 客户端库的依赖项：

dependencies {
    implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.0'
}

2. 在应用程序中创建一个 MQTT 客户端实例：

String clientId = MqttClient.generateClientId();
MqttAndroidClient client = new MqttAndroidClient(this.getApplicationContext(), "tcp://broker.emqx.io:1883", clientId);

其中，第一个参数是应用程序的上下文，第二个参数是 EMQX 代理的地址和端口，第三个参数是客户端 ID。

3. 连接到 EMQX 代理：

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

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

4. 订阅主题：

try {
    IMqttToken subToken = client.subscribe("topic", 0);
    subToken.setActionCallback(new IMqttActionListener() {
        @Override
        public void onSuccess(IMqttToken asyncActionToken) {
            // 订阅成功
        }

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

其中，第一个参数是要订阅的主题，第二个参数是 QoS 等级。

5. 接收消息：

client.setCallback(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) {

    }
});

以上就是在安卓应用程序中使用 EMQX 接收消息的步骤。