Problèmes d'utilisation de boost::asio::async_read()

Voici le code que j'utilise:

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;
    }
}

.....
}

Le problème est que je reçois toujours les mêmes données à partir du client: un char.
Dans mon client j'ai essayé d'envoyer un autre char, mais encore le serveur affiche le même char.

Et quand j'essaie de lire plus de 1 octets, j'obtiens une erreur que le buf variable est utilisée avant d'être initialisé.

InformationsquelleAutor Moshe Revah | 2010-12-24
  1. 13

    Vous êtes à l'aide de la variable locale buf que la mémoire tampon de lecture, ce qui est dangereux et ne fonctionne pas. Aussi, vous êtes juste à l'envoi de l'original du contenu de la mémoire tampon pour le gestionnaire. Donc, au lieu de cela, vous devez utiliser un tampon avec une durée de vie plus longue. Quelque chose comme ceci:

    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;
    }
}

.....
}

    modifier: ou, alternativement, à l'aide d'un segment de mémoire tampon alloué (je ne sais pas si le code est bon, mais vous obtenez l'idée):

    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;
    }
}
    • +1 lors de l'utilisation de méthodes asynchrones, c'est l'appelant responsabilité de veiller à ce que le tampon est valable pendant toute la durée de l'appel.
    • Merci ça fonctionne, mais avec un petit problème. J'ai configuré le client pour l'envoi de "aaaaaa" et le serveur pour lire les 6 caractères. Le serveur est correctement lire les caractères, mais pas proprement: "Message: aaaaaaÌÌÌÌÌÌ(c2.ˆ÷0". C'est la sortie, je vois dans la console du serveur. J'ai aussi essayé d'écrire buf.de données() dans un fichier, mais toujours le même résultat.
    • C'est parce que la chaîne n'est pas null. Si vous avez besoin d'utiliser un 7 tampon de caractères, et le client d'envoyer une chaîne terminée par null ou ont la configuration du serveur de la 7ème caractère null manuellement. Ou vous pourriez utiliser std::string comme le tampon, rappelez-vous juste de les appeler .redimensionner(6) avant de l'utiliser.
    • Ainsi, le dernier problème n'était pas lié à boost::asio 🙂 merci, ça fonctionne très bien.
    • +1, Vous avez résolu mon problème aussi!
    InformationsquelleAutor Timo