Comment fonctionne recv () ?

Version imprimable

24/04/2008, 18h11
mayu5

Comment fonctionne recv () ?

salut,
j'espère que vous m'aidez a comprendre comment fonctionne recv()
j'essai de faire ce truc pour une application client/serveur
le serveur a envoyé 2 messages au client, et le client ne fait recv()
apres un certain moment (sleep(1)) j'appelle recv()
alors normalement ces 2 messages sont stockés dans un buffer quelques part
donc jusque où on peut bufferiser de messages??
autre chose quand je fais recv(), normalement j'ai eu que le premier messages comment faire pour recuperer le 2ème et plus generalement comment je connais qu'il n'y a plus de messages a recevoir
merci d'avance
24/04/2008, 19h04
homeostasie

Citation:

Envoyé par mayu5

salut,
j'espère que vous m'aidez a comprendre comment fonctionne recv()

Déjà, as tu jeté un coup d'oeil sur :google2: et sur man developpez recv.

Citation:

Envoyé par mayu5

j'essai de faire ce truc pour une application client/serveur
le serveur a envoyé 2 messages au client, et le client ne fait recv()

Tu peux toujours montrer un peu ce que tu as fait.

Citation:

apres un certain moment (sleep(1)) j'appelle recv()

Je suis pas certain que tu as une résolution de 1ms...

Citation:

alors normalement ces 2 messages sont stockés dans un buffer quelques part
donc jusque où on peut bufferiser de messages??

Le buffer, c'est toi qui le déclares donc tu dois bien savoir où les données reçues sont stockées.

Citation:

autre chose quand je fais recv(), normalement j'ai eu que le premier messages comment faire pour recuperer le 2ème et plus generalement comment je connais qu'il n'y a plus de messages a recevoir
merci d'avance

La fonction recv() est bloquante. Donc tant que ton soft n'est pas bloqué sur cette fonction, c'est que tu reçois des données ou un cas d'erreur.
24/04/2008, 20h12
Emmanuel Delahaye

Citation:

Envoyé par mayu5

j'espère que vous m'aidez a comprendre comment fonctionne recv()
j'essai de faire ce truc pour une application client/serveur
le serveur a envoyé 2 messages au client, et le client ne fait recv()
apres un certain moment (sleep(1)) j'appelle recv()
alors normalement ces 2 messages sont stockés dans un buffer quelques part
donc jusque où on peut bufferiser de messages??

Oui.

Citation:

autre chose quand je fais recv(), normalement j'ai eu que le premier messages comment faire pour recuperer le 2ème et plus generalement comment je connais qu'il n'y a plus de messages a recevoir

Tu boucles sur recv(). C'est comme avec fgets(). Ça devient bloquant quand il n'y a plus rien à lire...

Nota. En mode connecté (TCP etc.), si recv() retourne 0, c'est que la connexion n'est plus établie. Attention, recv() nest alors plus bloquant et il faut sortir de la boucle.

Nota : il n'est pas utile d'ajouter des suspensions (ton sleep(1) ne sert à rien)

Un peu de lecture :

http://emmanuel-delahaye.developpez.com/reseaux.htm

j'espere que voue seriez plus patient(je suis en grande confusion:aie:)
voici un petit exemple où le serveur envoie plusieurs messages et je veux qu'au moment le client va lire des données normalement tout ces messages sont envoyés
serveur:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#define SOCKET_ERROR -1
#define SERVPORT 23
#define QUEUE_SIZE 10
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
#include<stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#define buffer_size 100
int main (void){
 
	SOCKET servsock, clisock;
	SOCKADDR_IN servaddr, cliaddr;
	int addrsize = (int) sizeof cliaddr;
    	int sock,sock_err,one;
 
    	servsock = socket (AF_INET, SOCK_STREAM, 0);
	if(servsock<0)
	{
		perror("socket failed()\n");
		exit(-1);
	}
        setsockopt(servsock, SOL_SOCKET, SO_REUSEADDR, (char *)&one, sizeof(one)); 
	memset((char*)&servaddr,0,sizeof(servaddr));
        servaddr.sin_addr.s_addr= htonl (INADDR_ANY);
        servaddr.sin_family= AF_INET;            
        servaddr.sin_port= htons (SERVPORT); 
 
        //error case
    	if((sock_err = bind (servsock, (SOCKADDR *) &servaddr, sizeof servaddr))<0)
	{
		perror("bind()failed\n");
		close(servsock);
		exit(-1);
	}	
    	if((sock_err = listen (servsock, QUEUE_SIZE))<0)
	{
	perror("listen failed()\n");
	close(servsock);
	exit(-1);
	}
        printf("serveur en attente de connexion...\n");
	memset((char  *)&cliaddr,0,sizeof(cliaddr)); 
	cliaddr.sin_addr.s_addr= htonl(SERVPORT);        
        cliaddr.sin_family= AF_INET;            
        cliaddr.sin_port= htons(SERVPORT);     
	if((clisock=accept(servsock,(SOCKADDR *) &cliaddr, &addrsize))<0)
	{
	perror("accept()failed\n");
	close(servsock);
	}
 
	printf("client connecté\n");	
	char b1[]="bienvenue sur ";
	sock_err = send(clisock, b1, sizeof(1), 0);
	if (sock_err != SOCKET_ERROR) printf("Chaine envoy�e : %s\n", b1);
	char b2[]="le forum ";
	sock_err = send(clisock, b2, sizeof(b2), 0);
	if (sock_err != SOCKET_ERROR) printf("Chaine envoy�e : %s\n", b2);
	char b3[]="de developpez ";
	sock_err = send(clisock, b3, sizeof(b3), 0);
	if (sock_err != SOCKET_ERROR) printf("Chaine envoy�e : %s\n", b3);
	close(servsock);
        return EXIT_SUCCESS;
 
}

client:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#define SOCKET_ERROR -1
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define taille 1024
int main (void)
{
    int erreur = 0;
    SOCKET sock;
    SOCKADDR_IN sin;
    char buffer[taille];    
   int sock_err,iof;
        // Cr�ation de la socket
        sock = socket(AF_INET, SOCK_STREAM, 0);
        // Configuration de la connexion
        sin.sin_addr.s_addr = inet_addr("127.0.0.1");
        sin.sin_family = AF_INET;
        sin.sin_port = htons(23 );
        // Si l'on a r�ussi � se connecter	
        if(connect(sock, (SOCKADDR *)&sin, sizeof(sin)) != SOCKET_ERROR)
        {
		sleep(2);
        	printf("Connection � %s sur le port %d\n", inet_ntoa (sin.sin_addr), htons(sin.sin_port));
        	int n;
		n = recv (sock, buffer, sizeof buffer, 0);
		if (n > 0)
			printf("%s\n",buffer);
                n = recv (sock, buffer, sizeof buffer, 0);
		if (n > 0)
			printf("%s\n",buffer);
        }
        else printf("Impossible de se connecter\n");
	return EXIT_SUCCESS;
}

resultat:
bien le forum

Citation:

Envoyé par mayu5

voici un petit exemple où le serveur envoie plusieurs messages et je veux qu'au moment le client va lire des données normalement tout ces messages sont envoyés
serveur:

Euh :

Citation:

Code:

1
2
3
 
   char b1[] = "bienvenue sur ";
   sock_err = send (clisock, b1, sizeof (1), 0);

C'est censé faire quoi ?

- C'est pas 1 mais probablement b1.
- C'est pas sizeof, mais strlen() qu'il faut utiliser (on ne transmet pas de zéro avec du texte).

Code:

1
2
3
4
5
 
Connection ? 127.0.0.1 sur le port 23
bienvenue sur $
le forum
Appuyez sur une touche pour continuer...

Ca commence à venir. En mettant strlen() partout :

Code:

1
2
3
4
 
Connection ? 127.0.0.1 sur le port 23
bienvenue sur le forum de developpez Æ|♦
Appuyez sur une touche pour continuer...

Il va falloir aussi travailler sur la réception...

Erreur habituelle :

Citation:

Code:

1
2
3
4
5
 
int n;
n = recv (sock, buffer, sizeof buffer, 0);
if (n > 0)
printf("%s\n",buffer);

Il faut réserver une place pour le 0 et placer celui-ci à la main :

Code:

1
2
3
4
5
6
7
8
9
10
 
{
   <...>
   int n;
   n = recv (sock, buffer, sizeof buffer - 1, 0);
   if (n > 0)
   {
      buffer[n] = 0;
      printf ("%s\n", buffer);
   }

Et voilà :

Code:

1
2
3
4
 
Connection ? 127.0.0.1 sur le port 23
bienvenue sur le forum de developpez
Appuyez sur une touche pour continuer...

Dans le client, il n'y a pas besoin de suspension. Ceci fonctionne :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
#if defined (WIN32)
#include <winsock2.h>
#elif defined (linux)
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#define INVALID_SOCKET -1
#define SOCKET_ERROR -1
#define closesocket(s) close (s)
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
#endif
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
 
int client (void)
{
// Creation de la socket
   SOCKET  sock = socket (AF_INET, SOCK_STREAM, 0);
   SOCKADDR_IN sin = {0};
   char buffer[1024];
// Configuration de la connexion
   sin.sin_addr.s_addr = inet_addr ("127.0.0.1");
   sin.sin_family = AF_INET;
   sin.sin_port = htons (23);
// Si l'on a reussi a se connecter
   if (connect (sock, (SOCKADDR *) & sin, sizeof (sin)) != SOCKET_ERROR)
   {
      printf ("Connection a %s sur le port %d\n", inet_ntoa (sin.sin_addr),
              htons (sin.sin_port));
      {
         int n = recv (sock, buffer, sizeof buffer - 1, 0);
         if (n > 0)
         {
            buffer[n] = 0;
            printf ("%s\n", buffer);
         }
      }
   }
   else
      printf ("Impossible de se connecter\n");
   return EXIT_SUCCESS;
}
 
int main (void)
{
#if defined (WIN32)
   WSADATA WSAData;
   int erreur = WSAStartup (MAKEWORD (2, 0), &WSAData);
#else
   int erreur = 0;
#endif
   client ();
#if defined (WIN32)
   WSACleanup ();
#endif
   system ("pause");
 
   return 0;
}

Voici le serveur corrigé :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
 
#include "psleep/inc/psleep.h"
 
#if defined (WIN32)
#include <winsock2.h>
#elif defined (linux)
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#define INVALID_SOCKET -1
#define SOCKET_ERROR -1
#define closesocket(s) close (s)
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
#endif
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
 
#define buffer_size 100
#define SERVPORT 23
#define QUEUE_SIZE 10
 
int server (void)
{
   int ret = EXIT_SUCCESS;
   SOCKET servsock = socket (AF_INET, SOCK_STREAM, 0);
   if (servsock == INVALID_SOCKET)
   {
      perror ("socket failed()\n");
      ret = EXIT_FAILURE;
   }
   else
   {
      int sock_err;
      SOCKADDR_IN servaddr = { 0 };
 
#if 0
      {
         int one;
         setsockopt (servsock, SOL_SOCKET, SO_REUSEADDR, (char *) &one,
                     sizeof (one));
      }
#endif
 
      servaddr.sin_addr.s_addr = htonl (INADDR_ANY);
      servaddr.sin_family = AF_INET;
      servaddr.sin_port = htons (SERVPORT);
 
//error case
      if ((sock_err =
           bind (servsock, (SOCKADDR *) & servaddr, sizeof servaddr)) < 0)
      {
         perror ("bind()failed\n");
         ret = EXIT_FAILURE;
         ret = EXIT_FAILURE;
      }
      else if ((sock_err = listen (servsock, QUEUE_SIZE)) < 0)
      {
         perror ("listen failed()\n");
         ret = EXIT_FAILURE;
         ret = EXIT_FAILURE;
      }
      else
      {
         SOCKET clisock;
         SOCKADDR_IN cliaddr = { 0 };
         int addrsize = (int) sizeof cliaddr;
         cliaddr.sin_addr.s_addr = htonl (SERVPORT);
         cliaddr.sin_family = AF_INET;
         cliaddr.sin_port = htons (SERVPORT);
 
         printf ("serveur en attente de connexion...\n");
 
         if ((clisock =
              accept (servsock, (SOCKADDR *) & cliaddr,
                      &addrsize)) == INVALID_SOCKET)
         {
            perror ("accept()failed\n");
            ret = EXIT_FAILURE;
         }
         else
         {
            printf ("client connecte\n");
 
            {
               char b1[] = "bienvenue sur ";
               sock_err = send (clisock, b1, strlen (b1), 0);
               if (sock_err != SOCKET_ERROR)
                  printf ("Chaine envoyee : %s\n", b1);
            }
 
            {
               char b2[] = "le forum ";
               sock_err = send (clisock, b2, strlen (b2), 0);
               if (sock_err != SOCKET_ERROR)
                  printf ("Chaine envoyee : %s\n", b2);
            }
 
            {
               char b3[] = "de developpez.";
               sock_err = send (clisock, b3, strlen (b3), 0);
               if (sock_err != SOCKET_ERROR)
                  printf ("Chaine envoyee : %s\n", b3);
            }
         }
      }
      closesocket (servsock);
   }
   return ret;
 
}
 
int main (void)
{
   int ret;
#if defined (WIN32)
   WSADATA WSAData;
   int erreur = WSAStartup (MAKEWORD (2, 0), &WSAData);
#else
   int erreur = 0;
#endif
   ret = server ();
#if defined (WIN32)
   WSACleanup ();
#endif
   return ret;
}

Pose des questions si tu ne comprends pas. Je conseille néanmoins de lire ceci avant :

http://emmanuel-delahaye.developpez.com/reseaux.htm

28/04/2008, 09h39
mayu5

je vous mercie pour votre reponse, ça me permet de fixer des idées correctes
le probleme etait que j'ai mal compris recv(), en fait dans une connexion tcp on parle pas de messages mais de flux et recv() au moment où elle est appelée elle reçoit tous ce qui est dans le buffer que c'est soit un "message" ou plus.
alors maitenent je dois voir dans mes données reçus pour pouvoir séparer les différents messages.
merci encore une fois.
28/04/2008, 09h57
Emmanuel Delahaye

Citation:

Envoyé par mayu5

alors maitenent je dois voir dans mes données reçus pour pouvoir séparer les différents messages.

Il est d'usage dans un protocole applicatif 'texte', d'utiliser les lignes, c'est à dire de terminer les messages par '\n'.
28/04/2008, 10h35
mayu5

ben, je vois encore une fois l'utilité des flux xml mais selon mes connaissances il faut parser le flux et construire chaque document a part et ca sera trop bavard ou simplement le traiter comme une chaine de caracteres et chercher le debut et la fin du document