更改订阅主题时应注意的事项

在更改 MQTT 订阅主题时，需要考虑以下注意事项： * **管理客户端连接：** 当主题更改时，需要断开原有主题的连接，并重新连接到新主题，以确保正确接收消息。 * **主题订阅和退订：** 更改主题时，需要先退订旧主题，再订阅新主题，以避免消息重叠或丢失。 * **消息处理程序：** 需要更新消息处理程序以处理新主题接收到的消息。 * **连接状态：** 更改主题时需要考虑客户端连接状态，确保连接保持活跃并在新主题上接收消息。

我有一个订阅主题 "info" 的 mqtt go 程序，我在其中收到一条 json 消息。我验证该 json 消息，如果验证成功，我想开始订阅新主题 "info_updates"。这是我的订阅代码：

func info(){
    c := make(chan os.signal, 1)
    signal.notify(c, os.interrupt, syscall.sigterm)

    opts := mqtt.newclientoptions().addbroker("tcp://test.mosquitto.org:1883")

    opts.setdefaultpublishhandler(f)
    topic := "info" //i want to be able to change this later to "info_updates"

    opts.onconnect = func(c mqtt.client) {
        if token := c.subscribe(topic, 0, f); token.wait() && token.error() != nil {
            panic(token.error())
        }
    }
    // creating new client
    client := mqtt.newclient(opts)
    if token := client.connect(); token.wait() && token.error() != nil {
        panic(token.error())
    } else {
        fmt.printf("connected to server\n")
    }
    <-c

}

这是我验证 json（部分）的代码：

var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {
var integrationResult string

        if JSONValidate(msg.Payload())[0] == ""{ //sanity check = successful
         integrationResult = "successful"
        }else{ //sanity check = unsuccessful
        integrationResult = "unsuccessful"
        }

//do something here to tell the first function to change subscribing topic if integrationResult = "successful"

}

注意： func info() 和 mqtt.messagehandler 位于两个单独的文件中。我对如何与 func info() 进行通信以更改主题订阅感到困惑。谢谢。

解决方案

在我的 message.handler 中，我这样做：

if integrationResult == "unsuccessful"{
        client.Subscribe("data_update/" + deviceID, 0, g)
    }

其中 g 是一个新的 message.handler。使用这种方法，我不确定第一个连接（订阅info）是否已断开，或者两个连接是否都打开。但是，如果您只是想从新主题获取消息，这是一个很好的方法。

终于介绍完啦！小伙伴们，这篇关于《更改订阅主题时应注意的事项》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！