我尝试连接到在外部服务器上运行的 MQTT 代理,我需要在其中处理多个不同的主题。问题是,只有最后一个订阅的处理程序被调用,即使主题与作为参数传递给 Subscribe()
方法的主题不匹配也是如此。
示例:
向 p1/test
发送任何内容都会触发 registrationHandler,它只应监听“P1/controller/registration”。其他处理程序或 DefaultPublishHandler 永远不会被调用。
我的程序的简化版本:
func main(){
var opts = MQTT.NewClientOptions()
opts.AddBroker(address)
opts.SetClientID("go-controller")
opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {
log.Printf("topic: %s\n", msg.Topic())
})
client = MQTT.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
log.Panicln(token.Error())
}
client.Subscribe("P1/#", 0, logHandler)
client.Subscribe("P1/controller/registration", 0, registrationHandler)
}
var logHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {
...
log.Printf("Topic %s logged...\n", msg.Topic())
}
var registrationHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {
...
log.Printf("Topic %s registered...\n", message.Value)
}
编辑#1
我发现订阅主题的顺序很重要。当我交换两个订阅调用时,将调用正确的处理程序。
最佳答案
对于 paho.mqtt.python 实现,一个客户端可以像这样在一个数组中一次调用订阅多个订阅
client.subscribe([("P1/#", 0),("P1/controller/registration", 0)])
它对数组中项目的顺序不敏感。这与“golang”语言实现无关,但我将其留在这里以供引用。
关于go - 如何使用 paho.mqtt.golang 库订阅多个 MQTT 主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50469066/