没有来自Aerospike的回应

No response from Aerospike

本文关键字:回应 Aerospike      更新时间:2023-10-16

我正在用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, "x02x01x00x00x00x00x006buildneditionnnodenservicenservicesnstatisticsnversion");
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。

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