如何将PAHO/Eclipse MQTT Android服务引入Android Studio项目

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

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

public class MyMqttService extends MqttService {
    // 实现相应的回调方法
}

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

mqttAndroidClient.connect(options, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 连接成功后的处理
    }

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

String topic = "my/topic";
int qos = 1;
mqttAndroidClient.subscribe(topic, qos, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 订阅成功后的处理
    }

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

String message = "Hello, MQTT!";
mqttAndroidClient.publish(topic, message.getBytes(), qos, false, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        // 发布成功后的处理
    }

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