У меня есть класс, очень глупый класс.Объекты этого класса, я хочу отправить их через TCP, используя Asio Boost.Мой класс правильно дружит с бустом и реализует метод serialize ...
Хорошо, я хочу, чтобы клиент подключался к серверу, отправлял ему мой объект, а затем сервер отправлял обратно другой объект того же класса.
Я пытался сделать это:
На сервере:
Data data;
int port = 2040;
boost::asio::io_service io_s;
tcp::acceptor data_acceptor(io_s, tcp::endpoint(tcp::v4(), port));
tcp::iostream data_stream;
Data data_recv;
data_acceptor.accept(*(data_stream.rdbuf())); /* Accepting */
boost::archive::binary_iarchive ia(data_stream);
ia >> data_recv;
boost::archive::binary_oarchive oa(data_stream); /* LINE Y */
oa << data; /* LINE X */
data_stream.close();
Данные - это сериализуемый класс.
На клиенте:
Data data_send;
Data data_recv;
tcp::iostream data_stream("127.0.0.1", "2040"); /* Creating TCP stream */
boost::archive::binary_oarchive oa(data_stream);
oa << data_send;
boost::archive::binary_iarchive ia(data_stream); /* LINE Q */
ia >> data_recv; /* Receive LINE W */
data_stream.close();
Ну, это не работает.Это как-то блокирует.
Это любопытно, потому что проблема в этой двунаправленной схеме. Если я уберу строку Q, W, X, Y, ЭТО РАБОТАЕТ !!!Вы знаете, как решить эту проблему?