Mosquitto 订阅者收到额外消息

Question

我正在探索 mosquitto 作为一个完整的初学者。我有一个 golang 测试程序，我正在使用它来查看它是如何管理消息的，但是该程序的后续运行显示收到了额外的消息。import (    mqtt "github.com/eclipse/paho.mqtt.golang"    log "github.com/sirupsen/logrus"    "strconv"    "time")var sent intvar received intfunc Test() {    sent  = 0    received = 0    const TOPIC = "mytopic/test"    opts := mqtt.NewClientOptions().AddBroker("tcp://localhost:1883").SetClientID("client1").SetResumeSubs(false).SetAutoReconnect(false).SetCleanSession(true)    client1 := mqtt.NewClient(opts)    if token := client1.Connect(); token.Wait() && token.Error() != nil {        panic(token.Error())    }    if token := client1.Subscribe(TOPIC, 2, receiver1); token.Wait() && token.Error() != nil {        panic(token.Error())    }    defer howManySent()    defer howManyReceived()    defer client1.Disconnect(1)    for index:=0;index<3;index++ {        sendMsg := "client1 message " + strconv.Itoa(index)        if token := client1.Publish(TOPIC, 2, true, sendMsg); token.Wait() && token.Error() != nil {            panic(token.Error())        } else {            sent++        }        time.Sleep(1 * time.Second)    }    time.Sleep(1*time.Second)}func howManyReceived() {    log.Warn("RECEIVED:", received)}func howManySent() {    log.Warn("SENT:", sent)}func receiver1(client mqtt.Client, msg mqtt.Message) {    received++    msg.Ack()    output := "message id:" + strconv.Itoa(int(msg.MessageID())) + " message = " + string(msg.Payload())    log.Warn(output)}第一次运行的输出：WARN[0000] message id:1 message = client1 message 0     WARN[0001] message id:2 message = client1 message 1     WARN[0002] message id:3 message = client1 message 2     WARN[0004] RECEIVED:3                                   WARN[0004] SENT:3      我究竟做错了什么？

Answer 1

发布定义如下：

Publish(topic string, qos byte, retained bool, payload interface{}) Token

因此，当您打电话时，token := client1.Publish(TOPIC, 2, true, sendMsg)您正在发布一条retained设置为 true 的消息。Retain是与消息一起传递给代理的标志，它意味着：

如果 RETAIN 标志设置为 1，则在客户端发送给服务器的 PUBLISH 数据包中，服务器必须存储应用程序消息及其 QoS，以便可以将其传递给订阅匹配其主题名称的未来订阅者 [MQTT- 3.3.1-5]。建立新订阅时，必须将每个匹配主题名称上的最后保留消息（如果有）发送给订阅者 [MQTT-3.3.1-6]。

每条带有retainset 的新消息都会替换任何以前的消息，因此当您的第一次执行完成时，消息2会被保留。这会在客户端重新连接时发送给客户端（意味着您看到的结果是预期的）。如果您更改对它的调用，token := client1.Publish(TOPIC, 2, false, sendMsg)它将按您预期的方式运行。

mosquitto 文档对标志说如下persistence：

如果为 true，则连接、订阅和消息数据将写入 mosquitto.db 中由 persistence_location 指定的位置的磁盘。当 mosquitto 重启时，它会重新加载 mosquitto.db 中存储的信息

所以这只有在你重启 Mosquitto 时才会产生影响；即使此标志设置为 ，会话信息仍将存储在内存中false。