[socket] select() ou fork()?

select() ou fork()? [socket] - C++ - Programmation

Marsh Posté le 27-04-2005 à 09:24:49    

Bonjour!
 
Je développe un serveur communiquant par sockets TCP dont la contrainte principale est d'être portable sous linux et sous windows.
Ce serveur doit accepter plusieurs connexions (et réception de message) simultanées. Pour gérer cela, j'hésitais entre le classique fork et un select(). J'ai finalement implémenté ce serveur multi-clients avec un select() et les macros FD_SET, FD_ISSET...
Les connexions et les échanges de messages fonctionnent correctement en simultané, mais j'ai quand même un problème. Mon programme s'enmêle les pinceaux avec les IP des clients!! :??:  
 
J'ai créé une classe Masocket, ce qui permet d'éclaircir le code et de gérer la portabilité de manière transparente. Je déclare 1 objet Masocket correspondant au listener et un tableau contenant les objets Masocket correspondant au clients. Dans les exemples de code que j'ai pu trouver pour illuster l'utilisation du select(), les sockets sont toujours des int (unix).
Pour que ce soit plus clair, voici mon code :

Code :
  1. #include <stdio.h>
  2. #include <string.h>
  3. #include "Masocket.h"
  5. #ifdef _WIN32
  6. #include <winsock2.h>
  7. #pragma  comment(lib,"ws2_32.lib" )
  8. #else
  9. #include <unistd.h>
  10. #include <sys/socket.h>
  11. #include <sys/types.h>
  12. #include <netinet/in.h>
  13. #include <arpa/inet.h>
  14. typedef struct sockaddr_in SOCKADDR_IN;
  15. #endif
  17. #define PORT 3490
  18. #define MAXMSG 255
  19. Masocket clist [5];
  20. Masocket listener = Socketiam();
  21. fd_set master;
  22. fd_set temp;
  23. int fdmax;
  24. int i;
  26. void read_socks(){
  28. int listnum, client,newclient;
  29. bool loadsock=false;
  30. bool findsock=false;
  32. // run through the existing connections looking for data to read
  33.             for(i = 0; i <= fdmax; i++) {
  34.                 if (FD_ISSET(i,&temp)) {
  35.                     if (i == listener.getSock()) { //handle new connections
  36.   for (listnum = 0; listnum < 5 && (!loadsock); listnum++) {
  37.   if (clist[listnum].getSock()==0) {
  38.    newclient=listnum;
  39.    loadsock=true;
  40.   }
  41.  }
  42.  if (listener.acceptSock(clist[newclient])) {
  43. FD_SET(clist[newclient].getSock(),&master); // add to master set
  44. if (clist[newclient].getSock() > fdmax) {    // keep track of the maximum
  45. fdmax = clist[newclient].getSock();
  46. }
  47. printf("Got connection from \n",inet_ntoa(clist[newclient].getClientAddr().sin_addr));
  48. }
  49. }
  50. else { // handle data from a client
  51. for (listnum = 0; listnum < 5 && (!findsock); listnum++) {
  52. if (clist[listnum].getSock()==i) {
  53.      client=listnum;
  54.      findsock=true;
  55. }
  56. }
  57. if (clist[client].receive()==-1){
  58. printf(inet_ntoa(clist[client].getClientAddr().sin_addr));
  59. printf(" deconnect\r\n" );
  60. clist[client].kill(2);
  61. clist[client].closeSock();
  62. FD_CLR(i, &master); // remove from master set
  63. }
  64. }
  65. } // if
  66. } //for
  68. }
  70. void main(){
  71. int readsocks;      /* Number of sockets ready for reading */
  73. printf("Serveur demarre...\r\n" );
  75. listener.initSock(PORT,"" );
  76. listener.initServer(10);
  78. FD_ZERO(&master);
  79. FD_ZERO(&temp);
  81. listener.setinFD(master);
  82. fdmax = listener.getSock();
  84. while(TRUE)
  85. {
  86.  temp = master; // copy the master fd_set
  87.  readsocks =select(0, &temp, NULL, NULL, NULL);
  88.         if (readsocks < 0) {
  89.   perror("select" );
  90.   exit(EXIT_FAILURE);
  91.  }
  92.  if (readsocks == 0) {
  93.   printf("." );
  94.   fflush(stdout);
  95.  } else read_socks();
  97. }//while
  99. listener.closeSock();
  101. #ifdef _WIN32
  102. WSACleanup();
  103. #endif
  105. }


 
Concrètement, ma question est la suivante :  
Le fait que je manipule des objets non primitifs est-il un problème pour une gestion multi-clients avec select() ou ce problème peut-il être résolu? Est-ce fork() la solution pour conserver ma classe Masocket?
 
Question subsidiaire :  
Suis-je obligée de faire un tableau de Masocket? ou bien 1 Masocket pour le listener et 1 Masocket pour le client courant pourraient suffire?
Merci d'avance pour votre aide!

Reply

Marsh Posté le 27-04-2005 à 09:24:49   

Reply

Marsh Posté le 04-05-2005 à 11:52:14    

J'ai finalement résolu mon problème toute seule, merci pour votre aide! Vraiment très concluant de poster sur ce forum!!
L'embrouille au niveau des adresses IP des clients n'était en fait qu'une illusion. Le serveur fonctionnait correctement. C'est l'appel à inet_noa() qui conserve la dernière adresse..
Sinon, j'ai changé la structure de stockage de mes sockets pour une map.

Code :
  1. #include <map>
  3. std::map <int,Masocket> clientsmap;


 
En espérant que ce sujet, aide quelqu'un à défaut de m'avoir aidé moi!
 

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed