Comportement (aléatoire?) de send()/recv() ?
Bonjour,
J'essaie de comprendre les bases de l'utilisation des sockets en codant un serveur et un client minimaux en c++.
Le serveur crée un thread de communication avec chaque nouveau client, avec une boucle attendant les messages ( recv() avec un(e) socket en mode bloquant.
Un client peut envoyer un message au serveur via une fonction simple contenant un send() qui utilise un(e) socket bloquante.
Le mode de communication est connecté.
Les deux impriment ce qu'ils envoient / reçoivent sur la sortie standard.
Le client se connecte correctement.
Mon probleme vient du fait que si j'appelle 3 fois (par exemple) la fonction d'envoi de message du client, le serveur va recevoir 3 messages identiques à ceux envoyés (3 recv() à la suite) et c'est le comportement attendu, OU BIEN, avec les 2 mêmes exécutables, le serveur va recevoir 1 message contenant les 3 envoyés par le client.
voici une sortie:
Serveur recoit :Message test 1Message test 2Message test 3
42 bytes recus
une autre:
Serveur recoit :Message test 1
14 bytes recus
Serveur recoit :Message test 2
14 bytes recus
Serveur recoit :Message test 3
14 bytes recus
Apres plusieurs essais, je me rend compte que lorsque je viens de compiler le client, le serveur imprime le resultat attendu. Si je relance le serveur et le client, la mauvaise sortie est obtenue (42 bytes consécutifs). Si je recompile le client, j'ai a nouveau la bonne sortie...etc
Voici le code de la boucle de reception du coté serveur:
Code:
1
2
3
4
5
6
7
8
9
10
11
12
13
|
do{
memset(message, 0, MAX_MESSAGE_LEN);
res = recv(soc, message, sizeof message - 1, 0);
if(res > 0){
cout << "Serveur recoit :" << message << endl;
}else if(res == 0){
cout << "Connection lost" << endl;
}else{
cerr << "Serveur:Erreur reception de message" << endl;
}
cout << res << " bytes recus" << endl;
}while(res > 0); |
Voici la fonction d'envoi du client:
Code:
1
2
3
4
5
6
7
8
9
10
11
|
void Client::sendMessage(string m){
const char * msg = m.c_str();
cout << "Client envoie:" << msg << endl;
int res;
res = send(communicationSocket, msg, (int)strlen(msg), 0);
if(res < 0){
cerr << "Client : erreur d'envoi de message" << endl;
}
cout << res << " bytes envoyés" << endl;
} |
Et voila une partie du main:
Code:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
Serveur s;
Client c;
if(isServeur){
if(s.init()){
cerr << "erreur init serveur" << endl;
}
if(s.start()){
cerr << "erreur demarrage serveur" << endl;
}
}else{
if(c.init()){
cerr << "erreur init client" << endl;
}else{
cout << "client initialisé" << endl;
c.connectToServer(SERVER_ADDR);
}
c.sendMessage("Message test 1");
c.sendMessage("Message test 2");
c.sendMessage("Message test 3");
} |
Quelqu'un peut-il m'éclairer sur ce qui me semble être un grand mystère?
Merci d'avance! :)
