diff --git a/internal/api/a2r/api2rpc.go b/internal/api/a2r/api2rpc.go index 70119d85d..33f69f7ac 100644 --- a/internal/api/a2r/api2rpc.go +++ b/internal/api/a2r/api2rpc.go @@ -2,7 +2,6 @@ package a2r import ( "OpenIM/internal/apiresp" - "OpenIM/pkg/common/log" "OpenIM/pkg/errs" "context" "github.com/gin-gonic/gin" @@ -27,13 +26,11 @@ func Call[A, B, C any]( } cli, err := client() if err != nil { - log.ZError(c, "get rpc client conn failed", err) apiresp.GinError(c, errs.ErrInternalServer.Wrap(err.Error())) // 获取RPC连接失败 return } data, err := rpc(cli, c, &req) if err != nil { - log.ZError(c, "rpc call failed", err) apiresp.GinError(c, err) // RPC调用失败 return } diff --git a/pkg/common/log/zap.go b/pkg/common/log/zap.go index 5fe5eefdd..18a11b7c2 100644 --- a/pkg/common/log/zap.go +++ b/pkg/common/log/zap.go @@ -47,25 +47,20 @@ func ZError(ctx context.Context, msg string, err error, keysAndValues ...interfa type ZapLogger struct { zap *zap.SugaredLogger - // store original logger without sampling to avoid multiple samplers - SampleDuration time.Duration - SampleInitial int - SampleInterval int } func NewZapLogger() (*ZapLogger, error) { zapConfig := zap.Config{ Level: zap.NewAtomicLevelAt(zapcore.DebugLevel), - Development: true, Encoding: "json", EncoderConfig: zap.NewProductionEncoderConfig(), DisableStacktrace: true, InitialFields: map[string]interface{}{"PID": os.Getegid()}, } - zl := &ZapLogger{} if config.Config.Log.Stderr { zapConfig.OutputPaths = append(zapConfig.OutputPaths, "stderr") } + zl := &ZapLogger{} opts, err := zl.cores() if err != nil { return nil, err @@ -75,13 +70,10 @@ func NewZapLogger() (*ZapLogger, error) { return nil, err } zl.zap = l.Sugar() + zl.zap.WithOptions(zap.AddStacktrace(zap.DPanicLevel)) return zl, nil } -func (l *ZapLogger) timeEncoder(t time.Time, enc zapcore.PrimitiveArrayEncoder) { - enc.AppendString(t.Format("2006-01-02 15:04:05")) -} - func (l *ZapLogger) cores() (zap.Option, error) { c := zap.NewProductionEncoderConfig() c.EncodeTime = zapcore.ISO8601TimeEncoder @@ -111,6 +103,14 @@ func (l *ZapLogger) cores() (zap.Option, error) { }), nil } +func NewErrStackCore(c zapcore.Core) zapcore.Core { + return &errStackCore{c} +} + +type errStackCore struct { + zapcore.Core +} + func (l *ZapLogger) getWriter() (zapcore.WriteSyncer, error) { logf, err := rotatelogs.New(config.Config.Log.StorageLocation+sp+"OpenIM.log.all"+".%Y-%m-%d", rotatelogs.WithRotationCount(config.Config.Log.RemainRotationCount), diff --git a/pkg/common/mw/rpc_server_interceptor.go b/pkg/common/mw/rpc_server_interceptor.go index 432797dc2..8cc08970b 100644 --- a/pkg/common/mw/rpc_server_interceptor.go +++ b/pkg/common/mw/rpc_server_interceptor.go @@ -4,6 +4,7 @@ import ( "OpenIM/pkg/common/log" "OpenIM/pkg/common/mw/specialerror" "OpenIM/pkg/errs" + "OpenIM/pkg/proto/wrapperspb" "context" "fmt" "google.golang.org/grpc" @@ -65,12 +66,12 @@ func rpcServerInterceptor(ctx context.Context, req interface{}, info *grpc.Unary code = errs.ServerInternalError } grpcStatus := status.New(codes.Code(code), codeErr.Msg()) - //if unwrap != err { - // stack := fmt.Sprintf("%+v", err) - // if details, err := grpcStatus.WithDetails(wrapperspb.String(stack)); err == nil { - // grpcStatus = details - // } - //} + if unwrap != err { + stack := fmt.Sprintf("%+v", err) + if details, err := grpcStatus.WithDetails(wrapperspb.String(stack)); err == nil { + grpcStatus = details + } + } log.ZWarn(ctx, "rpc resp", err, "funcName", funcName) return nil, grpcStatus.Err() }