C++在通道上Boost TCP序列化对象，双向通信不起作用

Question

我有一堂课，一堂非常愚蠢的课。此类的对象，我想使用 asio by boost 通过 tcp 发送它们。我的类正确地与 boost 东西建立了友谊并实现了方法序列化...

好吧，我希望客户端连接到服务器，向其发送我的对象，然后服务器发回同一类的另一个对象。

我尝试这样做：

在服务器中：

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 线，它就可以工作！ 你知道如何解决这个问题吗？

Answer 1

您需要在客户端中调用流上的刷新

oa << data_send;
data_stream.flush();