MQTT订阅队列未被清除

要解决"MQTT订阅队列未被清除"的问题，可以使用以下代码示例：

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 在连接成功后订阅主题
    client.subscribe("topic")

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

def on_disconnect(client, userdata, rc):
    if rc != 0:
        print("Unexpected disconnection.")

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

# 设置连接回调函数
client.on_connect = on_connect
# 设置消息接收回调函数
client.on_message = on_message
# 设置断开连接回调函数
client.on_disconnect = on_disconnect

# 连接到MQTT代理服务器
client.connect("mqtt.example.com", 1883, 60)

# 开启循环，保持与MQTT代理服务器的连接
client.loop_forever()

在上述代码中，on_connect函数用于在连接成功后订阅主题。on_message函数用于处理接收到的消息。on_disconnect函数用于处理意外断开连接的情况。

通过使用client.loop_forever()来开启一个无限循环，使得客户端保持与MQTT代理服务器的连接。这样，即使订阅队列未被清除，客户端也能持续接收到消息。

请注意，您需要根据实际情况修改代码中的MQTT代理服务器的地址和端口号。