如何使用paho.mqtt.golang库订阅多个MQTT主题？

Question

我试图连接到运行在外部服务器上的MQTT代理，在那里我需要处理多个不同的主题。问题是，即使主题与作为参数传递给方法的主题不匹配，也只有最后一个订阅处理程序被称为。

示例:向p1/test发送任何内容的将触发registrationHandler，该registrationHandler只应侦听“P1/控制器/注册”。其他处理程序或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

我发现订阅主题很重要。当我交换两个订阅调用时，将调用正确的处理程序。

Answer 1

对于paho.mqtt.python实现，一个客户端可以订阅多个订阅，一个调用在数组中进行，如下所示

client.subscribe([("P1/#", 0),("P1/controller/registration", 0)])

它对数组中项的顺序不敏感。这与“golang”语言的实现无关，但我将其留在这里以供参考。