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

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

import paho.mqtt.client as mqtt

# 连接参数
broker_address = "mqtt_server_ip"
client_id = "client1"
username = "mqtt_username"
password = "mqtt_password"
topics = [("topic1", 0), ("topic2", 1)]

# 定义回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    # 订阅主题
    for topic in topics:
        client.subscribe(topic[0], topic[1])

def on_message(client, userdata, msg):
    # 处理收到的消息
    print(msg.topic + " " + str(msg.payload))

# 创建 MQTT 客户端
client = mqtt.Client(client_id)

# 设置连接参数
client.username_pw_set(username=username, password=password)
client.on_connect = on_connect
client.on_message = on_message

# 连接 MQTT 服务器
try:
    client.connect(broker_address, keepalive=60)
except Exception as e:
    print("Error connecting to MQTT broker: " + str(e))

# 循环监听消息
client.loop_forever()

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

在连接成功后，我们通过回调函数 on_connect 来订阅主题。在 on_message 回调函数中处理收到的消息。最后，我们使用 client.loop_forever() 方法来循环监听消息。

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