Как отправить ostream через буст-сокеты на С++?

Я столкнулся с некоторыми проблемами при обмене данными между процессами с использованием 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.


c++ stream sockets boost-asio
person Konrad Reiche    schedule 15.04.2011    source источник
comment
Вы можете использовать ostringstream, сериализовать его с помощью protobuf, преобразовать его строковое значение .str() в буст-буфер и отправить его. Вы не планируете использовать семантику полного потока при автоматическом обмене сообщениями сокетов, не так ли?   -  person Jonas Bötel    schedule 15.04.2011

Ответы (2)


arrow_upward
11
arrow_downward

Библиотека asio Boost интегрируется с 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);
person sehe    schedule 15.04.2011

arrow_upward
0
arrow_downward

Как насчет использования ostringstream?

ostringstream oss;

oss << "hello world";

std::string str(oss.str());
person Tony The Lion    schedule 15.04.2011
comment
Я забыл сказать, я хотел бы снова десериализовать его в Java. - person Konrad Reiche; 15.04.2011
comment
@platz Я не могу вам с этим помочь, я ничего не знаю о Java - person Tony The Lion; 15.04.2011