android studio 连接emqx

要在Android Studio中连接EMQX，您需要遵循以下步骤：

1.在build.gradle文件中添加以下依赖项：

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'
implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'

2.在AndroidManifest.xml文件中添加以下权限：

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

3.在AndroidManifest.xml文件中添加以下服务：

<service android:name="org.eclipse.paho.android.service.MqttService">
</service>

4.在您的代码中，您需要创建一个MqttAndroidClient对象并设置回调函数。然后，您可以使用该对象连接到EMQX服务器并订阅主题。

MqttAndroidClient client = new MqttAndroidClient(context, "tcp://<EMQX服务器地址>:1883", "clientId");
client.setCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable cause) {
// 连接丢失时的处理
}

@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
// 接收到消息时的处理
}

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

MqttConnectOptions options = new MqttConnectOptions();
options.setUserName("<EMQX用户名>");
options.setPassword("<EMQX密码>".toCharArray());

try {
IMqttToken token = client.connect(options);
token.waitForCompletion();
client.subscribe("<订阅的主题>", 0);
} catch (MqttException e) {
e.printStackTrace();
}