Exemple de client/serveur TCP - Revision history

Bruno Deniaud at 11:02, 27 February 2006

2006-02-27T11:02:26Z

Laurent Toutain: /* Le serveur */

2005-12-17T07:39:18Z

‎Le serveur

Show changes

Laurent Toutain: /* L'établissement d'une connexion TCP, côté client */

2005-12-17T07:24:00Z

‎L'établissement d'une connexion TCP, côté client

Laurent Toutain: /* Vue d'ensemble */

2005-12-17T07:19:13Z

‎Vue d'ensemble

Laurent Toutain: /* Vue d'ensemble */

2005-12-17T07:17:04Z

‎Vue d'ensemble

WikiSysop: /* Vue d'ensemble */

2005-12-17T06:32:21Z

‎Vue d'ensemble

Laurent Toutain: /* Vue d'ensemble */

2005-12-16T19:29:42Z

‎Vue d'ensemble

Laurent Toutain: /* Le serveur */

2005-12-15T18:07:56Z

‎Le serveur

Show changes

Laurent Toutain: /* Le serveur */

2005-12-15T16:54:33Z

‎Le serveur

Laurent Toutain: /* L'établissement d'une connexion TCP, côté client */

2005-12-15T16:53:42Z

‎L'établissement d'une connexion TCP, côté client

← Older revision		Revision as of 11:02, 27 February 2006
Line 1:		Line 1:
		+	{{suivi\| La commande haah (host-address-address-host) \| La commande haah (host-address-address-host) \| mini-ping \| mini-ping }}
	==Vue d'ensemble==		==Vue d'ensemble==

Line 325:		Line 326:

	Une dernière remarque toujours à propos de la similitude des codes IPv6 et IPv4 : la seule différence dans le code de <tt>serv_daemon</tt> entre IPv4 et IPv6 est la valeur du premier argument, qui définit la famille d'adresses écoutée.		Une dernière remarque toujours à propos de la similitude des codes IPv6 et IPv4 : la seule différence dans le code de <tt>serv_daemon</tt> entre IPv4 et IPv6 est la valeur du premier argument, qui définit la famille d'adresses écoutée.
		+	{{suivi\| La commande haah (host-address-address-host) \| La commande haah (host-address-address-host) \| mini-ping \| mini-ping }}

@@ Line 148: / Line 148: @@
- #include <stdio.h>
+| #include <stdio.h>
- #include <unistd.h>
+| #include <unistd.h>
- #include <sys/socket.h>
+| #include <sys/socket.h>
- #include <netdb.h>
+| #include <netdb.h>
+|
- int open_conn(char *host, char *serv)
+| int open_conn(char *host, char *serv)
+| {
-    int sock, ecode;
+|    int sock, ecode;
-    struct addrinfo *res;
+|    struct addrinfo *res;
-    struct addrinfo hints = {
+|    struct addrinfo hints = {
-,
+|       0,
-       PF_UNSPEC,
+|       PF_UNSPEC,
-       SOCK_STREAM,
+|       SOCK_STREAM,
-,
+|       0,
-,
+|       0,
-       NULL,
+|       NULL,
-       NULL,
+|       NULL,
-       NULL
+|       NULL
-    };
+|    };
+|
-    ecode = getaddrinfo(host, serv, &hints, &res);
+|    ecode = getaddrinfo(host, serv, &hints, &res);
+|
-    if (ecode) {
+|    if (ecode) {
-       fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(ecode));
+|       fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(ecode));
-       exit(1);
+|       exit(1);
+|    }
+|
-    if ((sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol)) < 0) {
+|    if ((sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol)) < 0) {
-       freeaddrinfo(res);
+|       freeaddrinfo(res);
-       perror("socket");
+|       perror("socket");
-       return -1;
+|       return -1;
+|    }
+|
-   if (connect(sock, res->ai_addr, res->ai_addrlen) < 0) {
+|   if (connect(sock, res->ai_addr, res->ai_addrlen) < 0) {
-       close(sock);
+|       close(sock);
-       freeaddrinfo(res);
+|       freeaddrinfo(res);
-       perror("connect");
+|       perror("connect");
-       return -1;
+|       return -1;
+|    }
-    freeaddrinfo(res);
+|    freeaddrinfo(res);
-    return sock;
+|    return sock;
+| }
 ==Le serveur==

@@ Line 73: / Line 73: @@
 | }
-Le serveur <tt>nbusd</tt>, quant à lui, lance en tâche de fond un processus "démon" qui exécutera la fonction de service nbus (lignes See à See ) à chaque requête d'un client. Ce processus démon est réalisé par la fonction <tt>serv_daemon</tt>.
+Le serveur <tt>nbusd</tt>, quant à lui, lance en tâche de fond un processus "démon" qui exécutera la fonction de service nbus (lignes 28 à 60) à chaque requête d'un client. Ce processus démon est réalisé par la fonction <tt>serv_daemon</tt>.
 | #include <stdio.h>
-|#include <unistd.h>
+| #include <unistd.h>
 | #include <fcntl.h>
 | #include <utmp.h>

@@ Line 76: / Line 76: @@
- #include <stdio.h>
+| #include <stdio.h>
- #include <unistd.h>
+|#include <unistd.h>
- #include <fcntl.h>
+| #include <fcntl.h>
- #include <utmp.h>
+| #include <utmp.h>
- #include <sys/socket.h>
+| #include <sys/socket.h>
+|
- #include "nbus.h"
+| #include "nbus.h"
+|
+|
-  #if defined(IPV6)
+| #if defined(IPV6)
-  #define FAMILY PF_INET6
+| #define FAMILY PF_INET6
-  #elif defined(IPV4)
+| #elif defined(IPV4)
-  #define FAMILY PF_INET
+| #define FAMILY PF_INET
-  #else
+| #else
-  #define FAMILY PF_UNSPEC
+| #define FAMILY PF_UNSPEC
-  #endif
+| #endif
+|
-  extern serv_daemon(int, char *, void (*)(int), char *);
+| extern serv_daemon(int, char *, void (*)(int), char *);
+|
-  void nbus(int);
+| void nbus(int);
+|
-  int main(void)
+| int main(void)
+| {
-    serv_daemon(FAMILY, SERVICE, nbus, NULL);
+|    serv_daemon(FAMILY, SERVICE, nbus, NULL);
-    exit(0);
+|   exit(0);
+| }
+|
-  void nbus(int sock)
+| void nbus(int sock)
+| {
-    short nu = -1;
+|    short nu = -1;
-  #ifdef USER_PROCESS /* Solaris/Linux, use getutent */
+| #ifdef USER_PROCESS /* Solaris/Linux, use getutent */
-    struct utmp *up;
+|    struct utmp *up;
+|
-    up = getutent();
+|    up = getutent();
-    if (up != NULL) {
+|    if (up != NULL) {
-       for (nu = 0; up != NULL; up = getutent())
+|       for (nu = 0; up != NULL; up = getutent())
-       if (up->ut_type == USER_PROCESS)
+|       if (up->ut_type == USER_PROCESS)
-       nu++;
+|       nu++;
+|    }
-    endutent();
+|    endutent();
-  #else /* *BSD read directly utmp file */
+| #else /* *BSD read directly utmp file */
-  #ifndef UTMP
+| #ifndef UTMP
-  #define UTMP "/var/run/utmp" /* for FreeBSD/NetBSD */
+| #define UTMP "/var/run/utmp" /* for FreeBSD/NetBSD */
-  #endif
+| #endif
+|
-    struct utmp ut;
+|    struct utmp ut;
-    int fd;
+|    int fd;
+|
-    if ((fd = open(UTMP, O_RDONLY)) >= 0) {
+|   if ((fd = open(UTMP, O_RDONLY)) >= 0) {
-       nu = 0;
+|       nu = 0;
-       while (read(fd, (char *) &ut, sizeof(ut)) == sizeof(ut))
+|       while (read(fd, (char *) &ut, sizeof(ut)) == sizeof(ut))
-       if (ut.ut_name[0])
+|       if (ut.ut_name[0])
-       nu++;
+|       nu++;
+|    }
-    close(fd);
+|    close(fd);
-  #endif
+| #endif
-    nu = htons(nu);
+|    nu = htons(nu);
-    write(sock, (char *) &nu, sizeof(nu));
+|    write(sock, (char *) &nu, sizeof(nu));
-    return;
+|    return;
+| }
 ==L'établissement d'une connexion TCP, côté client==

@@ Line 39: / Line 39: @@
 Le programme client nbus établit tout d'abord une connexion TCP avec la machine cible (donnée en argument à <tt>nbus</tt>) via la fonction <tt>open_conn</tt> (cette fonction sera décrite ci-après). Il lit ensuite un entier court, résultat du calcul du nombre d'utilisateurs connectés sur la machine cible, puis l'imprime.
-On notera la présence de la macro ntohs rendue nécessaire du fait des représentations différentes des entiers selon les machines.
+On notera la présence de la macro <tt>ntohs</tt> rendue nécessaire du fait des représentations différentes des entiers selon les machines.
 | #include <stdio.h>

@@ Line 41: / Line 41: @@
 On notera la présence de la macro ntohs rendue nécessaire du fait des représentations différentes des entiers selon les machines.
- #include <stdio.h>
+| #include <stdio.h>
- #include <unistd.h>
+| #include <unistd.h>
+|
-  #include "nbus.h"
+| #include "nbus.h"
+|
-  extern open_conn(char *, char *);
+| extern open_conn(char *, char *);
+|
-  int main(int argc, char **argv)
+| int main(int argc, char **argv)
+| {
-    int sock;
+|    int sock;
-    short nu;
+|    short nu;
+|
-    if (argc != 2) {
+|    if (argc != 2) {
-       fprintf(stderr, "Usage: %s host\n", argv[0]);
+|       fprintf(stderr, "Usage: %s host\n", argv[0]);
-       exit(1);
+|       exit(1);
+|    }
-    if ((sock = open_conn(argv[1], SERVICE)) < 0)
+|    if ((sock = open_conn(argv[1], SERVICE)) < 0)
-       exit(1);
+|       exit(1);
-    read(sock, (char *) &nu, sizeof(nu));
+|    read(sock, (char *) &nu, sizeof(nu));
-    nu = ntohs(nu);
+|    nu = ntohs(nu);
-    if (nu == -1) {
+|    if (nu == -1) {
-       fprintf(stderr, "Can't read \"utmp\" on %s\n", argv[1]);
+|       fprintf(stderr, "Can't read \"utmp\" on %s\n", argv[1]);
-       exit(1);
+|       exit(1);
+|    }
-    if (nu) {
+|    if (nu) {
-       fprintf(stdout, "%d user(s) logged on %s\n", nu, argv[1]);
+|       fprintf(stdout, "%d user(s) logged on %s\n", nu, argv[1]);
-       exit(0);
+|       exit(0);
+|    }
-    fprintf(stdout, "Nobody on %s\n", argv[1]);
+|    fprintf(stdout, "Nobody on %s\n", argv[1]);
-    exit(0);
+|    exit(0);
+| }
-Le serveur <tt>nbusd</tt>, quant à lui, lance en tâche de fond un processus "démon" qui exécutera la fonction de service nbus (lignes See à See ) à chaque requête d'un client. Ce processus démon est réalisé par la fonction serv_daemon.
+Le serveur <tt>nbusd</tt>, quant à lui, lance en tâche de fond un processus "démon" qui exécutera la fonction de service nbus (lignes See à See ) à chaque requête d'un client. Ce processus démon est réalisé par la fonction <tt>serv_daemon</tt>.

← Older revision		Revision as of 16:54, 15 December 2005
Line 194:		Line 194:

	Le serveur proprement dit est réalisé par une unique fonction. C'est la fonction <tt>serv_daemon</tt> qui a quatre arguments. Le premier est la famille d'adresse gérée, <tt>PF_INET</tt> ou <tt>PF_INET6</tt>, ou <tt>PF_UNSPEC</tt> pour écouter dans les deux familles. Le deuxième est, comme dans le cas de <tt>open_conn</tt>, le nom du service tel qu'il apparaît dans le fichier <tt>/etc/services</tt>. Le troisième argument est un pointeur vers la fonction de service dont le type <tt>(int(*)(void))</tt> sera commenté ultérieurement. Enfin le dernier argument est le nom passé au démon syslogd lors de l'impression des messages d'erreur [[(ligne See )]]. Si le dernier argument est le pointeur nul, ce nom est par défaut le nom du service. Un aperçu du déroulement de la fonction <tt>serv_daemon</tt> est donné par la figure Algorithme du serveur.		Le serveur proprement dit est réalisé par une unique fonction. C'est la fonction <tt>serv_daemon</tt> qui a quatre arguments. Le premier est la famille d'adresse gérée, <tt>PF_INET</tt> ou <tt>PF_INET6</tt>, ou <tt>PF_UNSPEC</tt> pour écouter dans les deux familles. Le deuxième est, comme dans le cas de <tt>open_conn</tt>, le nom du service tel qu'il apparaît dans le fichier <tt>/etc/services</tt>. Le troisième argument est un pointeur vers la fonction de service dont le type <tt>(int(*)(void))</tt> sera commenté ultérieurement. Enfin le dernier argument est le nom passé au démon syslogd lors de l'impression des messages d'erreur [[(ligne See )]]. Si le dernier argument est le pointeur nul, ce nom est par défaut le nom du service. Un aperçu du déroulement de la fonction <tt>serv_daemon</tt> est donné par la figure Algorithme du serveur.
		+
		+	[[image:CS194.gif]]

@@ Line 141: / Line 141: @@
 Comme on l'a vu plus haut dans le code du client <tt>nbus.c</tt>, l'établissement de la connexion TCP se fait au moyen de la fonction <tt>open_conn</tt>. Cette fonction prend en premier argument le nom de la machine avec laquelle on va établir la connexion TCP et en deuxième argument le nom du service tel qu'il apparaît dans le fichier <tt>/etc/services</tt>. La valeur retournée par <tt>open_conn</tt> est soit <tt>-1</tt> en cas d'erreur, soit le descripteur associé à la socket réalisant la connexion. La figure Algorithme du client visualise l'algorithme employé.
-[[image:CS194.gif]]
+[[image:CS193.gif]]
 La première étape sera la construction de l'adresse de la socket distante, ceci via la primitive getaddrinfo. On remarquera que le champ <tt>ai_family</tt> de la structure <tt>hints</tt> a été initialisé à la valeur <tt>PF_UNSPEC</tt>, ce qui signifie que, suivant que l'on donne en argument à la commande nbus un nom de machine (ou une adresse numérique) IPv4 ou IPv6, on travaillera avec une socket soit dans la famille des protocoles <tt>PF_INET</tt>, soit dans la famille des protocoles <tt>PF_INET6</tt>. Si on avait fait le choix de forcer la famille des protocoles à la valeur <tt>PF_INET6</tt>, il aurait fallu initialiser les champs <tt>ai_flags</tt> et <tt>ai_family</tt> respectivement aux valeurs <tt>AI_V4MAPPED</tt> et <tt>PF_INET6</tt> (les adresses IPv4 seraient dans ce cas "mappées"). Si, comme dans l'exemple proposé, on ne fait pas ce choix, on notera qu'il n'y a aucune différence entre le code IPv4 et le code IPv6.