server/clienter.go
@@ -1,10 +1,9 @@ package server import ( "basic.com/valib/logger.git" "basic.com/valib/go-aiot.git/aiotProto/aiot" "basic.com/valib/go-aiot.git/client" "errors" "go-aiot/aiotProto/aiot" "go-aiot/client" "go.uber.org/zap" ) @@ -19,7 +18,7 @@ // 错误信息 errMsg := "Cluster have not registered" // 记录日志 logger.Error(errMsg, zap.Any("msg", msg)) cli.Logger.Error(errMsg, zap.Any("msg", msg)) cli.Close() // 移除集群 Srv.RemoveCluster(msg.SenderId)