如何将MqttClient和AsyncTask结合起来？

import android.os.AsyncTask;
import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.IMqttActionListener;
import org.eclipse.paho.client.mqttv3.IMqttToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MqttTask extends AsyncTask<Void, Void, Void> {
    private MqttAndroidClient mqttClient;
    private String serverUri;
    private String clientId;
    private String topic;
    private String message;

    public MqttTask(String serverUri, String clientId, String topic, String message) {
        this.serverUri = serverUri;
        this.clientId = clientId;
        this.topic = topic;
        this.message = message;
    }

    @Override
    protected Void doInBackground(Void... voids) {
        mqttClient = new MqttAndroidClient(context, serverUri, clientId);
        mqttClient.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();
        // 设置连接选项，如用户名、密码等

        try {
            IMqttToken token = mqttClient.connect(options, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    // 连接成功回调
                    publishMessage();
                }

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

        return null;
    }

    private void publishMessage() {
        try {
            mqttClient.publish(topic, message.getBytes(), 0, false);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

String serverUri = "tcp://mqtt.example.com:1883";
String clientId = "android-client";
String topic = "my/topic";
String message = "Hello, MQTT!";

MqttTask mqttTask = new MqttTask(serverUri, clientId, topic, message);
mqttTask.execute();