使用paho.mqtt.golang订阅多MQTT主题时仅最后Handler生效问题

我之前也碰到过类似的坑，结合你的代码和描述来看，这大概率是异步订阅操作未正确等待或者订阅顺序引发的Handler覆盖问题，下面一步步帮你分析和解决：

问题根源拆解 #

1. 异步订阅没等完成就执行下一次：你调用client.Subscribe()后直接跑下一个订阅，没等待返回的token完成。Subscribe是异步操作，前一次订阅还没在Broker端生效，后一次订阅就可能干扰它的注册流程，导致订阅关系乱掉。
2. 层级主题订阅顺序的意外交互：像P1/#（通配符）和P1/controller/registration（具体主题）这种有层级的主题，理论上更具体的主题应该优先匹配，但如果前一次订阅还没完成就执行后一次，可能出现通配符的Handler被后续订阅覆盖的情况，结果所有消息都触发最后注册的Handler。
3. 主题大小写敏感问题：MQTT主题是严格区分大小写的！如果你发的是p1/test（小写），但订阅的是P1/#（大写），这俩主题根本不匹配，本该触发默认Handler，但你说触发了registrationHandler，要么是描述时大小写写错了，要么是Broker配置了非标准的大小写不敏感。

具体解决方案 #

1. 每个订阅都要等完成+检查错误 #

每次订阅后一定要等待token完成，确保订阅在Broker端正确生效，同时检查错误避免静默失败：

func main() {
    var opts = MQTT.NewClientOptions()
    opts.AddBroker(address)
    opts.SetClientID("go-controller")
    opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {
        log.Printf("Default handler - topic: %s\n", msg.Topic())
    })

    client := MQTT.NewClient(opts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        log.Panicln(token.Error())
    }
    defer client.Disconnect(250)

    // 订阅P1/#并等待完成
    token := client.Subscribe("P1/#", 0, logHandler)
    token.Wait()
    if token.Error() != nil {
        log.Fatalf("订阅P1/#失败: %v", token.Error())
    }

    // 订阅具体主题并等待完成
    token = client.Subscribe("P1/controller/registration", 0, registrationHandler)
    token.Wait()
    if token.Error() != nil {
        log.Fatalf("订阅P1/controller/registration失败: %v", token.Error())
    }

    // 保持客户端运行，比如阻塞等待
    select {}
}

2. 单次调用批量订阅多个主题（更推荐） #

用SubscribeMultiple方法一次订阅所有主题，明确绑定每个主题的Handler，从根源避免异步顺序问题：

func main() {
    var opts = MQTT.NewClientOptions()
    opts.AddBroker(address)
    opts.SetClientID("go-controller")
    opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {
        log.Printf("Default handler - topic: %s\n", msg.Topic())
    })

    client := MQTT.NewClient(opts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        log.Panicln(token.Error())
    }
    defer client.Disconnect(250)

    // 定义主题与Handler的映射
    topicMap := map[string]MQTT.MessageHandler{
        "P1/#":                      logHandler,
        "P1/controller/registration": registrationHandler,
    }

    // 单次订阅所有主题
    token := client.SubscribeMultiple(topicMap, 0)
    token.Wait()
    if token.Error() != nil {
        log.Fatalf("批量订阅失败: %v", token.Error())
    }

    select {}
}

3. 统一主题大小写 #

确保发送的主题和订阅的主题大小写完全一致，比如都改成小写：

// 修改订阅主题为小写
client.Subscribe("p1/#", 0, logHandler)
client.Subscribe("p1/controller/registration", 0, registrationHandler)

发送消息时主题也用p1/test，这样才能正确匹配。

为什么交换订阅顺序会生效？ #

当你先订阅具体主题，再订阅通配符时，具体主题的订阅先完成并正确注册，后续的通配符订阅不会覆盖它——库会自动优先匹配更具体的主题。而原来的顺序中，通配符订阅还没在Broker端生效，就执行了具体主题的订阅，导致通配符的Handler被意外覆盖，所有匹配通配符的消息都触发了最后注册的Handler。

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