MqttPahoMessageHandler 如何判断是否连接上mqtt服务器 代码示例

以下是一个示例代码，展示了如何使用 MqttCallback 和 MqttAsyncClient 来判断是否连接上 MQTT 服务器：

import org.eclipse.paho.client.mqttv3.*;

public class MyMqttCallback implements MqttCallback {
    private MqttAsyncClient mqttClient;

    public MyMqttCallback(MqttAsyncClient mqttClient) {
        this.mqttClient = mqttClient;
    }

    @Override
    public void connectionLost(Throwable cause) {
        System.out.println("Connection lost: " + cause.getMessage());
        try {
            // 判断是否连接上 MQTT 服务器
            if (mqttClient.isConnected()) {
                System.out.println("Still connected to MQTT broker.");
            } else {
                System.out.println("Disconnected from MQTT broker.");
            }
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

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

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

在上述代码中，MyMqttCallback 实现了 MqttCallback 接口，其中关键的部分是在 connectionLost 方法中，通过调用 MqttAsyncClient 的 isConnected 方法来判断是否连接上 MQTT 服务器。如果 isConnected 方法返回 true，表示已经连接上 MQTT 服务器；如果返回 false，则表示当前未连接上 MQTT 服务器。在实际使用中，可以将 MyMqttCallback 与 MqttAsyncClient 关联起来，以便在 MQTT 连接状态发生变化时及时进行处理。