Проблемы с использованием boost :: asio :: async_read () - PullRequest
Новая
       14

Проблемы с использованием boost :: asio :: async_read ()

5 голосов
/ 24 декабря 2010

Вот код, который я использую: 

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 Ответ

13 голосов
/ 24 декабря 2010

Вы используете локальную переменную 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;
    }
}
...