Boost Client 无法接收来自服务器的消息答案

【问题标题】：Boost Client not able to receive message from serverBoost Client 无法接收来自服务器的消息
【发布时间】：2017-04-05 15:31:28
【问题描述】：

我是 boost 库的新手，因此需要一些帮助来修改此函数以从服务器获取返回消息。

如果我删除代码的第二部分，服务器就可以从客户端读取消息。

但是当我尝试从服务器读取返回消息（第二部分中的代码）时，服务器给出错误“无法从套接字读取”

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);
 }

【问题讨论】：

你想返回什么？？
接收命令的软件的返回信息。
你的意思是你想在你做write_some之后返回服务器发送的响应？
是的，我想要来自服务器的返回消息。
你试过socket.read和家庭功能吗？另外，请明确提出您的问题。从您提出问题的方式来看，这一点都不清楚。

标签： c++ c++11 visual-c++ boost boost-asio

【解决方案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;
}

测试::

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!

【讨论】：