diff --git a/dbOperate/mqttHelper.go b/dbOperate/mqttHelper.go index c720995..d298ca0 100644 --- a/dbOperate/mqttHelper.go +++ b/dbOperate/mqttHelper.go @@ -43,8 +43,7 @@ reConn: opts.SetUsername(the.UserName) opts.SetPassword(the.Password) opts.SetClientID(the.ClientId) - opts.SetCleanSession(false) // 通常需要关闭 CleanSession - opts.SetResumeSubs(true) // 启用 ResumeSubs + opts.SetCleanSession(true) // 通常需要关闭 CleanSession opts.SetOnConnectHandler(the.reConn2Subscribe) opts.SetMaxReconnectInterval(10 * time.Second) if sslEnable {