如何直接从protobuf创建GRPC服务器，而无需将其编译为java代码

Question

有必要将通用GRPC服务器实现为存根。

找不到与服务器类似的内容，仅针对客户端。

非常感谢！

Answer 1

我相信您想将生成的服务器用于测试目的？如果是这样，有一种称为服务虚拟化或应用编程接口模拟的做法——测试双重系列的一个子集。它允许您“模拟”或“存根”真实系统，以测试被测系统。其中一些工具允许导入模式文件来生成存根（即Swagger/OpenAPI/Proto/WSDL/...）。

维基百科包含这些工具的列表。今天看看这个列表，其中一个支持gRPC的工具叫做流量鹦鹉，它允许您根据Proto文件创建gRPC模拟。也有像GripMock这样的开源工具，但它不会根据Proto文件生成存根，你必须手动创建它们。

请记住，生成的存根/模拟/模拟器只是一个测试替身，它不会复制Proto文件对应的系统的完整行为。导入Proto文件并生成服务器测试替身的工具只能知道消息的语法，而不知道语义学或真实系统的行为。

如果您还想部分复制消息的语义学，请考虑记录gRPC消息以创建服务存根，这样您也可以查看示例数据。

Answer 2

可能有一些方法可以从包含服务的protobuf动态构建gRPC服务器，但这并不是很有用。事实上，铁锈板条箱，节点。js和其他实现可以动态生成代码，而无需直接使用protoc的额外手动步骤。

正如评论员所建议的那样，proto文件只定义了服务方法名称及其输入和输出消息，因此，假设的服务器除了接收消息和可能发送空回复之外，不会对消息做任何处理。

因为protos是强类型的，所以这样存根服务器也没有任何好处，因为您的（例如Java）客户端能够创建类型良好的消息（没有服务器）。

您的用例是什么？这可能有助于提出其他答案。

Answer 3

如果不想处理protobuf消息，则需要创建一个序列化到/从字节[]的封送拆收器，为要支持的每个方法创建一个MethodDescriptor，并为应用程序逻辑创建一个ServerCallHandler。您可能会发现grpc代理模型很有用。这些可以组合在一起传递给serverBuilder。添加服务（ServerServiceDefinition）。您还可以使用ServerCalls帮助创建一个ServerCallHandler。

java prettyprint-override">class ByteMarshaller implements MethodDescriptor.Marshaller<byte[]> {
  @Override public byte[] parse(InputStream stream) {
    try {
      return ByteStreams.toByteArray(stream);
    } catch (IOException ex) {
      throw new RuntimeException();
    }
  }

  @Override public InputStream stream(byte[] value) {
    return new ByteArrayInputStream(value);
  }
};
class YourHandler extends ServerCallHandler<byte[],byte[]> {...}

MethodDescriptor<> desc = MethodDescriptor.<byte[], byte[]>newBuilder()
    // UNKNOWN is fine, but specify the type if you know it
    .setType(MethodDescriptor.MethodType.UNKNOWN)
    .setFullMethodName("package.YourService/Method"))
    .setRequestMarshaller(new ByteMarshaller())
    .setResponseMarshaller(new ByteMarshaller())
    .build();
serverBuilder.addService(
    ServiceDescriptor.newBuilder("package.YourService")
      .addMethod(ServerMethodDefinition.create(desc, new YourHandler()))
      .build());

如果您想解析原型，那么您可以将DynamicMessage与gRPC的Pro buf Marshaller一起使用。一个类似的客户端问题解释了这个过程。