MQTT客户端订阅主题后无法接收消息，求排查思路

问题背景 #

发送端可成功发布MQTT消息，且消息能被对应主题的队列接收，但自定义实现的订阅端虽显示订阅成功，却始终收不到消息。同一容器内使用subscribe.callback方法可正常接收，自定义类实现失效。

核心排查点与解决建议 #

1. 空Client ID导致会话冲突 #

从日志可见客户端使用空Client ID（client_id=b''）：

DEBUG:root:log| client: <paho.mqtt.client.Client object at 0x7f2f26b28050>, userdata: None, level: 16, buf: Sending CONNECT (u0, p0, wr0, wq0, wf0, c1, k60) client_id=b''

MQTT Broker对空Client ID会自动分配临时ID，但多个客户端使用空ID可能引发会话覆盖或消息路由异常。而subscribe.callback会自动生成唯一Client ID，这是它能正常工作的关键原因之一。

解决：为每个客户端设置唯一Client ID，修改__init__方法：

def __init__(self, host: str):
    self.host = host
    # 生成唯一Client ID，用host区分不同仓库实例
    client_id = f"warehouse-sub-{host.replace('.', '-')}"
    self.client = mqtt.Client(client_id=client_id)

2. 客户端对象被垃圾回收 #

在subscribe_all方法中，client是局部变量，主线程循环结束后，对象可能被Python垃圾回收器回收，导致回调函数失效（即使线程内loop_forever处于阻塞状态）。

解决：在类中保存客户端实例的引用，防止被回收：

class MQTTSub:
    # 新增类属性保存活跃客户端实例
    active_clients = []
    
    class MQTTClient:
        # ... 原有代码保持不变 ...
    
    @staticmethod
    def subscribe_all():
        with open(os.path.join(settings.BASE_DIR, "warehouses.json")) as warehouses_file:
            warehouses = json.load(warehouses_file)
            for warehouse in warehouses:
                logging.debug(f"warehouse: {warehouse}")
                client = MQTTSub.MQTTClient(warehouse['host'])
                # 将客户端实例加入类列表，保留引用避免被GC回收
                MQTTSub.active_clients.append(client)
                threading.Thread(target=client.connect).start()

3. 回调上下文有效性验证 #

虽然代码中已绑定回调函数，但需确认self（MQTTClient实例）在线程运行期间始终有效。上述保存客户端引用的操作可间接解决此问题，确保回调函数的上下文不被销毁。

4. QoS匹配性检查 #

确认发送端的消息QoS与订阅端请求的QoS（2）兼容。Broker会取两端QoS的最小值进行消息传递，若发送端使用QoS 0仍能正常接收，但可检查发送端日志确认QoS设置是否正确。

5. 主题编码一致性验证 #

日志中订阅主题为字节形式（b'/warehouse'），确认发送端发布的主题是相同的字符串或字节编码（MQTT Broker通常会统一处理，但极端情况下可能存在编码差异）。

验证步骤 #

1. 修改Client ID后重启订阅端，观察日志中是否出现唯一的client_id。
2. 确认active_clients列表保留了客户端实例，避免被回收。
3. 重新发送消息，检查on_message回调是否触发并打印日志。

内容的提问来源于stack exchange，提问作者SamHuffman