Aerospike 没有回应

Question

我正在用C++编写自己的Aerospike客户端，遇到一个问题：虽然我的请求似乎到达了服务器（如果你发送废话，连接将被丢弃），但服务器并没有return任何回应。

这是我的代码：

#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 - HTML 是 return 用 "Bad request".

字词编辑的

Answer 1

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

Aerospike 没有回应

No response from Aerospike

c++

aerospike