Nous allons r\u00e9aliser en C un serveur tcp\/ip multi-clients g\u00e9n\u00e9rique…<\/p>\n
oul\u00e0… doucement :<\/p>\n
-serveur : va attendre que des clients se connectent<\/p>\n
-tcp\/ip : les connections clientes se feront par le protocole tcp\/ip<\/p>\n
-multi-clients : le serveur peut g\u00e9rer plusieurs clients en m\u00eame temps<\/p>\n
-g\u00e9n\u00e9rique \ud83d\ude2e : le serveur s’occupe uniquement de l’aspect communications r\u00e9seaux. Lorsqu’un client se connecte, il ex\u00e9cute une commande shell de notre choix.<\/p>\n
<\/p>\n
\u00a0<\/p>\n
On va voir quelques exemples pour bien comprendre :<\/p>\n
09:57:33 apesle:~ $ gts \"echo $SHELL\" 1234 &
[1] 28862
<\/pre>\nJe lance notre programme gts en tache de fond. Je lui demande d’attendre des clients sur le port 1234 et, pour chaque client, d’ex\u00e9cuter la commande \u00ab\u00a0echo $SHELL\u00a0\u00bb.<\/p>\n
09:57:50 apesle:~ $ nc localhost 1234
\/bin\/bash
09:58:03 apesle:~ $ nc localhost 1234
\/bin\/bash
<\/pre>\nAvec NetCat<\/a>, je cr\u00e9\u00e9 deux clients sur le port 1234 qui re\u00e7oivent bien le nom du shell utilis\u00e9.<\/p>\n
\u00a0<\/p>\n
exemple 2 :<\/h3>\n
09:58:03 apesle:~ $ gts \"echo $PWD\" 1235 &
[2] 28872
<\/pre>\nJe lance un nouveau processus gts en tache de fond. Cette fois ci je lui demande d’attendre des clients sur le port 1235 et, pour chaque client, d’ex\u00e9cuter la commande \u00ab\u00a0echo $PWD\u00a0\u00bb.<\/p>\n
09:58:16 apesle:~ $ nc localhost 1235
\/home\/apesle
<\/pre>\nOn peut voir que le client re\u00e7oit bien le r\u00e9pertoire courant du shell.<\/p>\n
\u00a0<\/p>\n
exemple 3 :<\/h3>\n
10:08:56 apesle:~ $ gts \"cd ~\/Desktop\/tests && .\/anagramme\" 1236 &
<\/pre>\nJe cr\u00e9\u00e9 un serveur sur le port 1236 qui lance notre programme C d’anagrammes pour chaque client.<\/p>\n
10:09:26 apesle:~ $ nc localhost 1236
nuuuunnnix
uuxunnunin
generic tcp server
grrcrs ee cievtpen
^C
<\/pre>\nLe client acc\u00e8de bien au programme d’anagramme \u00e0 travers la connection tcp\/ip.<\/p>\n
\u00a0<\/p>\n
exemple 4 :<\/h3>\n
09:58:20 apesle:~ $ gts \"nc localhost 1234\" 1237 &
[3] 28885
<\/pre>\nCette fois ci c’est plus compliqu\u00e9 : je demande au serveur de s’\u00e9tablir sur le port 1237, et lorsqu’il re\u00e7oit un client d’ex\u00e9cuter la commande \u00ab\u00a0nc localhost 1234\u00a0\u00bb qui cr\u00e9\u00e9 en fait un client pour notre premier serveur.<\/p>\n
09:59:06 apesle:~ $ nc localhost 1237
\/bin\/bash
<\/pre>\nLe client re\u00e7oit donc le nom du shell utilis\u00e9 ! En effet, on s’est connect\u00e9 au serveur, le serveur a donc ex\u00e9cut\u00e9 la commande \u00ab\u00a0nc localhost 1234\u00a0\u00bb qui cr\u00e9\u00e9 un client pour le serveur de l’exemple 1. Le serveur de l’exemple 1 a donc ex\u00e9cut\u00e9 la commande \u00ab\u00a0echo $SHELL\u00a0\u00bb et envois le r\u00e9sultat \u00e0 notre serveur, qui l’envois \u00e0 notre client !<\/p>\n
\u00a0<\/p>\n
Avec la commande \u00ab\u00a0netstat -tln\u00a0\u00bb, on peut voir nos 4 serveurs en attente de connections tcp\/ip :<\/p>\n
tcp 0 0 0.0.0.0:1234 0.0.0.0:* LISTEN
tcp 0 0 0.0.0.0:1235 0.0.0.0:* LISTEN
tcp 0 0 0.0.0.0:1236 0.0.0.0:* LISTEN
tcp 0 0 0.0.0.0:1237 0.0.0.0:* LISTEN
<\/pre>\n\u00a0<\/p>\n
Bon, mais comment \u00e7a marche ?<\/h3>\n
Le principe de fonctionnement est le suivant :<\/p>\n
\n
- le programme cr\u00e9\u00e9 une socket serveur, puis dans une boucle infinie accepte les clients qui s’y connectent. <\/li>\n<\/ul>\n
\n
- \u00c0 chaque fois qu’un client se connecte, on cr\u00e9\u00e9 un nouveau processus avec un \u00ab\u00a0fork\u00a0\u00bb. C’est ce processus fils qui va traiter la communication, alors que le p\u00e8re retourne en attente d’un client.<\/li>\n<\/ul>\n
\n
- On a donc un processus fils par client. Le processus fils redirige ses entr\u00e9es\/sorties standards sur la socket ouverte par son p\u00e8re puis ex\u00e9cute un programme tierce gr\u00e2ce \u00e0 un \u00ab\u00a0exec\u00a0\u00bb.<\/li>\n<\/ul>\n
Le r\u00f4le du serveur est donc uniquement de g\u00e9rer les sockets. Il d\u00e9l\u00e8gue la communication avec les clients \u00e0 un programme tierce qui manipule uniquement stdin et stdout.<\/p>\n
Ce programme peut, par ailleurs, \u00eatre \u00e9crit en n’importe quel langage (c,c++, script shell, etc).<\/p>\n
\u00a0<\/p>\n
Ok, et le source alors ?<\/h3>\n
Le programme, bien qu’assez succint, est int\u00e9ressant.<\/p>\n
Il montre l’utilisation des sockets en mode tcp\/ip (notamment l’option SO_REUSEADDR qui permet d’\u00e9viter l’erreur \u00ab\u00a0bind: Address already in use\u00a0\u00bb), la cr\u00e9ation de processus avec fork, la redirection de flux standard avec dup, ainsi que la mise en place d’un gestionnaire de signaux.<\/p>\n
Le code source est comment\u00e9, cependant quelques explications au niveau de la gestion des signaux n’est peut \u00eatre pas de trop :<\/p>\n
Le programme met en place un gestionnaire de signaux pour SIGCHLD (signal \u00e9mis par le noyau lors de la terminaison d’un processus fils).<\/p>\n
Ce signal, re\u00e7ut par le processus gts, interrompt l’appel syst\u00e8me accept (qui permet d’accepter des connections clientes sur la socket). On utilise donc errno pour d\u00e9tecter ce cas et r\u00e9-appeler accept.<\/p>\n
Notez \u00e9galement que le gestionnaire de signaux mis en place pour SIGCHLD lit le code de retour du processus fils termin\u00e9 pour \u00e9viter qu’il ne reste \u00e0 l’\u00e9tat zombie (\u00e9tat sp\u00e9cial d’un processus qui attend ind\u00e9finiment que son p\u00e8re lise son code de retour).<\/p>\n
\u00a0<\/p>\n
PS :<\/p>\n
-Pour compiler : gcc -Wall -g -o gts gts.c<\/p>\n
-Installer : sudo cp gts \/usr\/bin\/<\/p>\n
{codecitation class=\u00a0\u00bbbrush: c;\u00a0\u00bb}<\/p>\n
\/*
Copyright (c) 2009 Adrien Pesle - apesle at nunix.fr
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the \"Software\"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and\/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
*\/<\/pre>\n#include <stdio.h><\/p>\n
#include <stdlib.h><\/p>\n
#include <string.h><\/p>\n
#include <unistd.h><\/p>\n
#include <errno.h><\/p>\n
#include <signal.h><\/p>\n
#include <sys\/wait.h><\/p>\n
#include <arpa\/inet.h><\/p>\n
#include <netdb.h><\/p>\n
#include <netinet\/in.h><\/p>\n
#include <sys\/types.h><\/p>\n
#include <sys\/socket.h><\/p>\n
extern char **environ;<\/p>\n
int<\/p>\n
cree_socket_stream (const unsigned int port)<\/p>\n
{<\/p>\n
int sock;<\/p>\n
struct sockaddr_in adresse;<\/p>\n
memset (&adresse, 0, sizeof (struct sockaddr_in));<\/p>\n
\/* cr\u00e9ation de la socket *\/<\/p>\n
if ((sock = socket (AF_INET, SOCK_STREAM, 0)) < 0)<\/p>\n
{<\/p>\n
perror (\u00ab\u00a0socket\u00a0\u00bb);<\/p>\n
return -1;<\/p>\n
}<\/p>\n
\/* appliquer l’option SO_REUSEADDR qui dit au kernel de r\u00e9utiliser<\/p>\n
le port m\u00eame si il est occup\u00e9 (\u00e9tat TIME_WAIT). Ceci permet<\/p>\n
d’\u00e9viter l’erreure \u00ab\u00a0bind: Address already in use\u00a0\u00bb *\/<\/p>\n
int yes = 1;<\/p>\n
if (setsockopt (sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof (int)) == -1)<\/p>\n
{<\/p>\n
perror (\u00ab\u00a0Impossible d’appliquer setsockopt avec SO_REUSEADDR !\u00a0\u00bb);<\/p>\n
return -1;<\/p>\n
}<\/p>\n
\/* param\u00e9trage *\/<\/p>\n
adresse.sin_family = AF_INET;<\/p>\n
adresse.sin_port = htons (port);<\/p>\n
adresse.sin_addr.s_addr = htonl (INADDR_ANY);<\/p>\n
if (bind<\/p>\n
(sock, (struct sockaddr *) &adresse, sizeof (struct sockaddr_in)) < 0)<\/p>\n
{<\/p>\n
close (sock);<\/p>\n
perror (\u00ab\u00a0bind\u00a0\u00bb);<\/p>\n
return -1;<\/p>\n
}<\/p>\n
return sock;<\/p>\n
}<\/p>\n
void<\/p>\n
traite_connexion (int sock, const char *commande)<\/p>\n
{<\/p>\n
\/* redirection de stdout et stdin sur la socket *\/<\/p>\n
close (STDOUT_FILENO);<\/p>\n
if (dup (sock) < 0)<\/p>\n
{<\/p>\n
perror (\u00ab\u00a0dup\u00a0\u00bb);<\/p>\n
exit (EXIT_FAILURE);<\/p>\n
}<\/p>\n
close (STDIN_FILENO);<\/p>\n
if (dup (sock) < 0)<\/p>\n
{<\/p>\n
perror (\u00ab\u00a0dup\u00a0\u00bb);<\/p>\n
exit (EXIT_FAILURE);<\/p>\n
}<\/p>\n
\/* execution de la commande pass\u00e9e en param\u00e8tre du serveur *\/<\/p>\n
char *argv[] = { \u00ab\u00a0sh\u00a0\u00bb, \u00ab\u00a0-c\u00a0\u00bb, (char *) commande, (char *) NULL };<\/p>\n
execve (\u00ab\u00a0\/bin\/sh\u00a0\u00bb, argv, environ);<\/p>\n
fprintf (stdout, \u00ab\u00a0Rat\u00e9 : erreur = %dn\u00a0\u00bb, errno);<\/p>\n
close (sock);<\/p>\n
}<\/p>\n
int<\/p>\n
serveur_tcp (const char *commande, const unsigned int port)<\/p>\n
{<\/p>\n
int sock_contact;<\/p>\n
int sock_connectee;<\/p>\n
struct sockaddr_in adresse;<\/p>\n
socklen_t longueur;<\/p>\n
sock_contact = cree_socket_stream (port);<\/p>\n
if (sock_contact < 0)<\/p>\n
return -1;<\/p>\n
listen (sock_contact, 5);<\/p>\n
while (1)<\/p>\n
{<\/p>\n
longueur = sizeof (struct sockaddr_in);<\/p>\n
sock_connectee =<\/p>\n
accept (sock_contact, (struct sockaddr *) &adresse, &longueur);<\/p>\n
if (sock_connectee == -1)<\/p>\n
{<\/p>\n
if (EINTR == errno)<\/p>\n
\/* l’appel system a \u00e9t\u00e9 interrompu \u00e0 cause du signal SIGCHLD<\/p>\n
provoqu\u00e9 par la d\u00e9connection d’un client. *\/<\/p>\n
continue;<\/p>\n
else<\/p>\n
{<\/p>\n
\/* l’appel system accept a \u00e9chou\u00e9 *\/<\/p>\n
perror (\u00ab\u00a0accept\u00a0\u00bb);<\/p>\n
return -1;<\/p>\n
}<\/p>\n
}<\/p>\n
\/* cr\u00e9ation d’un processus fils pour chaque client *\/<\/p>\n
switch (fork ())<\/p>\n
{<\/p>\n
case 0:\t\t\/* fils *\/<\/p>\n
close (sock_contact);<\/p>\n
traite_connexion (sock_connectee, commande);<\/p>\n
exit (EXIT_SUCCESS);<\/p>\n
case -1:\t\t\/* erreure *\/<\/p>\n
perror (\u00ab\u00a0fork\u00a0\u00bb);<\/p>\n
return -1;<\/p>\n
default:\t\t\/* p\u00e8re *\/<\/p>\n
close (sock_connectee);<\/p>\n
}<\/p>\n
}<\/p>\n
return 0;<\/p>\n
}<\/p>\n
static void<\/p>\n
gestionnaire_signaux (int ignore)<\/p>\n
{<\/p>\n
\/* lecture du code de retour du fils termin\u00e9 pour eviter<\/p>\n
qu’il ne reste zombi. On passe NULL car on n’est pas<\/p>\n
int\u00e9rr\u00e9ss\u00e9 par les circonstances de la fin du processus. *\/<\/p>\n
wait (NULL);<\/p>\n
}<\/p>\n
int<\/p>\n
main (int argc, char *argv[])<\/p>\n
{<\/p>\n
if (argc < 3)<\/p>\n
{<\/p>\n
printf (\u00ab\u00a0Usage : %s commande portn\u00a0\u00bb, argv[0]);<\/p>\n
printf<\/p>\n
(\u00ab\u00a0comande = commande ex\u00e9cut\u00e9e par le shell pour chaque client.n\u00a0\u00bb);<\/p>\n
printf (\u00ab\u00a0port = port d’\u00e9coute.n\u00a0\u00bb);<\/p>\n
exit (EXIT_FAILURE);<\/p>\n
}<\/p>\n
\/*———————————————————————–<\/p>\n
* gestionnaire de signaux qui capture SIGGHLD pour \u00e9viter que les<\/p>\n
* processus fils deviennent zombi.<\/p>\n
*———————————————————————–*\/<\/p>\n
struct sigaction action;<\/p>\n
action.sa_handler = gestionnaire_signaux;<\/p>\n
sigemptyset (&(action.sa_mask));<\/p>\n
action.sa_flags = 0;<\/p>\n
if (sigaction (SIGCHLD, &action, NULL) != 0)<\/p>\n
{<\/p>\n
fprintf (stderr, \u00ab\u00a0Signal non captur\u00e9.n\u00a0\u00bb);<\/p>\n
exit (EXIT_FAILURE);<\/p>\n
}<\/p>\n
return serveur_tcp (argv[1], atoi (argv[2]));<\/p>\n
}<\/p>\n
{\/codecitation}<\/p>\n
{jcomments on}<\/p>\n
\u00a0<\/p>\n
\u00a0<\/p>\n
\u00a0<\/p>\n
\u00a0<\/p>\n","protected":false},"excerpt":{"rendered":"
GTS : Generic Tcp Server Nous allons r\u00e9aliser en C un serveur tcp\/ip multi-clients g\u00e9n\u00e9rique… oul\u00e0… doucement : -serveur : va attendre que des clients se connectent -tcp\/ip : les connections clientes se feront par le protocole tcp\/ip -multi-clients : le serveur peut g\u00e9rer plusieurs clients en m\u00eame temps -g\u00e9n\u00e9rique \ud83d\ude2e : le serveur s’occupe … Continuer la lecture de « GTS »<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[9],"tags":[],"class_list":["post-59","post","type-post","status-publish","format-standard","hentry","category-c"],"_links":{"self":[{"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/posts\/59","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/nunix.fr\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=59"}],"version-history":[{"count":1,"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/posts\/59\/revisions"}],"predecessor-version":[{"id":121,"href":"https:\/\/nunix.fr\/index.php?rest_route=\/wp\/v2\/posts\/59\/revisions\/121"}],"wp:attachment":[{"href":"https:\/\/nunix.fr\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=59"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/nunix.fr\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=59"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/nunix.fr\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=59"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}