在单个计算机上使用Eclipse Paho MQTT Golang作为独立进程，当发布/订阅AWS IoT时遇到EOF错误

在使用 Eclipse Paho MQTT Golang 库连接 AWS IoT 时，如果在单个计算机上以独立进程运行发布和订阅代码，可能会遇到 EOF 错误。这是因为在同时向 AWS IoT/MQTT 打开两个连接时使用了相同的客户端 ID。根据 MQTT 规范，每个连接必须使用唯一的客户端 ID。为发布和订阅代码使用不同的客户端 ID 可以解决此问题，并且需要在 AWS IoT 策略中允许每个客户端 ID 进行连接。

我在 linux 上使用 go v1.17.2，通过 paho.mqtt.golang 库 v1.4.1 连接到 aws mqtt。我的代码基于 emqx 中的此示例，使用 tls 和 aws iot core 提供的证书。

当我按照 emqx 的上述示例在相同 go 程序中运行发布和订阅代码时，一切正常，我可以看到以下输出：

2022/08/11 19:47:42 connected
subscribed to topic: topic_1
2022/08/12 13:47:42 received message: message 0 from topic: topic_1
2022/08/11 19:47:43 received message: message 1 from topic: topic_1
...
2022/08/11 19:47:51 received message: message 9 from topic: topic_1

但是，如果我在一个 go 程序中运行发布代码（使用 go run），并同时在同一台机器上的单独程序中运行订阅，那么每条消息的订阅都会失败，并出现 eof 错误：

2022/08/11 19:54:50 connected
2022/08/11 19:54:54 connect lost: eof
...
2022/08/11 19:54:59 connected
2022/08/11 19:54:59 connect lost: eof

这是发布代码

client := mqtt.newclient(opts)
if token := client.connect(); token.wait() && token.error() != nil {
    log.fatalln(token.error())
}

publish(client, *topic)
client.disconnect(250)
...

func publish(client mqtt.client, topic string) {
    num := 10
    for i := 0; i < num; i++ {
       text := fmt.sprintf("message %d", i)
       token := client.publish(topic, 0, false, text)
       token.wait()
       time.sleep(time.second)
    }
}

和订阅代码

client := mqtt.newclient(opts)
if token := client.connect(); token.wait() && token.error() != nil {
   log.fatalln(token.error())
}

sub(client, *topic)
time.sleep(11 * time.second)
client.disconnect(250)

...

func sub(client mqtt.client, topic string) {
    token := client.subscribe(topic, 1, nil)
    token.wait()
    log.printf("subscribed to topic: %s", topic)
}

如果我仅运行订阅代码，并使用 aws iot 控制台发布一些也有效的消息

2022/08/11 20:25:27 connected
2022/08/11 20:25:27 subscribed to topic: topic_1
2022/08/11 20:25:29 received message: {
  "message": "hello from aws iot console"
} from topic: topic_1
2022/08/11 20:25:30 received message: {
  "message": "hello from aws iot console"
} from topic: topic_1

问题似乎与同时向 aws iot/mqtt 打开两个连接有关。

这是我的 mqtt 客户端选项配置

opts := mqtt.NewClientOptions()
opts.AddBroker(fmt.Sprintf("tls://%s:%d", *host, 8883))
opts.SetClientID("basicPubSub")
opts.SetTLSConfig(tlsConfig)
opts.SetDefaultPublishHandler(messagePubHandler)
opts.OnConnect = connectHandler
opts.OnConnectionLost = connectLostHandler

正确答案

这是因为我在发布和订阅代码中使用了相同的客户端 ID。

Eclipse Paho 文档通过 MQTT specifications 的链接解释了这一点

我为每个程序使用了不同的客户端 ID，并且它有效。 注意：AWS IOT 策略必须允许每个客户端 ID 进行连接（允许 iot:Connectt 操作）

今天关于《在单个计算机上使用Eclipse Paho MQTT Golang作为独立进程，当发布/订阅AWS IoT时遇到EOF错误》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！