Проблемы с использованием boost::asio::async_read()
Вот код, который я использую:
class Server
{
.....
void Server::accepted()
{
std::cout << "Accepted!" << std::endl;
boost::array<char, 1> buf;
boost::asio::async_read(socket, boost::asio::buffer(buf),
boost::bind(&Server::handleRead, this, buf, boost::asio::placeholders::error));
}
void Server::handleRead(boost::array<char, 1> buf, const boost::system::error_code& error)
{
if(!error)
{
std::cout << "Message: " << buf.data() << std::endl;
}
else
{
std::cout << "Error occurred." << std::endl;
}
}
.....
}
Проблема в том, что я всегда получаю от клиента одни и те же данные: конкретный символ. В моем клиенте я попытался отправить другой символ, но все равно сервер показывает тот же символ.
И когда я пытаюсь прочитать более 1 байта, я получаю ошибку, что buf
переменная используется до ее инициализации.
1 ответ
Решение
Вы используете локальную переменную buf
как буфер чтения, который опасен и не будет работать. Кроме того, вы просто отправляете исходное содержимое этого буфера в обработчик. Поэтому вместо этого вам нужно использовать буфер с более длительным сроком службы. Что-то вроде этого:
class Server
{
.....
boost::array<char, 1> buf;
void Server::accepted()
{
std::cout << "Accepted!" << std::endl;
boost::asio::async_read(socket, boost::asio::buffer(buf),
boost::bind(&Server::handleRead, this, boost::asio::placeholders::error));
}
void Server::handleRead(const boost::system::error_code& error)
{
if(!error)
{
std::cout << "Message: " << buf.data() << std::endl;
}
else
{
std::cout << "Error occurred." << std::endl;
}
}
.....
}
edit: или в качестве альтернативы, используя выделенный буфер кучи (не уверен, что код правильный, но вы поймете идею):
void Server::accepted()
{
std::cout << "Accepted!" << std::endl;
boost::shared_ptr<boost::array<char, 1>> buf(new boost::array<char, 1>);
boost::asio::async_read(socket, boost::asio::buffer(*buf),
boost::bind(&Server::handleRead, this, buf, boost::asio::placeholders::error));
}
void Server::handleRead(boost::shared_ptr<boost::array<char, 1>> buf, const boost::system::error_code& error)
{
if(!error)
{
std::cout << "Message: " << buf->data() << std::endl;
}
else
{
std::cout << "Error occurred." << std::endl;
}
}