La programmation en Perl: Les trucs du réseau (Deuxiéme partie)

Dans notre dernier article, nous avons vu comment programmer un client en écrivant un simple utilitaire qui récupère les pages d'un serveur Web distant. Dans celui-ci, nous allons étudier l'écriture d'un petit serveur réseau. En guise d'application nous écrirons un serveur Web primaire. (L'intégralité du code de ce serveur se trouve à la fin du présent article pour les lecteurs qui trouveraient plus commode de le suivre au fure et à mesure des explications). N'hésitez pas à relire l'article précédant si vous n'avez plus en tête les concepts de base utilisés dans cette présentation.

Le point de départ

     use Socket;
     $this_host = `my-server.netmarket.com'; 
     $port = 8080; 
     $server_addr = (gethostbyname($this_host))[4]; 
     $server_struct = pack("S n a4 x8", AF_INET, $port, $server_addr); 
     $proto = (getprotobyname(`tcp'))[2]; 
     socket(SOCK, PF_INET, SOCK_STREAM, $proto)||  die "Failed to initialize socket: $!\n";

Souvenez vous de l'article précédant, le serveur Web utilisait le port 80 par défaut. Pourquoi donc cet exemple utilise-t-il le port 8080 ? Pour des questions de sécurité, les numéros de port inférieurs à 1024 ne peuvent être utilisés que par des serveurs lancés par root. L'arrière pensée de cette règle était de "garantir" que de tels serveurs (telnet, ftp, gopher, ... ), étaient administrés par des personnes "responsables" et que l'on pouvait donc s'y connecter en toute sécurité. Depuis l'explosion du nombre des stations de travail connectées au réseau, cette garantie n'en est plus une.

Revenons à notre exemple. Le serveur doit maintenant se préparer à recevoir des demandes de connexion sur le port et l'adresse définis :

     setsockopt(SOCK, SOL_SOCKET, SO_REUSEADDR,1) || 
          die "setsockopt() failed: $!\n"; 
     bind(SOCK, $server_struct) || die "bind() failed: $!\n"; 
     listen(SOCK, SOMAXCONN) || die "listen() failed: $!\n";

La fonction listen() est certainement mal nommée. Elle ne fait rien d'autre que spécifier la taille de la file des requêtes en attente de traitement par le serveur. Pratiquement toutes les implémentations de la couche sockette limitent cette queue à 5 entrées. Vous avez donc intèrêt à les traiter rapidement. SOMAXCONN, encore une constante définie dans Socket.pm, est généralement intialisée à 5. Si vous essayez une valeur plus grande le système d'exploitation limitera de toutes façon la queue à 5 entrées. Solaris 2.x est, à ma connaissance, le seul système d'exploitation moderne qui accepte une valeur supérieure à 5. (Il est amusant de noter que SOMAXCONN reste défini à 5 dans les headers du système).

Le traitement des requêtes en attende

     for (;;) { 
          $remote_host = accept(NEWSOCK, SOCK); 
          die "accept() error: $!\n" unless ($remote_host);
 
          # do some work here
          close(NEWSOCK); 
     }

La fonction accept rend une structure C contenant l'adresse de la machine distante, à moins que l'appel ait échoué, dans ce cas accept() retourne undef. Cette structure correspond à celle passée à connect. Vous pouvez l'utiliser pour récupérer l'adresse de la machine distante comme ceci :

     $raw_addr = (unpack("S n a4 x8",$remote_host))[2]; 
     @octets = unpack("C4", $raw_addr); 
     $address = join(".", @octets);

     $hostname = (gethostbyaddr($raw_addr,AF_INET))[0];

Un serveur Web élémentaire

HTTP est un protocole incroyablement simple. Les requêtes envoyées par le butineur sont des lignes de texte ASCII terminées par une ligne vide. Une fois qu'il a rencontré cette ligne vide, le serveur envoit sa réponse au client et rompt la communication. Bien que le client envoye généralement une foule d'informations avec sa requête, en pratique le serveur peut les ignorer toutes à l'exception de celles qui ont la forme suivante :

     GET /some/path/to/file.html ...

     while (<NEWSOCK>) { 
          last if (/^\s*$/); 
          next unless (/^GET /); 
          $path = (split(/\s+/))[1]; 
     }

     if (open(FILE, "< $docroot$path")) { 
          @lines = <FILE>; 
          print NEWSOCK @lines; 
          close(FILE); 
     } 
     else { 
          print NEWSOCK <<"EOErrMsg"; 
     <TITLE>Error</TITLE><H1>Error</H1> 
     The following error occurred while
     trying to retrieve your information:
     $! 
     EOErrMsg 
     }

Bravo. Si vous rassemblez les divers éléments de code que nous venons d'examiner, vous disposez du squelette d'un serveur Web. L'intégralité du code est donné à la fin de cet article pour vous permettre de mieux revoir tous les concepts que nous venons d'explorer.

Ce n'est pas tout

  /../../../../../../../etc/passwd

Dans le troisième et dernier article de cette série, nous verrons comment résoudre, entre autre, ces 2 problèmes de notre mini serveur Web.

     #!/packages/misc/bin/perl

     use Socket;

     $docroot = `/home/hal/public_html'; 
     $this_host = `my-server.netmarket.com'; 
     $port = 8080;

     # Initialize C structure 
     $server_addr =(gethostbyname($this_host))[4]; 
     $server_struct = pack("S n a4 x8", AF_INET,$port, $server_addr);

     # Set up socket 
     $proto = (getprotobyname(`tcp'))[2]; 
     socket(SOCK, PF_INET, SOCK_STREAM,$proto)|| die "Failed to initialize socket:$!\n";

     # Bind to address/port and set up pending queue 
     setsockopt(SOCK, SOL_SOCKET, SO_REUSEADDR, 1) || die "setsockopt() failed: $!\n"; 
     bind(SOCK, $server_struct) || die "bind() failed: $!\n"; 
     listen(SOCK, SOMAXCONN) || die "listen() failed: $!\n";

     # Deal with requests 
     for (;;) { 
          # Grab next pending request 
          # 
          $remote_host = accept(NEWSOCK, SOCK); 
          die "accept() error: $!\n" unless ($remote_host);
		
          # Read client request and get $path 		
          while (<NEWSOCK>) { 
               last if (/^\s*$/); 
               next unless (/^GET /); 
               $path = (split(/\s+/))[1]; 
          }

          # Print a line of logging info to STDOUT 
          $raw_addr = (unpack("S n a4 x8", $remote_host))[2];
          $dot_addr = join(".", unpack("C4", $raw_addr)); 
          $name = (gethostbyaddr($raw_addr, AF_INET))[0]; 
          print "$dot_addr\t$name\t$path\n";
		
          # Respond with info or error message 
          if (open(FILE, "< $docroot$path")) { 
               @lines = <FILE>; 
               print NEWSOCK @lines; 
               close(FILE); 
          } 
          else { 
               print NEWSOCK <<"EOErrMsg"; 
     <TITLE>Error</TITLE><H1>Error</H1> 
     The following error occurred while trying to retrieve your information: $! 
     EOErrMsg 
          }

          # All done 
          close(NEWSOCK); 
     }

Traduction de ;login: Vol. 21 No. 5, Octobre 1996.

---

Dernière édition: 15 mars 1998 phb Original 12/5/96

Back to the original Retour à l'index