-
La fonction d’initialisation d’un serveur IPv4 :
int initialisationServeur(short int *port,int connexions){
{
int s;
struct sockaddr_in adresse;
socklen_t taille=sizeof adresse;
int statut;
/* Creation d'une socket */
s=socket(PF_INET,SOCK_STREAM,0);
if(s<0){
perror("initialisationServeur.socket");
exit(-1);
}
/* Specification de l'adresse de la socket */
adresse.sin_family=AF_INET;
adresse.sin_addr.s_addr=INADDR_ANY;
adresse.sin_port=htons(*port);
statut=bind(s,(struct sockaddr *)&adresse,sizeof(adresse));
if(statut<0) return -1;
/* On recupere le numero du port utilise */
statut=getsockname(s,(struct sockaddr *)&adresse,&taille);
if(statut<0){
perror("initialisationServeur.getsockname");
exit(-1);
}
*port=ntohs(adresse.sin_port);
/* Taille de la queue d'attente */
statut=listen(s,connexions);
if(statut<0) return -1;
return s;
}
- La fonction d’initialisation d’un serveur IPv6 :
int initialisationServeur(short int *port,int connexions){
int s;
struct sockaddr_in6 adresse;
socklen_t taille=sizeof adresse;
int statut;
/* Creation d'une socket */
s=socket(PF_INET6,SOCK_STREAM,0);
if(s<0){
perror("initialisationServeur.socket");
exit(-1);
}
/* Specification de l'adresse de la socket */
adresse.sin6_family=AF_INET6;
adresse.sin6_addr=in6addr_any;
adresse.sin6_port=htons(*port);
adresse.sin6_flowinfo=0;
adresse.sin6_scope_id=0;
statut=bind(s,(struct sockaddr *)&adresse,taille);
if(statut<0) return -1;
/* Recuperation du numero du port utilise */
statut=getsockname(s,(struct sockaddr *)&adresse,&taille);
if(statut<0){
perror("initialisationServeur.getsockname");
exit(-1);
}
*port=ntohs(adresse.sin6_port);
/* Taille de la queue d'attente */
statut=listen(s,connexions);
if(statut<0) return -1;
return s;
}
- Une fonction d’initialisation générique :
int initialisationServeur(char *service,int connexions){
struct addrinfo precisions,*resultat,*origine;
int statut;
int s;
/* Construction de la structure adresse */
memset(&precisions,0,sizeof precisions);
precisions.ai_family=AF_UNSPEC;
precisions.ai_socktype=SOCK_STREAM;
precisions.ai_flags=AI_PASSIVE;
statut=getaddrinfo(NULL,service,&precisions,&origine);
if(statut<0){ perror("initialisationServeur.getaddrinfo"); exit(EXIT_FAILURE); }
struct addrinfo *p;
for(p=origine,resultat=origine;p!=NULL;p=p->ai_next)
if(p->ai_family==AF_INET6){ resultat=p; break; }
/* Creation d'une socket */
s=socket(resultat->ai_family,resultat->ai_socktype,resultat->ai_protocol);
if(s<0){ perror("initialisationServeur.socket"); exit(EXIT_FAILURE); }
/* Options utiles */
int vrai=1;
if(setsockopt(s,SOL_SOCKET,SO_REUSEADDR,&vrai,sizeof(vrai))<0){
perror("initialisationServeur.setsockopt (REUSEADDR)");
exit(EXIT_FAILURE);
}
if(setsockopt(s,IPPROTO_TCP,TCP_NODELAY,&vrai,sizeof(vrai))<0){
perror("initialisationServeur.setsockopt (NODELAY)");
exit(EXIT_FAILURE);
}
/* Specification de l'adresse de la socket */
statut=bind(s,resultat->ai_addr,resultat->ai_addrlen);
if(statut<0){ freeaddrinfo(origine); shutdown(s,SHUT_RDWR); return -1; }
/* Liberation de la structure d'informations */
freeaddrinfo(origine);
/* Taille de la queue d'attente */
statut=listen(s,connexions);
if(statut<0){ shutdown(s,SHUT_RDWR); return -2; }
return s;
}
- La fonction de gestion des clients :
int boucleServeur(int ecoute,int (*traitement)(int)){
int dialogue;
while(1){
/* Attente d'une connexion */
if((dialogue=accept(ecoute,NULL,NULL))<0) return -1;
/* Passage de la socket de dialogue a la fonction de traitement */
if(traitement(dialogue)<0){ shutdown(ecoute,SHUT_RDWR); return 0;}
}
}
- La fonction principale :
int gestionClient(int s){
/* Obtient une structure de fichier */
FILE *dialogue=fdopen(s,"a+");
if(dialogue==NULL){ perror("gestionClient.fdopen"); exit(EXIT_FAILURE); }
/* Echo */
char ligne[MAX_LIGNE];
while(fgets(ligne,MAX_LIGNE,dialogue)!=NULL)
fprintf(dialogue,"> %s",ligne);
/* Termine la connexion */
fclose(dialogue);
return 0;
}
int main(int argc,char *argv[])
{
int s;
/* Lecture des arguments de la commande */
analyseArguments(argc,argv);
/* Initialisation du serveur */
s=initialisationServeur(service,MAX_CONNEXIONS);
if(s<0){ fprintf(stderr,"Port non utilisable\n"); exit(EXIT_FAILURE); }
/* Lancement de la boucle d'ecoute */
boucleServeur(s,gestionClient);
}