为何Python Paho MQTT订阅RabbitMQ保留消息时通配符主题无效？

云上老周

2026-8-20

通配符订阅无法接收保留消息的原因及解决方法

针对你在RabbitMQ下使用test/data/#通配符订阅收不到保留消息，但具体主题test/data/user1可以正常接收的问题，主要有以下几个排查方向和解决办法：

权限配置限制
RabbitMQ的MQTT权限是基于主题粒度管控的，如果仅给当前用户配置了test/data/user1的订阅权限，使用test/data/#通配符订阅会被Broker拒绝。需要在RabbitMQ管理后台给用户添加test/data/#的订阅权限：权限类型选择subscribe，主题模式填写test/data/#。
持久化会话未开启
RabbitMQ的MQTT插件默认不会给clean_session=True的客户端推送通配符匹配的历史保留消息。你的代码中使用的是默认的clean_session=True，Broker不会存储客户端的订阅关系，也不会在连接时主动推送通配符覆盖的保留消息。修改客户端创建逻辑，开启持久化会话：
```
client = mqtt_client.Client(client_id, clean_session=False)
```

订阅时机不合理
当前代码先执行connect再调用subscribe，若连接过程存在延迟，可能导致订阅未正确注册到Broker。建议将订阅逻辑移到on_connect回调中，确保连接成功后再执行订阅：

def connect_mqtt() -> mqtt_client:
    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("Connected to MQTT Broker!")
            # 连接成功后立即执行订阅
            client.subscribe(topic)
        else:
            print("Failed to connect, return code %d\n", rc)

    client = mqtt_client.Client(client_id, clean_session=False)
    client.username_pw_set(**auth)
    client.on_connect = on_connect
    client.connect(host, port)
    return client

同时移除subscribe函数中的client.subscribe(topic)调用，避免重复订阅。