프로토콜 버퍼용 C에서 구분 I/O 기능 구현
Java에서 프로토콜 버퍼 버전 2.1.0은 구분 I/O 기능을 도입했습니다. 파일에서 여러 메시지를 쉽게 읽고 쓸 수 있습니다. 이러한 함수인parseDelimitedFrom, mergeDelimitedFrom 및 writeDelimitedTo는 메시지에 길이 접두사를 첨부하여 작동합니다.
원래 질문은 C에 해당하는 함수의 존재에 대해 문의했습니다. Java API는 이러한 기능을 제공하지만 공식 C 라이브러리에는 처음에는 이러한 기능이 부족했습니다. 하지만 버전 3.3.0부터 Google은 이러한 기능을 google/protobuf/util/delimited_message_util.h에 추가했습니다.
이전 버전의 C 라이브러리를 사용하는 경우 다음을 사용하여 구분 I/O를 구현할 수 있습니다. 다음 코드:
bool writeDelimitedTo( const google::protobuf::MessageLite& 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); uint8_t* buffer = output.GetDirectBufferForNBytesAndAdvance(size); if (buffer != NULL) { // Optimization: Serialize message directly to array if it fits. message.SerializeWithCachedSizesToArray(buffer); } else { // Slower path for messages spanning multiple buffers. message.SerializeWithCachedSizes(&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(&size)) return false; // Limit the stream to the message 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 stream limit. input.PopLimit(limit); return true; }
위 내용은 C에서 프로토콜 버퍼에 대한 구분 I/O를 어떻게 구현할 수 있습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!