问题描述

我在使用 protobuf 进行进程间通信时遇到了一些问题.Protobuf 允许一组序列化格式:

I am facing some issues with my inter-process communication using protobuf. Protobuf allows a set of serialization formats:

SerializeToArray(void * data, int size) : bool
SerializeToCodedStream(google::protobuf::io::CodeOutputStream * output) : bool
SerializeToFileDescriptor(int file_descriptor) : bool
SerializeToOstream(ostream * output)

我的问题是，我不知道如何将它与我正在使用的 boost asio 套接字一起使用，因为我实现了它们来发送字符串:

My problem is, I have no clue how to use it with the boost asio sockets I am using, as I implemented them to send strings:

boost::asio::write(socket, boost::asio::buffer(message),
            boost::asio::transfer_all(), ignored_error);

但我想发送 ostream.

But I would like to send the ostream.

推荐答案

Boost 的 asio 库在流缓冲区级别与 std iostream 集成

Boost's asio library integrates with std iostream on the level of streambuffers

所以写一个请求

boost::asio::streambuf request;
std::ostream request_stream(&request);
request_stream << "GET " << argv[2] << " HTTP/1.0
";
request_stream << "Host: " << argv[1] << "
";
request_stream << "Accept: */*
";
request_stream << "Connection: close

";

// Send the request.
boost::asio::write(socket, request);

阅读回复:

boost::asio::streambuf response;
boost::asio::read_until(socket, response, "
");

// Check that response is OK.
std::istream response_stream(&response);

复制流:

boost::asio::streambuf request;
std::ostream request_stream(&request);
request_stream << std::cin.rdbuf() << std::flush;

// Send the request.
boost::asio::write(socket, request);

这篇关于如何通过 C++ 中的 boost 套接字发送 ostream?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持跟版网！