如何在 C 和 Java 中讀寫帶有長度前綴的 Protocol Buffer 訊息？

Java 中Protocol Buffers 分隔I/O 函數的C 等效項

問題：

在C和Java中，如何使用長度讀取Protocol Buffers訊息並將其寫入文件前綴？ Java API 具有用於此目的的「定界」I/O 函數，但是 C 中是否有等效的函數？如果不是，大小前綴的底層傳輸格式是什麼？

答案：

從版本 3.3.0 開始，C 現在包含等效函數google/protobuf/util/delimited_message_util.h.h.

這些函數提供了比之前建議的更快、更優化的實現

原始實現：

在引入官方等效項之前，可以使用以下優化的C實作：

bool writeDelimitedTo(
    const google::protobuf::MessageLite& message,
    google::protobuf::io::ZeroCopyOutputStream* rawOutput) {
  // Use a new coded stream for each message (fast).
  google::protobuf::io::CodedOutputStream output(rawOutput);

  // Write the size.
  const int size = message.ByteSize();
  output.WriteVarint32(size);

  uint8_t* buffer = output.GetDirectBufferForNBytesAndAdvance(size);
  if (buffer != NULL) {
    // Optimization: Direct-to-array serialization for messages in a single buffer.
    message.SerializeWithCachedSizesToArray(buffer);
  } else {
    // Slower path for messages across multiple buffers.
    message.SerializeWithCachedSizes(&output);
    if (output.HadError()) return false;
  }

  return true;
}

bool readDelimitedFrom(
    google::protobuf::io::ZeroCopyInputStream* rawInput,
    google::protobuf::MessageLite* message) {
  // Each message uses its own coded stream (fast).
  google::protobuf::io::CodedInputStream input(rawInput);

  // Read the size.
  uint32_t size;
  if (!input.ReadVarint32(&size)) return false;

  // Limit the stream to the size of the message.
  google::protobuf::io::CodedInputStream::Limit limit =
      input.PushLimit(size);

  // Parse the message.
  if (!message->MergeFromCodedStream(&input)) return false;
  if (!input.ConsumedEntireMessage()) return false;

  // Release the limit.
  input.PopLimit(limit);

  return true;
}

以上是如何在 C 和 Java 中讀寫帶有長度前綴的 Protocol Buffer 訊息？的詳細內容。更多資訊請關注PHP中文網其他相關文章！