为什么 mqtt 客户端使用唯一的 clientId 重新连接代理？

如何解决为什么 mqtt 客户端使用唯一的 clientId 重新连接代理？

当我只是运行一个程序来测试与 mqtt 代理的连接时，客户端总是会丢失。 这是我的代码

var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client,msg mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s\n",msg.Payload(),msg.Topic())
}

var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
    fmt.Println("Connected")
}

var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client,err error) {
    fmt.Printf("Connect lost: %v\n",err)
}

var messageSubHandler mqtt.MessageHandler = func(client mqtt.Client,msg mqtt.Message) {
    fmt.Printf("Sub message: %s from topic: %s\n",msg.Topic())
}

func main() {
    opts := mqtt.NewClientOptions()
    opts.AddBroker("tcp://broker.emqx.io:1883")
    opts.SetClientID("go_mqtt_client")
    opts.SetResumeSubs(true)
    opts.SetAutoReconnect(true)
    opts.SetOrderMatters(false)
    opts.SetCleanSession(false)
    // opts.SetTLSConfig()
    opts.SetDefaultPublishHandler(messagePubHandler)
    opts.OnConnect = connectHandler
    opts.OnConnectionLost = connectLostHandler
    client := mqtt.NewClient(opts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    sub(client)

    s := make(chan os.Signal,1)
    signal.Notify(s,syscall.SIGINT,syscall.SIGTERM,syscall.SIGKILL)
    select {
    case <-s:
        glog.Infoln(`quit`)
        glog.Flush()
    }
}

func sub(client mqtt.Client) {
    topic := "topic/test"
    token := client.Subscribe(topic,2,messageSubHandler)
    token.Wait()
    fmt.Printf("Subscribed to topic: %s\n",topic)
}

结果是

$ go run cmd/client/client.go 
Connected
Subscribed to topic: topic/test
Connect lost: EOF
Connected
Connect lost: EOF
Connected
...

我知道这是因为 clientId。但是现在我只是运行了一个叫go_mqtt_client的客户端，不知道是不是配置的原因。我遇到过两次这个问题。第一次我不记得发生了什么变化，它可以工作。但是第二次（现在），我无法修复它。 It just can work if I change the ClientId...

解决方法

根据评论，MQTT spec 要求：

如果 ClientId 代表已经连接到服务器的客户端，那么服务器必须断开现有的客户端 [MQTT-3.1.4-2]。

因此，如果您有一个使用 ClientId go_mqtt_client 的连接，而另一个连接使用相同的 ClientId，您的连接将被丢弃（导致您看到消息）。

您使用的代理 (broker.emqx.io) 是一个 free,public broker，带有“切勿在生产中使用它”的建议。由于其性质，您无法知道还有谁在使用它或他们正在使用什么 ClientId（如果您订阅 #，您将看到所有消息都发布到代理！）。

EMQX Demo code 使用 ClientID go_mqtt_client；这意味着很有可能其他人正在使用具有相同 ID 的 EMQX 公共经纪商；事实上，page with the demo code 底部的评论（来自“EMQ X”帐户）中提到了这一点。

鉴于演示代码使用默认选项，如果连接断开，它将自动重新连接。这意味着您会得到一系列事件，例如：

1. 你连接；导致用户 2（具有相同 ClientId）的连接被丢弃）
2. 用户 2 自动重新连接，导致您的连接中断。
3. 您自动重新连接导致用户 2 的连接中断。
4. 等等...

虽然无法 100% 确定这是您所看到的问题的原因，但它肯定是最有可能的原因。由于这是一个免费提供的公共经纪人，这正是您需要忍受的；使用随机 ClientId 将最大限度地减少（与随机 23 个字符 ID 冲突的风险很小）发生这种情况的机会。