UNIX, serveur multiconnexion(thread) pour tchat

UNIX, serveur multiconnexion(thread) pour tchat - C++ - Programmation

Marsh Posté le 14-06-2007 à 09:58:36    

Bonjour, je suis un développeur amateur... j'aurais eu besoin d'aide pour rendre mon code compatible avec le multithread, j'ai essayer de trouver de la doc..... mais je n'y comprends rien, s'il vous plait, quelqu'un pourrait me donner les modification a faire pour parvenir a mes fin??? j'ai mit mon code juste en dessou
Je vous en remerci grandement, et d'avance :p
 

Code :
  1. #include <sys/types.h>
  2. #include <sys/socket.h>
  3. #include <netinet/in.h>
  4. #include <fcntl.h>
  5. #include <netdb.h>
  6. #include <iostream>
  7. #include <string.h>
  8. #include <unistd.h>
  10. using namespace std;
  12. #define TAILLEMAX 256
  13. #define PORT 2708
  14. #define SOCKET_ERROR -1
  15. #define INVALID_SOCKET -1
  16. #define CONNEXION_MAX 3
  18. class connexion
  19. {
  20. private:
  21. struct sockaddr_in serv_ad, client_ad,sin;
  22. int sockd,sockcli,ex;
  23. public:
  25. connexion()
  26. {
  27. sockd=socket(AF_INET,SOCK_STREAM,0);
  28. }
  30. int getException()
  31. {
  32. return ex;
  33. }
  35. void init(int domaine,int type )
  36. {
  37. serv_ad.sin_family = domaine;
  38. serv_ad.sin_addr.s_addr = type;
  39. serv_ad.sin_port = htons(PORT);
  40. }
  42. int c_bind()
  43. {
  44. int res = bind(sockd,(struct sockaddr*)&serv_ad,sizeof(serv_ad));
  45. return res;
  46. }
  48. int c_listen()
  49. {
  50. return listen(sockd,100);
  51. }
  53. unsigned int sizeOfSin()
  54. {
  55. return sizeof(sin);
  56. }
  58. int c_accept(unsigned int size)
  59. {
  60. return (sockcli = accept(sockd,(struct sockaddr*)&sin, &size));
  61. }
  63. int c_read(char machaine[TAILLEMAX])
  64. {
  65. char ch[TAILLEMAX];
  66. int res = (read(sockcli,ch,sizeof(ch)));
  67. strcpy(machaine,ch);
  68. return res;
  69. }
  71. int c_write(char machaine[TAILLEMAX])
  72. {
  73. char envoi[TAILLEMAX];
  74. strcpy(envoi,machaine);
  75. int res = write(sockcli,envoi,sizeof(envoi));
  76. ;
  77. return res;
  78. }
  80. void c_close()
  81. {
  82. close(sockcli);
  83. }
  85. int c_connect()
  86. {
  87. sockcli=sockd;
  88. return (connect(sockd,(struct sockaddr*)&serv_ad,sizeof(serv_ad)));
  89. }
  91. };
  94. int main(int argc, char *argv[]){
  95. connexion serveur;
  96. unsigned int sin_size;
  97. int ecoute,conn_serv;
  98. char ch[TAILLEMAX],taille,ret,recu[TAILLEMAX];
  99. char * quit ="/quit\0";
  101. //ouverture de la socket socket.open
  102. ;
  104. if(serveur.getException() ==-1)
  105. {
  106. printf("Erreur
  107. socket\n" );
  109. return -1;
  110. }
  112. serveur.init(AF_INET,htonl(INADDR_ANY));
  114. if (serveur.c_bind()  == SOCKET_ERROR)
  115. {      // liaison à la socket
  117. printf("Erreur bind \n" );
  119. return -1;
  121. } 
  123. conn_serv = 0;
  125.   do
  127.   {
  129.   cout << "Serveur en ecoute...\n";
  131.   }while((ecoute = serveur.c_listen()) != 0);
  133.   cout << "Tentative de connexion " <<conn_serv+1 << "\n";
  135.   if(ecoute == SOCKET_ERROR)
  137.   {
  139.             cout << "Connexion failed\n";
  141.             return EXIT_FAILURE;
  143.   }
  145.  
  147.   //Accepte la connexion
  149.   // structure destinée à recueillir les renseignements sur l'appelant
  151.   sin_size = serveur.sizeOfSin();
  153.   if(serveur.c_accept(sin_size) == INVALID_SOCKET)
  155.   {
  157.         cout<<"Tentative de connexion Superieur à" <<conn_serv+1<<"\n";
  159.             return EXIT_FAILURE;     
  161.   };
  163.   cout << "Acceptation de connexion\n";
  165.   // connexion et envoi du message au client
  167.   int retour;
  169. cout<<"Connexion etabli\n";
  170. int bcle = 1;
  172. do
  173. {
  174. fflush(stdin);
  175. fflush(stdout);
  176. ret = (serveur.c_read(ch)==-1);
  178.    if(ret ==-1)
  180. {
  182.  cout <<"Receive error\n";
  184.  return EXIT_FAILURE;
  186. }
  187. if(ch[0] == quit[0] && ch[1] == quit[1] && ch[2] == quit[2] && ch[3] == quit[3] && ch[4] == quit[4])
  188. {
  189.  bcle = 0;
  190.  cout << "Deconnexion du client\n";
  191. }
  192. else
  193. {
  194.     cout<<"Client: "<<ch<<"\n";
  195. cout<<"Entrez le mot a envoyer : ";
  196. fgets(recu,TAILLEMAX,stdin);
  197. fflush(stdin);
  198. fflush(stdout);
  199. ret = serveur.c_write(recu);
  200. if(recu[0] == quit[0] && recu[1] == quit[1] && recu[2] == quit[2] && recu[3] == quit[3] && recu[4] == quit[4])
  201. {
  202.  bcle = 0;
  203.  cout<<"Deconnexion\n";
  204. }
  205. else
  206. {
  208.    if (ret == SOCKET_ERROR)
  210.    { 
  212.     cout<<"Erreur envoi \n";
  214.         return EXIT_FAILURE;
  216.    }
  217. ret = -1;
  219. cout<<"------MESSAGE ENVOYEE------\n";
  220. }
  221. }     
  222. }while(bcle);
  223. serveur.c_close();
  224. return 0;
  225. }

Reply

Marsh Posté le 14-06-2007 à 09:58:36   

Reply

Marsh Posté le 14-06-2007 à 10:18:41    

Tu design un serveur dans un objet, sur le "accept" tu instancie un thread avec un nouvel objet serveur encapsulé dans un thread par exemple, l'objet serveur étant paramétré par les information de la nouvelle socket ouverte.


---------------
Töp of the plöp
Reply

Marsh Posté le 14-06-2007 à 11:26:32    

Euh........................ au risque de passer pour un véritable et lamentable boulet... jdois dire que je ne m'y connais vraiment pas...  :/ et j'ai rien comprit :s

Reply

Sujets relatifs:

Leave a Replay

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