[Resolu]Serveur Multi Thread en C

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [Resolu]Serveur Multi Thread en C

thanks33

bonjour a tous est a toute,

Je cherche a développer un serveur Multi Thread en C sur les plateforme windows et unix.

Malheureusement je ne m'en sort pas.

J'aurai besoin de conseils avisé sur les librairie a utiliser, ainsi que exemple si sa existe.

Mon serveur doit se connecter a plusieurs clients simultanément, grâce a leur adresse IP.

ps: google ne pas beaucoup aidé dans mes recherches.

Cordialement

Message édité par thanks33 le 11-06-2009 à 11:21:29

Publicité

Olivier51

Les mots cles pour ta recherche sont : "network programming c"

Un bon tutorial sur le sujet (qui t'introduira aux socket(), connect(), etc) te parlera en meme temps du multi-threads.

Olivier51

Au passage se sont les clients qui se connectent aux serveurs. Dans ton cas ce que tu appelles des clients sont en fait des serveurs qui attendent les requetes des clients (ton serveur).

thanks33

merci de ton aide.

bonjour, voila se qui me bloque.

Je doit réalisé un outil de supervision de serveur Unix.

En réalité mon serveur tcp ip sera aussi un client, je m'explique :

le programme en C ou C++ devra être capable de recevoir un ordre grâce a un site internet, puis de lancer un ordre a chacun des client.
Puis un fois que la partie cliente a finie d'exécuter les script, il devra envoyer au serveur un fichier txt.

Code :

[COLOR="Black"]function [/COLOR]envoi_serveur($envoi) /* Permet l'envoie de la commande au serveur*/
{
$port = 10000; /*définition du port */
$adresse = "127.0.0.1"; /*définition de l'adresse ip du serveur */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);/* Cree une socket TCP/IP. */
if ($socket < 0) /*Si le socket ne c'est pas créé */
{
echo "socket_create() a échoué : raison : " . socket_strerror ($socket) . "<br />"; /*affiche l'erreur */
}
else /* Sinon*/
{
$resultat = socket_connect($socket, $adresse, $port); /* connexion au serveur*/
if ($resultat < 0) /*Si la connexion au serveur a échoué*/
{
echo "socket_connect() a échoué : raison : ($resultat) " . socket_strerror($resultat) . "<br />";/*affiche l'erreur */
}
else /* Sinon*/
{
socket_write($socket, $envoi, strlen($envoi)); /*envoi de la données*/
}
}
socket_close($socket); /*Fermeture du serveur*/
}

qui envera un code qui ressemble a celui ci : 10XTOT-pprod

ma partie serveur ressemble a ceci

Code :

#include <cstdlib>
#include <iostream>
#include <fstream>
using namespace std;
#include <winsock2.h>
int main(int argc, char *argv[])
{
// Initialisation
WSADATA initialisation_win32;
int erreur=WSAStartup(MAKEWORD(2,2),&initialisation_win32);
if (erreur!=0)
{
cout << "Desole, je ne peux pas initialiser Winsock du a l'erreur : ";
cout << erreur << " " << WSAGetLastError() << "\n\n";
system("PAUSE" );
return -1;
}
else
{
cout << "WSAStartup : OK\n";
}
// Création de la socket
SOCKET id_de_la_socket;
id_de_la_socket=socket(AF_INET,SOCK_STREAM,0);
if (id_de_la_socket==INVALID_SOCKET)
{
cout << "Desole, je ne peux pas creer la socket du a l'erreur : ";
cout << WSAGetLastError() << "\n\n";
system("PAUSE" );
return -1;
}
else
{
cout << "socket : OK\n";
}
// Ouverture du port 47836
SOCKADDR_IN information_sur_la_source;
information_sur_la_source.sin_family=AF_INET;
information_sur_la_source.sin_addr.s_addr=INADDR_ANY;
information_sur_la_source.sin_port=htons(10000); // Le porte 47836 est écouté
erreur=bind(id_de_la_socket,(struct sockaddr*)&information_sur_la_source,
sizeof(information_sur_la_source));
if (erreur!=0)
{
cout << "Desole, je ne peux pas ecouter ce port : ";
cout << erreur << " " << WSAGetLastError() << "\n\n";
system("PAUSE" );
return -1;
}
else
{
cout << "bind : OK\n";
}
// Attend une demande de connection
do
erreur=listen(id_de_la_socket,1);
while(erreur!=0);
cout << "listen : OK\n";
// On accepte la connexion
SOCKET id_de_la_nouvelle_socket;
int tempo=sizeof(information_sur_la_source);
id_de_la_nouvelle_socket=accept(id_de_la_socket,
(struct sockaddr*)&information_sur_la_source,&tempo);
if(id_de_la_nouvelle_socket==INVALID_SOCKET)
{
cout << "Desole, je ne peux pas accepter la session TCP du a l'erreur : ";
cout << WSAGetLastError() << "\n\n";
system("PAUSE" );
return -1;
}
else
cout << "accept : OK\n";
char buffer[4096]; long buffer2;
// Reçois la taille du nom du fichier (4 octet ou 32 bits)
int nombre_de_caractere=recv(id_de_la_nouvelle_socket,(char*)&buffer2,4,0);
if (nombre_de_caractere==SOCKET_ERROR)
{
cout << "Erreur, je n'ai pas recu la taille du nom de fichier !\n\n";
system("PAUSE" );
return -1;
}
// Reçois le nom du fichier
char*nomdefichier=new char[buffer2+1];nomdefichier[0]=0;
for (int i=0;i<buffer2;i+=nombre_de_caractere)
{
nombre_de_caractere=recv(id_de_la_nouvelle_socket,buffer,(buffer2-i<4096)?buffer2-i:4096,0);
if (nombre_de_caractere==SOCKET_ERROR)
{
cout << "Erreur, je n'ai pas recu le nom du fichier !\n\n";
system("PAUSE" );
return -1;
}
else
{
for (int y=0;y<nombre_de_caractere;y++)
{
nomdefichier[y+i]=buffer[y];
nomdefichier[y+i+1]=0;
}
}
}
cout << "Nom du fichier a recevoir : " << nomdefichier << "\n";
ofstream fichiers(nomdefichier,ios::out|ios::binary);
if (!fichiers)
{
cout << "Erreur, impossible de créer le fichier !\n\n";
shutdown(id_de_la_socket,2);
closesocket(id_de_la_socket);
shutdown(id_de_la_nouvelle_socket,2);
closesocket(id_de_la_nouvelle_socket);
WSACleanup();
system("PAUSE" );
return -1;
}
// Reçois la taille du fichier (4 octet ou 32 bits)
nombre_de_caractere=recv(id_de_la_nouvelle_socket,(char*)&buffer2,4,0);
if (nombre_de_caractere==SOCKET_ERROR)
{
cout << "Erreur, je n'ai pas recu la taille du fichier !\n\n";
system("PAUSE" );
return -1;
}
cout << "Taille du fichier a recevoir : " << buffer2 << "\n";
// Reçois le fichier
for (int i=0;i<buffer2;i+=nombre_de_caractere)
{
nombre_de_caractere=recv(id_de_la_nouvelle_socket,buffer,
(buffer2-i<4096)?buffer2-i:4096// Si le nombre de donnée restant à reçevoir
// est plus petit que le buffer on indique ce nombre sinon la taille du buffer
,0);
if (nombre_de_caractere==SOCKET_ERROR)
{
cout << "Erreur, je n'ai pas recu le fichier !\n\n";
system("PAUSE" );
return -1;
}
else
{
fichiers.write(buffer,nombre_de_caractere);
}
}
delete[]nomdefichier;
fichiers.close();
shutdown(id_de_la_socket,2);
closesocket(id_de_la_socket);
shutdown(id_de_la_nouvelle_socket,2);
closesocket(id_de_la_nouvelle_socket);
cout << "\nLe fichier a bien ete recu !\n\n";
system("PAUSE" );
return 0;
}

mais malheureusement rien ne se passe.
pourtant, un client PHP reçoit bien le message alors que le client C++ ne reçoit rien.

Cordialement

Message cité 1 fois
Message édité par thanks33 le 09-06-2009 à 21:38:00

Emmanuel Delahaye

C is a sharp tool

thanks33 a écrit :

ma partie serveur ressemble a ceci

Code :

// Attend une demande de connection
do
erreur=listen(id_de_la_socket,1);
while(erreur!=0);
cout << "listen : OK\n";

On ne fait pas de boucle sur listen(). On fait une boucle sur accept() (qui est bloquante).

A lire de A à Z :

http://www.bien-programmer.fr/reseaux.htm

BUG : pour accept(), il faut fournir un sin (csin : client sin) différent de celui du serveur (ssin : server sin).

Ceci devrait mieux fonctionner :

Code :

#include <stdlib.h>
#include <stdio.h>
#include <winsock2.h>
int main (void)
{
int ret = EXIT_SUCCESS;
/* Initialisation */
WSADATA initialisation_win32;
int erreur = WSAStartup (MAKEWORD (2, 2), &initialisation_win32);
if (erreur != 0)
{
printf
("Desole, je ne peux pas initialiser Winsock du a l'erreur : %d %d\n",
erreur, WSAGetLastError ());
ret = EXIT_FAILURE;
}
else
{
/* Création de la socket */
SOCKET ssock = socket (AF_INET, SOCK_STREAM, 0);
printf ("WSAStartup : OK\n" );
if (ssock == INVALID_SOCKET)
{
printf
("Desole, je ne peux pas creer la socket du a l'erreur : %d %d\n",
erreur, WSAGetLastError ());
ret = EXIT_FAILURE;
}
else
{
SOCKADDR_IN ssin;
printf ("socket : OK\n" );
/* Ouverture du port */
ssin.sin_family = AF_INET;
ssin.sin_addr.s_addr = INADDR_ANY;
ssin.sin_port = htons (10000);
erreur = bind (ssock, (struct sockaddr *) &ssin, sizeof (ssin));
if (erreur != 0)
{
printf
("Desole, je ne peux pas me lier a ce port : %d %d\n",
erreur, WSAGetLastError ());
ret = EXIT_FAILURE;
}
else
{
printf ("bind : OK\n" );
/* Le port est mis en ecoute */
erreur = listen (ssock, 1);
if (erreur == SOCKET_ERROR)
{
printf
("Desole, je ne peux pas ecouter ce port : %d %d\n",
erreur, WSAGetLastError ());
ret = EXIT_FAILURE;
}
else
{
printf ("listen : OK\n" );
/* En attente de connexion d'un client */
{
SOCKADDR_IN csin;
int tempo = sizeof (csin);
SOCKET csock =
accept (ssock, (struct sockaddr *) &csin, &tempo);
if (csock == INVALID_SOCKET)
{
printf
("Desole, je ne peux pas accepter la session TCP du a l'erreur : %d %d\n",
erreur, WSAGetLastError ());
ret = EXIT_FAILURE;
}
else
{
char buffer[4096];
long buffer2;
/* Reçoit la longueur du nom du fichier (4 octet ou 32 bits) */
int nombre_de_caractere;
printf ("accept : OK\n" );
/* -ed- pas portable ! */
nombre_de_caractere =
recv (csock, (char *) &buffer2, 4, 0);
if (nombre_de_caractere <= 0)
{
printf
("Erreur, je n'ai pas recu la longueur du nom de fichier ! \n\n" );
ret = EXIT_FAILURE;
}
else
{
char *nomdefichier;
printf ("la longueur du nom de fichier est %ld\n",
buffer2);
/* Reçois le nom du fichier */
nomdefichier = malloc (buffer2 + 1);
if (nomdefichier != NULL)
{
/* -ed- Horriblement compliqué. Quel est le format des données ?
Je recommande :
(Codage des valeurs numériques : MSB en tete)
[Origine:longueur]
[0:2] LN : Longueur du nom de fichier (16-bit)
[2:LN] Nom de fichier (chaine de caracteres)
[2+LN:4] LD : longueur des données (32-bit)
[6+LN:LD]Donnees
*/
nomdefichier[0] = 0;
{
int i;
for (i = 0; i < buffer2;
i += nombre_de_caractere)
{
nombre_de_caractere =
recv (csock, buffer,
(buffer2 - i <
4096) ? buffer2 - i : 4096, 0);
if (nombre_de_caractere == SOCKET_ERROR)
{
printf
("Erreur, je n'ai pas recu le nom du fichier !\n\n" );
return EXIT_FAILURE;
}
else
{
int y;
for (y = 0; y < nombre_de_caractere; y++)
{
nomdefichier[y + i] = buffer[y];
nomdefichier[y + i + 1] = 0;
}
}
}
}
printf ("Nom du fichier a recevoir : %s\n",
nomdefichier);
{
FILE *fichiers = fopen (nomdefichier, "rb" );
if (fichiers == NULL)
{
printf
("Erreur, impossible de créer le fichier !\n\n" );
ret = EXIT_FAILURE;
}
else
{
/* Reçois la taille du fichier (4 octet ou 32 bits) */
nombre_de_caractere =
recv (csock, (char *) &buffer2, 4, 0);
if (nombre_de_caractere <= 0)
{
printf
("Erreur, je n'ai pas recu la taille du fichier !\n\n" );
return EXIT_FAILURE;
}
printf
("Taille du fichier a recevoir : %ld\n",
buffer2);
/* Reçois le fichier */
{
int i;
for (i = 0; i < buffer2;
i += nombre_de_caractere)
{
/* Si le nombre de donnée restant à reçevoir */
nombre_de_caractere =
recv (csock, buffer,
(buffer2 - i <
4096) ? buffer2 - i : 4096
/* est plus petit que le buffer on
indique ce nombre sinon la taille
du buffer */
, 0);
if (nombre_de_caractere ==
SOCKET_ERROR)
{
printf
("Erreur, je n'ai pas recu le fichier !\n\n" );
return EXIT_FAILURE;
}
else
{
fwrite (buffer, 1,
nombre_de_caractere,
fichiers);
}
}
}
fclose (fichiers);
}
}
printf ("\nLe fichier a bien ete recu !\n\n" );
}
free (nomdefichier);
}
shutdown (csock, 2);
closesocket (csock);
}
}
}
}
shutdown (ssock, 2);
closesocket (ssock);
}
WSACleanup ();
}
return ret;
}

Il faut quand même revoir le mécanisme de réception des données...

Message édité par Emmanuel Delahaye le 11-06-2009 à 13:47:27

---------------
Des infos sur la programmation et le langage C: http://www.bien-programmer.fr Pas de Wi-Fi à la maison : http://www.cpl-france.org/

FORUM HardWare.fr

Programmation

[Resolu]Serveur Multi Thread en C

Sujets relatifs
Lancer l'appli heure/zone horaire windows depuis C++	[Résolu] Utilisation d'une application winform en réseau
[Résolu] XML UTF-8 > Java String decodage	Langage C, Projet, Puissance 4 en langage C
[C] Fork et Pipe	variable et thread safe
Erreur Nonetype sur une regexp pourtant reconnue [résolu]	[C] Image ne s'affiche pas correctement sur un LCD
[Resolu][ASP.NET] deployement sur serveur IIS / pb de bibliotheque
Plus de sujets relatifs à : [Resolu]Serveur Multi Thread en C

Page générée en 0.244 secondes