Boost Клиент не может получать сообщение с сервера

Question

Я новичок в создании библиотеки, поэтому вам нужно помочь в изменении этой функции, чтобы получить сообщение возврата с сервера.

Если я удалю вторую часть кода, сервер сможет читать сообщение от клиента.

Но когда я пытаюсь прочитать ответное сообщение от сервера (кода во второй части) сервер выдает сообщение об ошибке «Не удается прочитать из гнезда»

void send_something(std::string host, int port, std::string message) 
{ 
    boost::asio::io_service ios; 

    boost::asio::ip::tcp::endpoint 
    endpoint(boost::asio::ip::address::from_string(host), port); 
    boost::asio::ip::tcp::socket socket(ios); 
    socket.connect(endpoint); 
    boost::array<char, 128> buf; 
    std::copy(message.begin(),message.end(),buf.begin()); 
    boost::system::error_code error; 
    socket.write_some(boost::asio::buffer(buf, message.size()), 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(), len); 
} 

Answer 1

Вот код, который делает то, что вы хотите. Обратите внимание, что я не реализовал кадрирование для получения данных с сервера, так что может получиться или не получиться, что вы получите полные данные.

Если вы хотите получить полное сообщение с сервера, вы можете перемещаться вокруг read_some так же, как это делается для write_some, пока ваш размер прочитанного сообщения не будет равен ожидаемому.

Есть и другие вкусы чтения, а также read_until, с помощью которых вы позволяете asio собирать отклик, пока не увидите указанный шаблон, например, новую строку ('\ n' или \ r \ n).

#include <iostream> 
#include <array> 
#include <string> 
#include <system_error> 
#include <asio.hpp> 


void send_something(std::string host, int port, std::string message) 
{ 
    asio::io_service ios; 

    asio::ip::tcp::endpoint 
    endpoint(asio::ip::address::from_string(host), port); 
    asio::ip::tcp::socket socket(ios); 
    socket.connect(endpoint); 

    std::error_code error; 
    size_t len = 0; 
    // Write the complete message 
    while (len < message.length()) { 
     len += socket.write_some(asio::buffer(message), error); 
    } 

    std::array<char, 128> buf; 
    socket.read_some(asio::buffer(buf), error); 

    if (error == asio::error::eof) 
    { 
     std::cout << "Connection closed by server\n"; 
    } 
    else if (error) 
    { 
     std::cout << "ERROR in connection" << std::endl; 
     return; 
    } 

    std::cout << "Received: " << buf.data() << std::endl; 
} 


int main() { 
    send_something("127.0.0.1", 7869, "Hello!"); 
    return 0; 
} 

TEST ::

Python 2.7.10 (default, Jul 14 2015, 19:46:27) 
[GCC 4.2.1 Compatible Apple LLVM 6.0 (clang-600.0.39)] on darwin 
Type "help", "copyright", "credits" or "license" for more information. 
>>> import socket as sock 
>>> sd = sock.socket(sock.AF_INET, sock.SOCK_STREAM) 
>>> sd 
<socket._socketobject object at 0x1088d2c20> 
>>> sd.bind(("localhost", 7869)) 
>>> sd.listen(2) 
>>> c, a = sd.accept() 
>>> c 
<socket._socketobject object at 0x1088d2c90> 
>>> buf = c.recv(512) 
>>> buf 
'Hello!' 
>>> 
>>> c.send("Cool!") 
5 

MacBook-Pro:asio_test amuralid$ g++ -g -std=c++14 -I ~/asio-master/asio/include/ -o client_read_so client_read_so.cc -pthread 

MacBook-Pro:asio_test amuralid$ ./client_read_so 
    Received: Cool!