Boost.Asio简单客户端服务器模型不返回响应

Question

尝试第一次在boost.asio上构建我的客户端服务器时，服务器对客户端的响应为空。我不确定是什么问题 - 很乐意提供任何帮助。

服务器代码：

const std::string message = "Hi";
        boost::system::error_code ignored_error;
        try
        {
                boost::asio::io_service io_service;
                tcp::endpoint endpoint = tcp::endpoint(tcp::v4(), 12345);
                tcp::acceptor acceptor(io_service,endpoint);
                for (;;){
                        tcp::socket socket(io_service);
                        acceptor.accept(socket);
                   boost::asio::write(socket,boost::asio::buffer(message), ignored_error);
                }

        }
        catch (std::exception& e){
                std::cerr << e.what() << std::endl;
        }

客户代码：

        try{
        boost::asio::io_service io_service;
        tcp::resolver resolver(io_service);
        tcp::resolver::query query(IP, "12345");
        tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
        tcp::socket socket(io_service);
        boost::asio::connect(socket, endpoint_iterator);
        for (;;)
        {
                std::string buf;
                boost::system::error_code error;



                size_t len = socket.read_some(boost::asio::buffer(buf), error);           
                if (error == boost::asio::error::eof)
                        break; // Connection closed cleanly by peer.
                else if (error)
                        throw boost::system::system_error(error); // Some other error.
                std::cout.write(buf.data());
        }
}
catch (std::exception& e)
{
        std::cerr << e.what() << std::endl;
}

Answer 1

socket.read_some将数据读入由boost::asio::buffer(buf)定义的缓冲区。此缓冲区的大小由buf.size()确定。在您的情况下，std::string为空，因此用于读取字节的缓冲区为空。 read_some读取0个字节并返回。

因为服务器总是发送一个由2个字节组成的消息，所以你可以调整buf的大小来保存2个字节：

std::string buf;
buf.resize(2);
boost::system::error_code error;
size_t len = socket.read_some(boost::asio::buffer(buf), error); 
// now read_some reads at most 2 bytes into buf

因为在服务器端创建了一个套接字，它会发送消息并被销毁，你可以使用dynamic_buffer + transfer_all + boost::asio::read来读取非固定长度的消息：

std::string buf;
size_t len = boost::asio::read (socket,boost::asio::dynamic_buffer(buf),
    boost::asio::transfer_all(),error);
if (len && error == boost::asio::error::eof)
{ 
  // data was read from server and eof is reached
  // do sth with buf
}

boost::asio::read读取数据，直到缓冲区被完全读取或发生一些错误（例如eof - 服务器端的socket已关闭）。服务器发送数据，客户端读取数据，服务器上的套接字被破坏，客户端从eof获取asio::read。