Aerospike无响应

Question

我正在用C++编写自己的Aerospike客户端，遇到了问题：虽然我的请求似乎已经到达服务器（如果发送无意义内容，连接将被断开），但服务器没有返回任何响应。

以下是我的代码：

#include <boost/asio.hpp>
#include <boost/array.hpp>
#include <iostream>

void read_message(boost::asio::ip::tcp::socket& socket)
{
    for (;;)
    {
      boost::array<char, 1> buf;
      boost::system::error_code error;
      size_t len = socket.read_some(boost::asio::buffer(buf), error);
      if (error == boost::asio::error::eof)
        break;
      else if (error)
        throw boost::system::system_error(error);
      std::cout.write(buf.data(), len);
      std::cout << std::endl;
    }
}

void send_message(boost::asio::ip::tcp::socket& socket, std::string message)
{
    boost::array<char, 1024> buf;
    std::copy(message.begin(), message.end(), buf.begin());
    boost::system::error_code error;
    socket.write_some(boost::asio::buffer(buf, message.size()), error);
}

int main()
{
    std::cout << "Connecting to socket.." << std::endl;
    boost::asio::io_service ios;
    boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), 3000);
    boost::asio::ip::tcp::socket socket(ios);
    socket.connect(endpoint);
    std::cout << "Connected to socket. Writing message." << std::endl;
    send_message(socket, "\x02\x01\x00\x00\x00\x00\x006build\nedition\nnode\nservice\nservices\nstatistics\nversion");
    std::cout << "Writed message. Reading response." << std::endl;
    read_message(socket);
    std::cout << "Read response. Exiting prigram." << std::endl;
    socket.close();
    return 0;
}

这段代码在与1.1.1.1:80等地址配合使用时工作正常 - 返回带有“Bad request”字样的HTML。

- General Grivus

Answer 1

你在 send_message() 函数中只调用了一次 socket.write_some() 方法。这基本上是假设所有字节都会在一次调用中发送。但实际上并没有这样的保证。当我测试你的代码时，它只发送了 2 个字节。除非所有字节都到达服务器，否则服务器不会响应（显然）。

- sunil