NodeJS使用mqtt模块订阅#通配符所有MQTT主题失效问题问询

你的代码实现逻辑本身符合MQTT.js的使用规范，指定主题订阅功能正常就能说明整体流程没有问题，#订阅失效是外部限制导致的：

• 公共Broker限制：你使用的HiveMQ公共节点为了避免资源滥用，默认拦截#全主题订阅请求。全主题订阅会导致Broker将所有节点流量同步到你的客户端，会极大占用公共服务的带宽、算力资源，几乎所有公开MQTT Broker都会做这个限制。你可以查看subscribe回调的granted参数，如果返回空、或者对应条目的qos为0x80（订阅失败码），就可以确认是Broker主动拒绝了你的订阅请求。
• MQTT协议规则限制：根据MQTT标准规范，#通配符不匹配$开头的主题，比如Broker的系统主题$SYS/xxx这类，需要单独订阅$SYS/#才能接收。

1. 缩小通配符订阅范围
   如果你的业务消息都有统一的前缀，比如mytopic/开头，改为订阅mytopic/#即可，公共节点一般不会拦截这种有明确范围的通配符订阅，也能满足你接收同前缀下所有主题消息的需求。
   示例修改代码：

client = mqtt.connect(broker,options)
client.on('connect',()=>{
    console.log("MQTT Connected")
    // 订阅自己业务前缀下的所有主题，不会被公共Broker拦截
    client.subscribe('mytopic/#',(err,granted)=>{
        if(err){
            console.log(err)
        }
        console.log(granted)
        console.log("Subscribed to all business topics")
    })
    listenIncoming()
})
client.on('error',err=>{
    console.log("ERROR in MQTT: ",err)
})

2. 使用私有MQTT Broker
   自己部署Mosquitto、EMQX等开源MQTT Broker，私有环境没有订阅限制，可以正常使用#订阅全主题。
3. 额外订阅系统主题
   如果你需要接收$开头的系统主题，在订阅普通通配符之外额外增加$SYS/#的订阅即可。

你原来代码里的console.log("MQTT Connected")位置有误，mqtt.connect是异步操作，该日志打印的时候连接其实还没建立，建议移动到connect事件回调内部，避免误导排查方向。

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