java - 在 gRPC 中使用直接类以避免数据复制

Question

我们希望避免gRPC通信中的数据拷贝。

我在 proto 文件中有以下(不是真实的)示例:

message Person
{
    string id = 1;
    string Name = 2;
    string Address = 3;
}

message PersonId
{
    required string id = 1;
}

service PersonService
{
    rpc GetPersonById( PersonId ) returns Person;
}

而且效果很好。但是当我实现它时，我将所有数据复制到请求中:

class PersonServiceImpl : PersonService.MaterialServiceBase
{
    public override Task<Person> GetPersonById( PersonId request, ServerCallContext context )
    {
        Datamodel.Person person = GetPersonForDatabaseAsync(request.Id).Result;

        Task.FromResult( new Person() {
            Id = person.Id,
            Name = person.Name,
            Address = person.Address
            } );
    }
}

但是，如果我们避免数据复制，那将是非常棒的，因为当我们向 Person 添加新成员时，它既慢又危险。完美的代码如下:

    public override Task<Person> GetPersonById( PersonId request, ServerCallContext context )
    {
        return GetPersonForDatabaseAsync(request.Id);
    }

这可能吗？

我们检查了性能，25% 的时间用于编码和解码，尤其是在具有嵌套类型(例如 Huge Orders)的大型类型上。

我添加了java标签，因为它也是Java环境中的相关问题。

因评论而编辑:

namespace Datamodel
{
    class Person
    {
        string Id { get; set; }
        string Name { get; set; }
        string Address { get; set; }
    }
}

所以问题是，从另一个角度来看:我应该如何更改 Datamodel.Person 以使其与 gRPC 响应兼容。

Answer 1

不幸的是，这是不可能的，因为 protobuf 代码生成。所有成员和函数都是硬编码的。

如果 gRPC 提供了使用接口(interface)而不是直接成员定义消息类的可能性，那就太好了。该接口(interface)将包含所有成员和一个创建函数。

所以生成的代码是这样改的:

[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void MergeFrom( pb::CodedInputStream input )
{
    uint tag;
    while ( ( tag = input.ReadTag() ) != 0 )
    {
        switch ( tag )
        {
            default:
                _unknownFields = pb::UnknownFieldSet.MergeFieldFrom( _unknownFields, input );
                break;
            case 10:
                {
                    Id = input.ReadString();
                    break;
                }
            case 18:
                {
                    Name = input.ReadString();
                    break;
                }
        }
    }
}

对此:

[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void MergeFrom( pb::CodedInputStream input )
{
    uint tag;
    while ( ( tag = input.ReadTag() ) != 0 )
    {
        switch ( tag )
        {
            default:
                Instance.UnknownFields = pb::UnknownFieldSet.MergeFieldFrom( Instance.UnknownFields, input );
                break;
            case 10:
                {
                    Instance.Id = input.ReadString();
                    break;
                }
            case 18:
                {
                    Instance.Name = input.ReadString();
                    break;
                }
        }
    }
}

其中 Instance 是从 protofile 生成的接口(interface)的实现:

public interface IPerson
{
    private pb::UnknownFieldSet UnknownFields;
    string Id { get; set; }
    string Name { get; set; }
}

如果我的 Datamodel.Person 实现了这个接口(interface)，并且生成的 Person 消息通过这个 IPerson 接口(interface)存储和检索数据，那么我们可以避免datacopy，gRPC的使用会更快25%。

我认为这对 gRPC 来说是一个巨大的优势也许 Jon Skeet可以做到。当我们有清晰的概念时，我可以对 c、c++ 和 c# 进行更改。

顺便说一下，这将是 gRPC 向前迈出的一大步，因为这是人们使用 REST 而不是它的原因之一。在 REST 世界中，可以使用 JSON Serialize 将数据直接检索到 Datamodel 结构。通过 Deserialize，他们可以直接发送结构。

它必须是protobuf文件中的一个新选项，并且在所有支持接口(interface)的语言中都是可能的。