我有一个使用boost::asio进行读/写操作的C++服务器 - 写出消息没有问题 - 但由于某种原因,我无法使读取工作正常。
我从客户端发送到服务器的消息是15个16位无符号短整数 - 我的测试消息如下:
这是第三次运行,发送它一次(我不知道这里发生了什么)。
变量如下所示。
我从客户端发送到服务器的消息是15个16位无符号短整数 - 我的测试消息如下:
1, 34, 7, 0, 0, 0, 0, 0, 4, 0, 0, 0, 0, 0, 0
现在在服务器上,我经常看到像这样的东西。读取通常会被分割和/或乘以256。
这是一次运行两次发送的情况。
reading length = 8: [1 34 7 0 0 0 0 0]
reading length = 3: [1024 0 0]
reading length = 3: [0 0 0]
reading length = 8: [1 34 7 0 0 0 0 0]
reading length = 6: [1024 0 0 0 0 0]
这是第二次运行,发送两次
reading length = 8: [1 34 7 0 0 0 0 0]
reading length = 6: [1024 0 0 0 0 0]
reading length = 6: [1 34 7 0 0 0]
reading length = 1: [0]
reading length = 0: []
reading length = 0: []
reading length = 2: [0 0]
reading length = 2: [0 0]
reading length = 1: [0]
这是第三次运行,发送它一次(我不知道这里发生了什么)。
reading length = 14: [256 8704 1792 0 0 0 0 0 1024 0 0 0 0 0]
这里是实际的服务器读取代码
void Session::start(void) {
msg_interface->add_msg_listener(this);
_socket.async_read_some(
boost::asio::buffer(_read_data_buffer, READ_DATA_BUFFER_LENGTH),
boost::bind(&Session::handle_read, this, boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
void Session::handle_read(const boost::system::error_code& error, std::size_t bytes_transferred) {
if (error) {
msg_interface->remove_msg_listener(this);
delete this;
} else {
if (bytes_transferred != 0) {
// print what we've received
const int length = bytes_transferred / sizeof(uint16_t);
std::cout << "reading length = " << length << ": [";
for (int i = 0; i < length; i++) {
const uint16_t data = ntohs(_read_data_buffer[i]);
std::cout << data;
if (i != length - 1) {
std::cout << " ";
}
}
std::cout << "]" << std::endl;
}
_socket.async_read_some(
boost::asio::buffer(_read_data_buffer, READ_DATA_BUFFER_LENGTH),
boost::bind(&Session::handle_read, this, boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
}
变量如下所示。
const int READ_DATA_BUFFER_LENGTH = 1024;
class AbstractSession {
protected:
uint16_t _read_data_buffer[READ_DATA_BUFFER_LENGTH];
...
有一件事——当消息被接收时(服务器正在与旧接口通信,并将其接收到的消息发送给所有客户端),我使用相同的IO服务来编写消息并从客户端读取消息。同时使用相同的io服务会导致这种情况发生吗?
您有什么想法来解决这个问题吗?