如何在单个 MQTT 客户端中高效订阅多个主题并保持长期连接-Python教程-PHP中文网

如何在单个 MQTT 客户端中高效订阅多个主题并保持长期连接

本文详解如何使用 paho mqtt python 客户端正确实现多主题订阅，避免重复连接与线程滥用，通过 loop_start() 启动后台网络循环，并推荐单客户端多主题的规范实践。

本文详解如何使用 paho mqtt python 客户端正确实现多主题订阅，避免重复连接与线程滥用，通过 loop_start() 启动后台网络循环，并推荐单客户端多主题的规范实践。

MQTT 协议设计初衷即支持“一对多”消息分发，一个客户端完全可同时订阅多个主题（如 "sensors/humidity" 和 "sensors/temperature"），无需为每个主题创建独立客户端或线程。原代码的核心问题在于：

未启动网络事件循环：client.loop_forever() 被作为线程目标调用，但该方法会阻塞当前线程；而更关键的是，connect_mqtt() 在循环内反复调用，导致同一 client_id 频繁重连（MQTT Broker 会踢掉旧连接），形成恶性循环；
资源冗余：为每个 topic 创建新 client 实例，浪费 socket 连接、内存及 Broker 订阅槽位；
逻辑错位：on_message 回调被重复赋值，后注册的会覆盖前一个，实际仅最后一个 topic 的消息能被处理。

✅ 正确做法是：复用单个 MQTT 客户端，一次性订阅全部主题，并启用非阻塞后台循环。以下是优化后的完整示例：

import random
from paho.mqtt import client as mqtt_client

broker = '172.18.0.3'
port = 1885
topics = ["sensors/humidity", "sensors/temperature"]

def connect_mqtt() -> mqtt_client:
    client_id = f'subscribe-{random.randint(0, 10000)}'  # 避免 ID 冲突，但通常建议固定或按用途命名
    client = mqtt_client.Client(client_id)

    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("✅ Connected to MQTT Broker!")
            # 在成功连接后批量订阅所有主题
            client.subscribe([(topic, 0) for topic in topics])  # QoS 0
        else:
            print(f"❌ Failed to connect, return code {rc}")

    def on_message(client, userdata, msg):
        print(f"? Received `{msg.payload.decode()}` from `{msg.topic}`")

    client.on_connect = on_connect
    client.on_message = on_message
    client.connect(broker, port)

    # ✅ 关键：启动后台网络循环（非阻塞）
    client.loop_start()
    return client

def run():
    client = connect_mqtt()
    # 主线程保持活跃，防止程序退出
    try:
        input("? Press Enter to exit...\n")
    except KeyboardInterrupt:
        pass
    finally:
        client.disconnect()
        client.loop_stop()
        print("? MQTT client stopped.")

if __name__ == '__main__':
    run()

? 关键改进说明：