将日志记录中间件添加到 grpc

Question

我正在尝试将一些日志中间件添加到 grpc 服务器，我正在按照他们的 github 上的简单示例进行操作。

https://github.com/grpc-ecosystem/go-grpc-middleware/blob/master/logging/logrus/examples_test.go

我这样设置我的服务器选项：

var (

  logrusLogger *logrus.Logger

  customFunc   grpc_logrus.CodeToLevel

)

func main() {

    logrusEntry := logrus.NewEntry(logrusLogger)

    lorgusOpts := []grpc_logrus.Option{

        grpc_logrus.WithLevels(customFunc),

    }

    grpc_logrus.ReplaceGrpcLogger(logrusEntry)

    opt := []grpc.ServerOption{

        grpc.Creds(credentials.NewTLS(tlsConfig)),

        grpc_middleware.WithUnaryServerChain(

            grpc_auth.UnaryServerInterceptor(auther.Auth),

            grpc_logrus.UnaryServerInterceptor(logrusEntry, lorgusOpts...),

        ),

    }

    s := grpc.NewServer(opt...)

    if err := s.Serve(lis); err != nil {

        log.Fatalf("err %+v", err)

    }

}

但是，每当我查看日志时，我都会得到一个 nil 指针。

panic: runtime error: invalid memory address or nil pointer dereference

[signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x89edde]

goroutine 23 [running]:

github.com/grpc-ecosystem/go-grpc-middleware/logging/logrus.UnaryServerInterceptor.func1(0xb2e640, 0xc00026c390, 0x9df7a0, 0xc0000adfc0, 0xc00018caa0, 0xc00018cac0, 0xb2e640, 0xc00026c390, 0x0, 0x0)

    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.0/logging/logrus/server_interceptors.go:37 +0x1be

github.com/grpc-ecosystem/go-grpc-middleware.ChainUnaryServer.func1.1.1(0xb2e640, 0xc00026c390, 0x9df7a0, 0xc0000adfc0, 0x0, 0x0, 0x0, 0xc0000adfc0)

    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.0/chain.go:25 +0x63

github.com/grpc-ecosystem/go-grpc-middleware/auth.UnaryServerInterceptor.func1(0xb2e640, 0xc00026c390, 0x9df7a0, 0xc0000adfc0, 0xc00018caa0, 0xc00018cae0, 0x89ceda, 0x9f24e0, 0xc00018cb00, 0xc00018caa0)

Answer 1

查看此代码的启发示例，问题是否与没有“grpc_ctxtags”拦截器有关？见https://github.com/grpc-ecosystem/go-grpc-middleware/blob/06f64829ca1f521d41cd6235a7a204a6566fb0dc/logging/logrus/examples_test.go#L31

Answer 2

因为这些变量为零，所以很恐慌var (  logrusLogger *logrus.Logger  customFunc   grpc_logrus.CodeToLevel)改为使用var (  logrusLogger = logrus.New()  customFunc   = func(code codes.Code) logrus.Level {    if code == codes.OK {        return logrus.InfoLevel    }    return logrus.ErrorLevel  })注意：grpc_logrus.CodeToLevel具有基础类型func(code codes.Code) logrus.Level

Answer 3

我面临着类似的问题：panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x8e8ffb]  goroutine 38 [running]: github.com/grpc-ecosystem/go-grpc-middleware/logging/logrus.UnaryServerInterceptor.func1(0xc98ac0, 0xc00011e9c0, 0xafa620, 0xc00011e3f0, 0xc0001164c0, 0xc000116520, 0xc98ac0, 0xc00011e9c0, 0xc000120030, 0xc00011e990)    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.2/logging/logrus/server_interceptors.go:37 +0x1bb github.com/grpc-ecosystem/go-grpc-middleware.ChainUnaryServer.func1.1.1(0xc98ac0, 0xc00011e9c0, 0xafa620, 0xc00011e3f0, 0x17, 0xafa620, 0xc00011e3f0, 0x0)    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.2/chain.go:25 +0x63 github.com/grpc-ecosystem/go-grpc-middleware/tags.UnaryServerInterceptor.func1(0xc98ac0, 0xc00011e3c0, 0xafa620, 0xc00011e3f0, 0xc0001164c0, 0xc000116540, 0x8dac2a, 0xb165e0, 0xc000116560, 0xc0001164c0)    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.2/tags/interceptors.go:23 +0x86 github.com/grpc-ecosystem/go-grpc-middleware.ChainUnaryServer.func1.1.1(0xc98ac0, 0xc00011e3c0, 0xafa620, 0xc00011e3f0, 0xc000152100, 0x0, 0xc0001f3b30, 0x40f0a8)    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.2/chain.go:25 +0x63 github.com/grpc-ecosystem/go-grpc-middleware.ChainUnaryServer.func1(0xc98ac0, 0xc00011e3c0, 0xafa620, 0xc00011e3f0, 0xc0001164c0, 0xc0001164e0, 0xc000505ba0, 0x493578, 0xb34560, 0xc00011e3c0)    /go/pkg/mod/github.com/grpc-ecosystem/go-grpc-middleware@v1.2.2/chain.go:34 +0xd5    /go/pkg/mod/google.golang.org/grpc@v1.29.1/server.go:1082 +0x50a google.golang.org/grpc.(*Server).handleStream(0xc00031eea0, 0xc9ffa0, 0xc000102780, 0xc000152100, 0x0)    /go/pkg/mod/google.golang.org/grpc@v1.29.1/server.go:1405 +0xccd google.golang.org/grpc.(*Server).serveStreams.func1.1(0xc000142020, 0xc00031eea0, 0xc9ffa0, 0xc000102780, 0xc000152100)    /go/pkg/mod/google.golang.org/grpc@v1.29.1/server.go:746 +0xa1 created by google.golang.org/grpc.(*Server).serveStreams.func1    /go/pkg/mod/google.golang.org/grpc@v1.29.1/server.go:744 +0xa1导致问题的代码是（我导入logrus为log）：func InitgRPC(port int, appStruct *app.App) (*grpc.Server, net.Listener) {    lis, err := net.Listen("tcp", fmt.Sprintf(":%s", fmt.Sprint(port)))    if err != nil {        log.Fatalf("Failed to listen on port: %s, error: %v", fmt.Sprint(port), err)    }    logrusEntry := log.NewEntry(logrusLogger)    opts := []grpc_logrus.Option{        grpc_logrus.WithLevels(customFunc),    }    grpc_logrus.ReplaceGrpcLogger(logrusEntry)    grpcServer := grpc.NewServer(    grpc_middleware.WithUnaryServerChain(        grpc_ctxtags.UnaryServerInterceptor(grpc_ctxtags.WithFieldExtractor(grpc_ctxtags.CodeGenRequestFieldExtractor)),        grpc_logrus.UnaryServerInterceptor(logrusEntry, opts...),        grpc_auth.UnaryServerInterceptor(appStruct.AuthenticateUser),        grpc_recovery.UnaryServerInterceptor()),    grpc_middleware.WithStreamServerChain(        grpc_ctxtags.StreamServerInterceptor(grpc_ctxtags.WithFieldExtractor(grpc_ctxtags.CodeGenRequestFieldExtractor)),        grpc_logrus.StreamServerInterceptor(logrusEntry, opts...),        grpc_auth.StreamServerInterceptor(appStruct.AuthenticateUser),        grpc_recovery.StreamServerInterceptor(),    ),)    app.RegisterServer(grpcServer, appStruct)    return grpcServer, lis}grpc_ctxtags所以这个问题与尼克波科克所说的不包括拦截器无关。