gRPC 可能出现零服务器消息吗？

Question

在下面的gRPC-客户端代码中，第二个if是必须的吗？

status, err := cli.GetStatus(ctx, &empty.Empty{})
if err != nil {
    return err
}

if status == nil {
    // this should NEVER happen - right?
    return fmt.Errorf("nil Status result returned") 
}

直觉上，应该总是在 go 中检查 nil 以防万一 。但是，有一个运行时检查来捕获任何客户端到服务器 nil 的使用，例如

status, err := cli.GetStatus(ctx, nil) // <- runtime error

if err != nil {
    // "rpc error: code = Internal desc = grpc: error while marshaling: proto: Marshal called with nil"
    return err
}

那么是否有类似的服务器到客户端运行时保证，从而消除了 status == nil 检查的需要？

Answer 1

是的，这永远不应该发生。 GRPC 对此负责。

Answer 2

使用人为的服务器示例进一步调查：

func (s *mygRPC) GetStatus(context.Context, *empty.Empty) (*pb.Status, error) {
    log.Println("cli: GetStatus()")

    //return &pb.Status{}, nil
    return nil, nil // <- can server return a nil status message (with nil error)
}

并测试 client/server 反应：

客户：

ERROR: rpc error: code = Internal desc = grpc: error while marshaling: proto: Marshal called with nil

服务器：

2019/05/14 16:09:50 cli: GetStatus()
ERROR: 2019/05/14 16:09:50 grpc: server failed to encode response:  rpc error: code = Internal desc = grpc: error while marshaling: proto: Marshal called with nil

因此，即使有人想合法地 return 零值，gRPC 传输也不允许。

注意： server-side 代码仍在执行 - 正如预期的那样 - 但就客户端而言，gRPC 调用失败。

结论：一个有效的（err==nil）服务器响应将总是 return一个有效的（非nil) 消息。

编辑：

检查 gRPC 来源揭示捕获 nil 消息的位置：

server.go

func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
    data, err := encode(s.getCodec(stream.ContentSubtype()), msg)
    if err != nil {
        grpclog.Errorln("grpc: server failed to encode response: ", err)
        return err
    }
    // ...
}

rpc_util.go

func encode(c baseCodec, msg interface{}) ([]byte, error) {
    if msg == nil { // NOTE: typed nils will not be caught by this check
        return nil, nil
    }
    b, err := c.Marshal(msg)
    if err != nil {
        return nil, status.Errorf(codes.Internal, "grpc: error while marshaling: %v", err.Error())
    }
    // ...
}

这一行的注释是关键：

if msg == nil { // NOTE: typed nils will not be caught by this check }

因此，如果要对我们的 typed-nil 使用反射，reflect.ValueOf(msg).IsNil() 会 return true。以下 c.Marshal(msg) 个错误 - 调用无法向客户端发送消息响应。

gRPC 可能出现零服务器消息吗？

is a nil server message possible with gRPC?

go

grpc

grpc-go