android mqtt json

Android Mqtt Json是一种用于在Android手机上使用Mqtt协议进行通信的工具，它能够实现消息的订阅和发布，并且能够将传输的数据进行Json格式的编解码。

@H_404_4@

首先，在项目的build.gradle文件中添加以下依赖项：

dependencies {
    implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.0'
    implementation 'com.google.code.gson:gson:2.8.2'
}

其中，org.eclipse.paho.client.mqttv3为Mqtt客户端库，com.google.code.gson为Json编解码库。

接着，在代码中可以通过以下方式初始化MqttClient：

String brokerUrl = "tcp://broker.hivemq.com:1883";
String clientId = "AndroidClient";
MemoryPersistence persistence = new MemoryPersistence();
MqttClient mqttClient = new MqttClient(brokerUrl,clientId,persistence);

其中，brokerUrl为Mqtt服务器地址，clientId为客户端ID，persistence为客户端持久化方式。

订阅消息可以使用以下方法：

String topicName = "testTopic";
mqttClient.subscribe(topicName,new IMqttMessageListener() {
    @Override
    public void messageArrived(String s,MqttMessage mqttMessage) throws Exception {
        String payload = new String(mqttMessage.getPayload());
        Gson gson = new Gson();
        JsonObject jsonObject = gson.fromJson(payload,JsonObject.class);
        String message = jsonObject.get("message").getAsstring();
        // 处理收到的消息
    }
});

其中，IMqttMessageListener为消息接收监听器，将接收到的消息进行Json解码，获取其中的message字段，进行处理。

发布消息可以使用以下方法：

JsonObject jsonObject = new JsonObject();
jsonObject.addProperty("message","Hello World!");
String payload = jsonObject.toString();
MqttMessage mqttMessage = new MqttMessage(payload.getBytes());
mqttClient.publish(topicName,mqttMessage);

其中，Json编码将message字段转为Json对象，使用mqttClient.publish方法将消息发送出去。

在使用Android Mqtt Json时，还需要注意在AndroidManifest.xml文件中添加以下权限：

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

这些权限是为了让Android程序可以访问网络，使用Mqtt协议进行通信。