我有这样的处理程序:
func (daemon *Daemon) List(item string) (map[string][]string, error) {
panic("this is a panic")
...
我只想恢复这种潜在的恐慌,所以在我的grpc服务器中,我写道:
// Serve serves gRPC request by goroutines
func (s *ServerRPC) Serve(addr string) error {
defer func() {
if err := recover(); err != nil {
glog.Errorf("Recovered from err: ", err)
}
}()
l, err := net.Listen("tcp", addr)
if err != nil {
glog.Fatalf("Failed to listen %s: %v", addr, err)
return err
}
return s.server.Serve(l)
}
但是它并没有引起惊慌,我以为是因为我的惊慌发生在儿童goroutine中?如果是这样,如何使我的grpc服务器正常崩溃?
[查看Golang gRPC Middlewares程序包中的恢复拦截器。它从Goroutine请求中的紧急情况中恢复,并将其作为内部gRPC错误返回。
myServer := grpc.NewServer(
grpc.StreamInterceptor(grpc_middleware.ChainStreamServer(
grpc_zap.StreamServerInterceptor(zapLogger),
grpc_auth.StreamServerInterceptor(myAuthFunction),
grpc_recovery.StreamServerInterceptor(),
)),
grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(
grpc_zap.UnaryServerInterceptor(zapLogger),
grpc_auth.UnaryServerInterceptor(myAuthFunction),
grpc_recovery.UnaryServerInterceptor(),
)),
)