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

Question

当我只是运行一个程序来测试与 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.Payload(), 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...

Answer 1

根据评论，MQTT spec 要求：

If the ClientId represents a Client already connected to the Server then the Server MUST disconnect the existing Client [MQTT-3.1.4-2].

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

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

EMQX Demo code uses the ClientID go_mqtt_client; this means that there is a good chance that someone else is using the EMQX public broker with the same ID; in fact this is mentioned in a comment (from the "EMQ X" account) at the bottom of the page with the demo code.

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

您已连接；导致用户 2（具有相同 ClientId）的连接被删除）
用户 2 自动重新连接导致您的连接断开。
您自动重新连接导致用户 2 的连接中断。
等...

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

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

why the mqtt client reconnect broker with an unique clientId?

go

mqtt

paho