Rumah >pembangunan bahagian belakang >C++ >Bagaimana untuk Mencapai Fungsi I/O Terhad Penimbal Protokol Java dalam C ?

Bagaimana untuk Mencapai Fungsi I/O Terhad Penimbal Protokol Java dalam C ?

Barbara Streisand
Barbara Streisandasal
2024-12-05 02:32:091015semak imbas

How to Achieve Java Protocol Buffers Delimited I/O Functionality in C  ?

C Equivalents for Java Protocol Buffers Delimited I/O Functions

Masalah:
Pembangun yang cuba membaca dan menulis berbilang mesej Protocol Buffers daripada fail dalam kedua-dua C dan Java mungkin menghadapi masalah menggunakan fungsi I/O "Terhad" yang tersedia dalam Java tetapi nampaknya tidak boleh diakses dalam C .

Penyelesaian:
Sehingga versi 3.3.0, fungsi yang setara untuk membaca dan menulis mesej yang dibataskan telah diperkenalkan dalam C dalam fail pengepala google /protobuf/util/delimited_message_util.h. Fungsi-fungsi ini ialah:

  • writeDelimitedTo(): ​​Menulis mesej terhad kepada google::protobuf::io::ZeroCopyOutputStream.
  • readDelimitedFrom(): Membaca mesej terhad daripada a google::protobuf::io::ZeroCopyInputStream.

Nota:
Pelaksanaan alternatif, yang disediakan oleh pengarang asal pustaka protobuf C dan Java, menawarkan pengoptimuman tidak terdapat dalam pelaksanaan perpustakaan rasmi. Pelaksanaan ini, ditunjukkan di bawah, menghalang kemungkinan kegagalan selepas 64MB input sambil masih menguatkuasakan had 64MB pada mesej individu:

bool writeDelimitedTo(
    const google::protobuf::MessageLite& message,
    google::protobuf::io::ZeroCopyOutputStream* rawOutput) {
  // We create a new coded stream for each message.  Don't worry, this is 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:  The message fits in one buffer, so use the faster
    // direct-to-array serialization path.
    message.SerializeWithCachedSizesToArray(buffer);
  } else {
    // Slightly-slower path when the message is multiple buffers.
    message.SerializeWithCachedSizes(&output);
    if (output.HadError()) return false;
  }

  return true;
}

bool readDelimitedFrom(
    google::protobuf::io::ZeroCopyInputStream* rawInput,
    google::protobuf::MessageLite* message) {
  // We create a new coded stream for each message.  Don't worry, this is fast,
  // and it makes sure the 64MB total size limit is imposed per-message rather
  // than on the whole stream.  (See the CodedInputStream interface for more
  // info on this limit.)
  google::protobuf::io::CodedInputStream input(rawInput);

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

  // Tell the stream not to read beyond that size.
  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;
}

Atas ialah kandungan terperinci Bagaimana untuk Mencapai Fungsi I/O Terhad Penimbal Protokol Java dalam C ?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn