Golang 服务器未正确接收从 Python 客户端发送的 GRPC 请求

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《Golang 服务器未正确接收从 Python 客户端发送的 GRPC 请求》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我编写了一个python grpc客户端，可以连接到许多grpc golang服务。我已经能够像这样完成这项工作：

from alphausblue.connection.conn import grpc_client_connection
from alphausblue.iam.v1.iam_pb2 import whoamirequest
from alphausblue.iam.v1.iam_pb2_grpc import iamstub

async def main():
    conn = grpc_client_connection(svc = "blue")
    stub = iamstub(conn)
    resp = await stub.whoami(whoamirequest())
    print(resp)

其中服务名称为 blue。但是，如果我尝试连接到不同的服务来请求如下数据：

from alphausblue.connection.conn import grpc_client_connection
from alphausblue.cost.v1.cost_pb2 import listaccountsrequest
from alphausblue.cost.v1.cost_pb2_grpc import coststub

async def main():
    conn = grpc_client_connection(svc = "cost")
    stub = coststub(conn)
    account = await stub.getaccount(getaccountrequest(vendor = 'aws', id = '731058950257'))
    print(account)

我收到未实现的回复。如果该服务不存在但它确实存在并且我的 golang 客户端可以很好地连接到它，那么这是有意义的。此外，当我检查服务器的日志时，我可以清楚地看到请求已到达服务器。做了更多研究，我在我的服务器上发现了这段代码：

type service struct {
    userinfo *blueinterceptors.userdata

    cost.unimplementedcostserver
}

func (s *service) getaccount(ctx context.context, in *cost.getaccountrequest) (*api.account, error) {
    switch in.vendor {
    case "aws":
        // do stuff
    default:
        return status.errorf(codes.unimplemented, "not implemented")
    }
}

这告诉我，正在调用该函数，但正在反序列化的有效负载缺少 vendor 字段。但是，在调试时我可以看到这一行：

src/core/lib/security/transport/secure_endpoint.cc:296] 写 0000018e2c62fb80: 00 00 00 13 0a 03 61 77 73 12 0c 37 33 31 30 35 38 39 35 30 32 35 37 '......aws ..731058950257'

因此，数据通过 grpc 发送到服务器，但被反序列化为缺少字段的对象。那么这是什么原因呢？

更新

我按照 @blackgreen 的建议查看了 python 和 golang 客户端的 getaccountrequest 的定义。

golang客户端代码：

// request message for the cost.getaccount rpc.
type getaccountrequest struct {
    state         protoimpl.messagestate
    sizecache     protoimpl.sizecache
    unknownfields protoimpl.unknownfields

    vendor string `protobuf:"bytes,1,opt,name=vendor,proto3" json:"vendor,omitempty"`
    id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

python 客户端代码：

_GETACCOUNTREQUEST = _descriptor.Descriptor(
  name='GetAccountRequest',
  full_name='blueapi.cost.v1.GetAccountRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  create_key=_descriptor._internal_create_key,
  fields=[
    _descriptor.FieldDescriptor(
      name='vendor', full_name='blueapi.cost.v1.GetAccountRequest.vendor', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
    _descriptor.FieldDescriptor(
      name='id', full_name='blueapi.cost.v1.GetAccountRequest.id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=b"".decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=946,
  serialized_end=993,
)

很明显，此处的字段顺序相同，因此我认为这不是问题，除非 grpc 使用 index 而不是 number。

正确答案

确保在 python version 字段中设置的字符串不包含不可见字符后，python 客户端中导入的生成代码与 go 服务器中导入的生成代码可能存在版本不匹配。

特别是，如果两个版本实际上都有 version 字段，但不知何故 go 代码无法“识别”它，则可能是由于字段标记号不匹配造成的。 p>

您显示的字节有效负载（hexa 0a 03 61 77 73 12 0c 37 33 31 30 35 38 39 35 30 32 35 37，base64 cgnhd3msddczmta1odk1mdi1nw==）确实正在发送zq proto 字段中的 bczqbaws 字符串，标签号为 1 ( how do I know)

所以让我们考虑一个人为的示例，python 客户端中使用的 getaccountrequest 的原型架构可能是

message getaccountrequest {
    string version = 1; // field tag number 1
}

而go服务器中使用的可能是：

message getaccountrequest {
    string version = 3; // field tag number 3
}

在这种情况下，您将在线路上看到具有版本字段的消息，但是在针对具有不同标记号的 go 结构对其进行反序列化时，它将最终变为空。客户端发送带有标签 1 的数据，服务器期望带有标签 3 的数据。

您可以通过检查 go getaccountrequest 结构来验证此假设。它应该如下所示：

type GetAccountRequest struct {
    // unexported fields

    // other fields, in order
    Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
}

反引号`之间的部分是结构体标记，其中3是标记号。

我不知道 python 中的 grpc codegen 是什么样子，但你应该能够以某种方式比较标签号。如果它们确实不同，请确保使用具有相同标记号的生成结构更新客户端或服务器代码。

今天关于《Golang 服务器未正确接收从 Python 客户端发送的 GRPC 请求》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！