2

在 C++ 中,我使用GzipOutputStream来压缩数据,这是一个大字符串。首先,我必须将字符串转换为原始消息,如下所示:

syntax = "proto3";
package Serverlog_Compress;

message ServerlogMessage {
  string data = 1;
}

然后,在代码中,我调用GzipOutputStream来压缩数据,例如:

google::protobuf::io::GzipOutputStream::Options options_; 
options_.format = google::protobuf::io::GzipOutputStream::GZIP; 
options_.compression_level = 9; 

google::protobuf::io::FileOutputStream file_stream(fd); 
google::protobuf::io::GzipOutputStream gzip_stream(&file_stream, options_);

auto *message = butil::get_object<Serverlog_Compress::ServerlogMessage>();
message->set_data(data);

int ret = 0;
{
  std::lock_guard<std::mutex> lock(file_mutex_);
  ret = message->SerializeToZeroCopyStream(&gzip_stream);
}
if (!ret) { 
  LOG(ERROR) << "Failed to write the message, the ret is " << ret;
  message->Clear();
  butil::return_object(message);
  return -1; 
}
message->Clear();
butil::return_object(message);

完成压缩后,我得到了压缩的数据文件,但是当我使用zcat来获取文件数据时,我得到了这个错误:

gzip: 20200301_12: invalid compressed data--crc error  
gzip: 20200301_12: invalid compressed data--length error

20200301_12是文件名。

4

0 回答 0