打印日志

pkg/logx/logx.go

@@ -36,7 +36,7 @@ func NewLogger() {
 		Compress:   compress,   // 是否压缩旧日志文件
 	})
 
-	multiWriteSyncer := zapcore.NewMultiWriteSyncer(zapcore.AddSync(os.Stdout), lumberjack)
+	multiWriteSyncer := zapcore.NewMultiWriteSyncer(zapcore.AddSync(os.Stdout), zapcore.AddSync(lumberjack))
 	core := zapcore.NewCore(encoder, multiWriteSyncer, zap.NewAtomicLevelAt(zap.InfoLevel))
 	zap.ReplaceGlobals(zap.New(core))
 }

server/client.go

@@ -175,8 +175,9 @@ func (c *Client) reader() {
 					// ERROR
 					c.ReplySend <- newErrorMessage(message.RequestId(), err)
 				}
+
+				zap.L().Info("[conn] 收到消息 - 语聊", zap.Any("msg", chating), zap.String("user_id", c.UserId))
 			}
-			zap.L().Info("received", zap.Any("message", message))
 
 		case MessageTypeNotification: