Discussion :

[asphalte]

Bonjour, je suis en train de faire un petit chat en C en utilisant les sockets sous Linux.
J'en suis a essayé de renvoyer à tous les clients connectés un message reçu par le serveur. Pour cela, j'ai le descripteur de socket de chaque client dans le serveur. Je me sers de ses descripteurs pour communiquer avec tous les clients (enfin j'aimerais pour le moment).
Voici le code du serveur :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
  listen(sd,MAXCLIENT);
  ladcour=sizeof(adclcour);
  for(;;)
    {
      if((nsd=accept(sd,(struct sockaddr*)&adclcour,(socklen_t*)&ladcour))<0)
	{
	  perror(">>Probléme avec accept");
	  exit(1);
	}
      printf("nsd :: %d\n",nsd);
  /* Récupération du nom du client */
      if(cherche(adclcour.sin_addr.s_addr,liste_cl,nb_client)==-1)
	{
	  printf("traitement nom\n");
	  FD_SET(nsd,&ensemble);
	  nsdbis=select(20,&ensemble,NULL,NULL,&timer);
	  if(nsdbis)
	    {
	      read(nsd,buf,sizeof(buf));
	      liste_cl[nb_client].ip=adclcour.sin_addr.s_addr;
	      strcpy(liste_cl[nb_client].nom,buf);
	      strcat(liste_cl[nb_client].nom," : ");
	      liste_cl[nb_client].soc=nsd;
	      nb_client++;
	      printf("%s est %s\n",(char*)inet_ntoa(liste_cl[nb_client-1].ip),liste_cl[nb_client-1].nom);
	      close(nsd);
	    }
	  else
	    {
	      write(nsd,"Resaisir le nom",strlen("Resaisir le nom"));
	      close(nsd);
	    }
	  timer.tv_sec = 5;
	}
      else
	{
	  if(fork()==0)
	    {
	      /* Traitement des messages */
	      printf("Traitement messages\n");
	      close(sd);
	      nu_client=cherche(adclcour.sin_addr.s_addr,liste_cl,nb_client);
	      printf("Client considéré :: %s\n",liste_cl[nu_client].nom);
	      renvoi(liste_cl[nu_client].soc, liste_cl,nu_client,nb_client);
	      exit(0);
	    }
	  else
	    close(nsd);

Pour le moment, j'arrive à communiquer avec n clients sur mon serveur. Mon serveur connait toutes les ips des clients.
Voyez vous une autre façon de communiquer avec tous les clients, sans utiliser les threads. Je pense que mon problème est lié au stockage des descripteurs de socket et à ma gestion des sockets... Je n'ai pas réussi à trouver la solution à mon problème alors si vous pouvez m'éclairer un peu...

[crocodilex]

[...]
Voyez vous une autre façon de communiquer avec tous les clients, sans utiliser les threads.
[...]

Il y a une solution, c'est de passer ta socket en mode UDP et de faire du "broadcast".

[granquet]

Il y a une solution, c'est de passer ta socket en mode UDP et de faire du "broadcast".

du broadcast? comment ça?

pour moi la solution la plus simple est d'utiliser select dans un thread jusqu'a FD_SETSIZE clients.
au dela, soit tu drop, soit tu fait un nouveau thread qui vas accepter encore FD_SETSIZE clients ...

FD_SETSIZE vaut 1023 en principe sur les unixoïdes ... et une rumeurs dis que ça tourne autour de 128 pour les windowsoïdes.
chiffres a confirmer!

ensuite, soit tu definis un nombre max de clients qui pourrons se connecter (genre 4 * FD_SETSIZE) et tu fait un tableau d'entiers qui contiens tes sockets.
soit tu fait une liste chainée et t'as plus de limite en nombre de clients.

[crocodilex]

du broadcast? comment ça?

Ce qu'il veut c'est envoyer un meme message à tout ses clients connectés. Le broadcast sert à ça non ? Ou alors je n'ai rien compris au problème...

[Lunixinclar]

Salut, C'est sûr que le broadcast est l' alternative mais elle ne se fait pas en TCP. Et il faut tout ré-écrire. La modif ici est:
Avant d'invoquer accept(), il faut copier le master (nommé ici "ensemble"), faire un select() sur la copie, pour faire une boucle sur tous les clients: FD_ISSET(n, &copie); détermine si un évènement est arrivé. Dans ce cas
Si n = le socket qui écoute, alors un nouveau client se connecte c'est là qu'il faut accept().
Sinon c'est que des données arrivent d'un client. Pour répercuter ce message vers tous les autres un

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
for(j = 0; j <= NBUSERS; j++)
{ 
  if (FD_ISSET(j, &master))
  { 
   if (j != listener)// && j != i) // ni lui ni moi
     if (send(j, strOUT, strlen(strOUT), 0) == -1) perror("send");
  }
}

suffit, pas besoin de fork.
Ce n'est probablement pas clair mais tout est dans le titre.

[asphalte]

Pour le broadcast, comme ça été dit, ceci m'oblige à tout refaire ce qui ne m'enchante pas trop. Je préfèrerai éviter d'utiliser un thread pour l'écoute (c'est pour un TP et ça ne colle pas trop avec le sujet). Je vais donc tester la dernière solution, enfin essayer car je n'ai pas tout compris surtout au niveau du principe de faire une copie du "master".
Je teste et je vous tiens au courant...

[asphalte]

Finit le problème. En laissant ma socket de communication ouverte, le accept() me génère bien des descripteurs de socket diffèrents. Du coup, chaque client possède une ip et une socket propre à lui et de descripteur fixe. Je peux donc facilement communiquer avec chacun d'entre eux. A condition que tout soit bien synchronisé.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
  for(;;)
    {
      if((nsd=accept(sd,(struct sockaddr*)&adclcour,(socklen_t*)&ladcour))<0)
	{
	  perror(">>Probléme avec accept");
	  exit(1);
	}
      printf("nsd :: %d\n",nsd);
      if(cherche(adclcour.sin_addr.s_addr,liste_cl,nb_client)==-1)
	{
	  printf("traitement nom\n");
	  FD_SET(nsd,&ensemble);
	  nsdbis=select(20,&ensemble,NULL,NULL,&timer);
	  if(nsdbis)
	    {
	      read(nsd,buf,sizeof(buf));
	      liste_cl[nb_client].ip=adclcour.sin_addr.s_addr;
	      strcpy(liste_cl[nb_client].nom,buf);
	      strcat(liste_cl[nb_client].nom," : ");
	      liste_cl[nb_client].soc=nsd;
	      printf("%s est %s\n",(char*)inet_ntoa(liste_cl[nb_client-1].ip),liste_cl[nb_client-1].nom);
	      write(liste_cl[nb_client].soc,"Connexion établie\n",strlen("Connexion établie\n"));
	      nb_client++;
	      //close(nsd);
	    }
	  else
	    {
	      write(nsd,"Resaisir le nom",strlen("Resaisir le nom"));
	      close(nsd);
	    }
	  timer.tv_sec = 5;
	  for(i=0;i<nb_client;i++)
	    printf("%s utilise %d\n",liste_cl[i].nom,liste_cl[i].soc);
	}
      else
	{
	  if(fork()==0)
	    {
	      /* Traitement des messages */
	      printf("Traitement messages\n");
	      close(sd);
	      nu_client=cherche(adclcour.sin_addr.s_addr,liste_cl,nb_client);
	      printf("Client considéré :: %s\n",liste_cl[nu_client].nom);
	      renvoi(liste_cl[nu_client].soc, liste_cl,nu_client,nb_client);
	      exit(0);
	    }

Merci pour vos réponses

[Lunixinclar]

Quelle drole de cuisine.
Enlever la boucle sur nb_client produit ce que tu voulais (à savoir, envoyer un msg à tous les clients)?
La fonction cherche() est une fonction BSD? Est-elle vraiment nécessaire?
Faire un fork par client donne de meilleures performances? Est-ce vraiment nécessaire?

[asphalte]

>Je ne vois pas trop de quel boucle for tu parles. Si c'est de celle la ->

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
	  for(i=0;i<nb_client;i++)
	    printf("%s utilise %d\n",liste_cl[i].nom,liste_cl[i].soc);

Elle ne fait rien qu'afficher. Le "broadcast" est fait par la fonction renvoi ->

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
  for(i=0;i<nb_client;i++)
    if(liste_cl[i].ip!=liste_cl[nu_client].ip)
      {
	printf("broadcast vers %s :: %s\n",liste_cl[i].nom,mesg);
	if(send(liste_cl[i].soc,mesg,strlen(mesg),0)<0)
	  {
	    perror(">> Prob sur le write 1");
	    exit(1);
	  }
      }

>La fonction cherche() est une fonction que j'ai créé. Elle me permet de rechercher un client d'après une ip dans ma structure liste_cl.
>Faire un fork par client me permet d'avoir un processus fils pour discuter avec un client. Pas besoin de faire de select() pour savoir si un client a parlé. C'est utile lors de la connexion de plusieurs client.