0

在我的代码中，我设置了一个客户端和服务器套接字，以使用 asio 模拟两者之间的交互。不幸的是，我的 read() 出现了一些问题，我不完全确定我没有正确传递什么以及为什么。当我运行它时，它会无限期地等待。可能是我缺少的东西吗？

boost::asio::io_service ioservice;
tcp::acceptor acceptor(ioservice);
tcp::socket client(ioservice);
tcp::socket server(ioservice);

boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), 2222);

acceptor.open(endpoint.protocol());
acceptor.bind(endpoint);
acceptor.listen();
acceptor.async_accept(server, &acc_handle);

client.async_connect(endpoint, &conn_handle);

ioservice.run();

boost::asio::write(client, boost::asio::buffer("test"));

boost::asio::streambuf bfr;
boost::asio::read(client, bfr);

编辑：添加了处理程序，它们只是记录信息，所以我省略了它们的定义。

4

1 回答 1

0

如果这是真正的代码流，那么在ioservice.run();您停止它之前不会执行任何ioservice操作，此时也不会执行任何操作。代码需要驻留在这些异步处理程序中。

由于您没有包含处理程序的定义，因此很难掌握正在发生的事情，但我会尝试进行预测：

acc_handle应该包含server.async_receive(read_buffer, [](const boost::system::error_code&, size_t){...});一个.

,conn_handle应该包含 a client.async_send(write_buffer, endpoint, [](const boost::system::error_code&, size_t){...});，此时您应该能够看到服务器的接收处理程序触发。

话虽如此，我强烈建议您阅读http://www.boost.org/doc/libs/1_64_0/doc/html/boost_asio/examples/cpp11_examples.html上的相关示例，因为它们写得清晰干净。

于 2017-08-17T00:59:06.760 回答