구분된 I/O를 사용하여 C에서 프로토콜 버퍼 메시지를 어떻게 인코딩하고 디코딩합니까?

Java의 프로토콜 버퍼 구분 I/O 함수에 대한 C 등가물

C와 Java 모두에서 여러 프로토콜을 읽고 쓸 필요가 발생합니다. 파일의 메시지를 버퍼링합니다. Java 버전 2.1.0은 이러한 목적을 위해 "구분된" I/O 함수 세트를 제공합니다.

• parseDelimitedFrom
• mergeDelimitedFrom
• writeDelimitedTo

이러한 기능을 사용하면 각 메시지 앞에 길이 접두사를 쉽게 첨부할 수 있습니다. 그러나 이러한 기능이 C에 존재하는지 여부는 여전히 불분명합니다.

C와 동등한 기능의 존재

처음에는 이러한 Java 기능에 직접적으로 대응하는 C 기능이 없었습니다. 그러나 버전 3.3.0부터 C는 이제 google/protobuf/util/delimited_message_util.h에서 구분된 메시지 유틸리티 기능을 제공합니다.

크기 접두사 형식

이러한 공식 유틸리티가 출시되기 전에 C에서 자체 파서를 구현하려는 사용자는 Java API에 첨부된 크기 접두어의 연결 형식을 이해하는 것이 중요합니다. 형식은 다음 지침을 준수합니다.

• 첫 번째 메시지 이전에도 구분 기호가 있어야 합니다.
• 메시지 크기는 32비트 varint로 인코딩됩니다.
• 1바이트 구분 기호 바이트(0x0A)가 각 메시지를 종료하고 길이가 접두어로 붙은 다음 메시지가 바로 뒤에 시작됩니다.

최적화된 C 구현

공식 C 유틸리티 함수가 출시된 후 원래 제안된 구현에서 누락된 몇 가지 최적화가 발견되었습니다. 아래에 제공되는 이러한 최적화된 기능은 향상된 성능을 제공하고 잠재적인 오류를 방지합니다.

<code class="cpp">bool writeDelimitedTo(
    const google::protobuf::MessageLite&amp; message,
    google::protobuf::io::ZeroCopyOutputStream* rawOutput) {
  // Create a new coded stream for each message.
  google::protobuf::io::CodedOutputStream output(rawOutput);

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

  // Serialize the message directly to the output buffer if possible.
  uint8_t* buffer = output.GetDirectBufferForNBytesAndAdvance(size);
  if (buffer != NULL) {
    message.SerializeWithCachedSizesToArray(buffer);
  } else {
    // Use a slower path if the message spans multiple buffers.
    message.SerializeWithCachedSizes(&amp;output);
    if (output.HadError()) return false;
  }

  return true;
}

bool readDelimitedFrom(
    google::protobuf::io::ZeroCopyInputStream* rawInput,
    google::protobuf::MessageLite* message) {
  // Create a new coded stream for each message.
  google::protobuf::io::CodedInputStream input(rawInput);

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

  // Set a read limit to enforce the 64 MB per-message size constraint.
  google::protobuf::io::CodedInputStream::Limit limit =
      input.PushLimit(size);

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

  // Remove the read limit.
  input.PopLimit(limit);

  return true;
}</code>

위 내용은 구분된 I/O를 사용하여 C에서 프로토콜 버퍼 메시지를 어떻게 인코딩하고 디코딩합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!