可以将 protobuf 封送消息到已分配的字节数组而不进行复制吗？

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《可以将 protobuf 封送消息到已分配的字节数组而不进行复制吗？》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我正在通过自定义数据包实现客户端服务器通信。 我正在使用 go net.conn。它可以拨打tcp/unix方案，非常方便。我使用 protocol buffer 来定义我的消息。

我定义了一个包含length和buffer的数据包

type packet struct {
    length uint32
    buffer []byte
}

api函数是这样的：

func(api *api) send(m *proto.message) error

func(api *api) 接收(p *packet) 错误

以send函数为例，它接收一个protobuf消息，将其编组到packet中。并将其写入net.conn。

这是发送函数的简化版本：

func(api *API) Send(m *proto.Message) error {
    bytes, err := proto.Marshal(m)
    if err != nil {
        return err
    }
    buffer := api.packet[:length]
    copy(buffer, bytes)
    _, err := api.conn.Write(buffer)
    if err != nil {
        return err
    }
    return nil
}

我正在将 bytes 复制到 buffer 中。因为go协议缓冲区api只提供了

func marshal(pb message) ([]字节，错误)

在protocol buffer c++中，它提供了 bool serializetoarray(void * data, int size) const，正在序列化消息并将其存储在给定的字节数组中。 但我在 go protocol buffer api 中找不到相同的东西。

如果我想直接将序列化结果存储在给定的字节数组中，有什么方法可以避免复制吗？

解决方案

您正在从 gogo/protobuf 中寻找 MarshalTo 方法，这是 protobuf 的另一个实现，与原始方法兼容。

当您将要填充的缓冲区传递给它时，您可以通过多个编组调用重复使用同一缓冲区。显然缓冲区应该足够大。

func MarshalTo([]byte, m) error

今天关于《可以将 protobuf 封送消息到已分配的字节数组而不进行复制吗？》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！