Golang MQTT 断线重连实现指南

在使用 Golang 进行 MQTT 通信时，断线重连可以通过以下方式实现：

创建一个 MQTT 客户端实例，并设置断线重连的参数，如最大重试次数、重试间隔时间等。

opts := MQTT.NewClientOptions()
opts.AddBroker('tcp://localhost:1883')
opts.SetClientID('mqtt-client')
opts.SetAutoReconnect(true)
opts.SetMaxReconnectInterval(10 * time.Second)
opts.SetConnectionLostHandler(func(client MQTT.Client, err error) {
    fmt.Printf('Connection lost: %v\n', err)
    // 进行断线重连操作
})
client := MQTT.NewClient(opts)

在连接 MQTT 服务器时，调用 Connect() 方法，并在连接成功后设置订阅的主题。

token := client.Connect()
if token.Wait() && token.Error() != nil {
    panic(token.Error())
}
// 设置订阅主题
token = client.Subscribe('test/topic', 0, nil)
if token.Wait() && token.Error() != nil {
    panic(token.Error())
}

在 SetConnectionLostHandler() 回调函数中进行断线重连操作，可以使用循环来实现多次重连尝试，直到连接成功为止。

opts.SetConnectionLostHandler(func(client MQTT.Client, err error) {
    fmt.Printf('Connection lost: %v\n', err)
    for i := 0; i < maxRetry; i++ {
        token := client.Connect()
        if token.Wait() && token.Error() == nil {
            fmt.Println('Reconnected to mqtt broker')
            // 重新订阅主题
            token = client.Subscribe('test/topic', 0, nil)
            if token.Wait() && token.Error() == nil {
                break
            }
        }
        time.Sleep(retryInterval)
    }
})

在程序退出时，调用 Disconnect() 方法来关闭 MQTT 连接。

client.Disconnect(250)