用java代码实现mqtt连接异常后重新连接，并且订阅原先订阅的主题

以下是使用 Java Eclipse Paho MQTT 库实现 MQTT 连接异常后重新连接，并订阅原先订阅的主题示例代码：

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

public class MqttClientExample implements MqttCallback {

    // 连接参数
    private static final String broker = "tcp://mqtt_server_ip:1883";
    private static final String clientId = "JavaExample";
    private static final String username = "mqtt_username";
    private static final String password = "mqtt_password";
    private static final String[] topics = {"topic1", "topic2"};

    // MQTT 客户端
    private MqttClient client;

    // 构造函数
    public MqttClientExample() {
        // 创建 MQTT 客户端
        try {
            client = new MqttClient(broker, clientId, new MemoryPersistence());
            client.setCallback(this);

            // 设置连接参数
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setUserName(username);
            connOpts.setPassword(password.toCharArray());
            connOpts.setCleanSession(true);

            // 连接 MQTT 服务器
            client.connect(connOpts);

            // 订阅主题
            for (String topic : topics) {
                client.subscribe(topic);
            }
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    // 回调函数：连接成功
    @Override
    public void connectionLost(Throwable cause) {
        System.out.println("Connection lost, trying to reconnect...");

        // 重新连接 MQTT 服务器
        try {
            client.connect();
            for (String topic : topics) {
                client.subscribe(topic);
            }
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    // 回调函数：收到消息
    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        System.out.println("Message received: " + new String(message.getPayload()));
    }

    // 回调函数：消息发送完成
    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        System.out.println("Message delivered.");
    }

    // 主函数
    public static void main(String[] args) {
        MqttClientExample example = new MqttClientExample();

        // 循环监听消息
        while (true) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在上述代码中，我们首先定义了连接参数、订阅主题等信息。然后创建一个 MQTT 客户端，并设置连接参数和回调函数。在连接 MQTT 服务器时，我们使用 try-catch 块来捕获连接异常，以便在连接失败时进行处理。

在连接成功后，我们通过回调函数 connectionLost 来处理连接异常。在 connectionLost 回调函数中，我们重新连接 MQTT 服务器，并重新订阅主题。在 messageArrived 回调函数中处理收到的消息。最后，我们使用一个无限循环来循环监听消息。

如果连接异常或断开后，Eclipse Paho MQTT 库会自动进行重连，并且调用 connectionLost 回调函数重新订阅主题。通过这种方式，我们可以在 MQTT 连接异常或断开后自动重新连接，并订阅原先订阅的主题。