当前位置：首页 > 文章列表 > Golang > Go问答 > 在单个计算机上使用Eclipse Paho MQTT Golang作为独立进程，当发布/订阅AWS IoT时遇到EOF错误

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

来源：stackoverflow 2024-03-17 22:09:29 0浏览收藏

在使用 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