如何在 grpc 的状态错误对象的详细信息中发送自定义 proto

Question

我正在尝试在我的 grpc 调用的错误响应中发送自定义原型。按照这个，应该是可以的。

这是代码。

    st := status.Newf(codes.NotFound, "user %s doesn't exist", req.Name)

    desc := "The username Doesn't exist, please give a valid username"

    customProtoError := &data.Error{

        Message:         "Check username",

        Code:            1404,

        Type:            "Service",

        DetailedMessage: desc,

    }

    st, err := st.WithDetails(customProtoError)

    if err != nil {

        panic(fmt.Sprintf("Unexpected error attaching metadata: %v", err))

    }

我有这些 GRPC API 的 grpc 和 http 处理程序。HTTP 服务器中使用的 Marshaler 是github.com/gogo/gateway

mux := runtime.NewServeMux(

    runtime.WithMarshalerOption(JSONContentType, &gateway.JSONPb{}))

HTTP和GRPC服务器的配置可在此处获得。当我尝试使用 HTTP 调用访问 API 时，这是我得到的响应。

HTTP 错误：

{

    "error": "user kishore1 doesn't exist",

    "code": 5,

    "message": "user kishore1 doesn't exist",

    "details": [

        {

            "type_url": "type.googleapis.com/data.Error",

            "value": "Cg5DaGVjayB1c2VybmFtZRD8ChoHU2t5ZmxvdyI4VGhlIHVzZXJuYW1lIERvZXNuJ3QgZXhpc3QsIHBsZWFzZSBnaXZlIGEgdmFsaWQgdXNlcm5hbWU="

        }

    ]

}

type_url与 google 一起提供，因为它在golang proto code中进行了硬编码。但这在 JSON 中表示 Any将被反序列化为嵌入式消息。

GRPC 客户端代码：

resp, err := client.GetUser(ctx, req)

        if err != nil {

        st := status.Convert(err)

        for _, detail := range st.Details() {

            switch t := detail.(type) {

            case *pb.Error:

                fmt.Println("Oops! Your request was rejected by the server.")

                ...

            default:

                fmt.Println("Error Received - ", detail, reflect.TypeOf(detail))

            }

        }

grpc错误：

Error Received - proto: not found *errors.prefixError

知道是什么导致了这种混乱吗？HTTP 不会反序列化为嵌入式消息，而 GRPC 提供proto.NotFound

这可能是因为 gogo proto 是网关吗？我什至对 googleapis proto 进行了同样的尝试，errdetails.BadRequest但还是一样。

Answer 1

花了大约一天后，我才发现问题是由于版本不兼容造成的。因此，在使用 gogo proto 时，这对我有用。对于 GRPC 错误，我必须升级我的 grpc-gateway 版本并使用gogo/status而不是grpc/statusgithub.com/gogo/status v1.1.0 github.com/grpc-ecosystem/grpc-gateway v1.14.5对于 HTTP 错误，我不得不降级我的golang/protobufgithub.com/golang/protobuf v1.3.2