如何通过 C++ 中的 boost 套接字发送 ostream?

Posted

技术标签:

【中文标题】如何通过 C++ 中的 boost 套接字发送 ostream?【英文标题】:How to send ostream via boost sockets in C++? 【发布时间】:2011-04-15 10:26:20 【问题描述】:

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

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

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

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

但我想发送 ostream。

【问题讨论】:

你可以使用ostringstream,用protobuf序列化它,将它的字符串值.str()转换成一个boost缓冲区,然后发送。您不打算在消息交换套接字上自动使用完整的流语义,是吗? 【参考方案1】:

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

所以写一个请求

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

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

阅读回复:

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

// 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);

【讨论】:

【参考方案2】:

使用 ostringstream 怎么样?

ostringstream oss;

oss << "hello world";

std::string str(oss.str());

【讨论】:

我忘了说,我想再次用Java反序列化它。 @platz 这个我帮不了你,我对 Java 一无所知

以上是关于如何通过 C++ 中的 boost 套接字发送 ostream?的主要内容,如果未能解决你的问题,请参考以下文章

C++ Boost ASIO:如何读取/写入超时?

使用 boost asio udp 套接字时如何设置本地端点

boost.asio 和文件 i/o 有啥关系?

如何确定是不是有数据可从 boost::asio 中的套接字读取?

C++ 如何通过套接字发送对象?

如何在 c++ 和 java 之间通过 udp 有效发送数据数组