mqtt断开重连死循环

以下是一个演示mqtt断开重连死循环的示例代码：

import time
import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    client.subscribe("topic/test")

def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))

def on_disconnect(client, userdata, rc):
    print("Disconnected from MQTT broker. Trying to reconnect...")
    while True:
        try:
            client.reconnect()
            break
        except:
            print("Reconnection failed. Retrying in 5 seconds...")
            time.sleep(5)

client = mqtt.Client(client_id="unique_client_id")
client.on_connect = on_connect
client.on_message = on_message
client.on_disconnect = on_disconnect

client.connect("mqtt_broker_address", 1883, 60)

client.loop_forever()

在上述代码中，我们使用了paho-mqtt库来创建一个mqtt客户端。当客户端连接成功后，我们订阅了一个名为"topic/test"的主题。当收到消息时，会调用on_message函数进行处理。如果客户端与mqtt broker断开连接，会调用on_disconnect函数进行重连。

请注意，为了避免mqtt断开重连的死循环，我们在on_disconnect函数中使用了一个无限循环来尝试重连。如果重连失败，会等待5秒后再次尝试。