[inetdoc.LINUX]

Au niveau du client, l'objectif est d'ouvrir un nouveau socket ; ce qui revient à ouvrir un canal de communication réseau avec la fonction socket.

  int socketDescriptor;

<snipped/>
  socketDescriptor = socket(AF_INET, SOCK_DGRAM, 0);
  if (socketDescriptor < 0) {
    cerr << "Impossible de créer le socket\n";
    exit(1);
    }

Une fois le canal de communication réseau correctement ouvert, on peut passer à l'émission des datagrammes avec la fonction sendto.

  int socketDescriptor;
  char msg[MSG_ARRAY_SIZE];
  struct sockaddr_in serverAddress;

<snipped/>
if (sendto(socketDescriptor, msg, strlen(msg), 0,
           (struct sockaddr *) &serverAddress,
           sizeof(serverAddress)) < 0) {
  cerr << "Émission du message impossible\n";
  close(socketDescriptor);
  exit(1);
  }

Ensuite, il ne manque plus que la description de la réception des datagrammes renvoyés par le serveur.

  int numRead;

<snipped/>
numRead = recv(socketDescriptor, msg, MAX_MSG, 0);
if (numRead < 0) {
  cerr << "Aucune réponse du serveur ?\n";
  close(socketDescriptor);
  exit(1);
  }

Pour toute information complémentaire sur les fonctions utilisées, consulter les pages de manuels correspondantes. Pour la fonction socket on peut utiliser man 2 socket ou man 7 socket par exemple.

Code du programme udp-client.cc :

// $Id: udp-client.cc 1473 2010-03-03 23:03:07Z latu $
#include <netdb.h>
#include <netinet/in.h>
#include <unistd.h>
#include <limits>
#include <iostream>
#include <cstdlib>
#include <cstring>

#define MAX_MSG 100
// 3 caractères pour les codes ASCII 'cr', 'lf' et '\0'
#define MSG_ARRAY_SIZE (MAX_MSG+3)

using namespace std;

int main()
{
  int socketDescriptor;
  int numRead;
  unsigned short int serverPort;
  struct sockaddr_in serverAddress;
  struct hostent *hostInfo;
  struct timeval timeVal;
  fd_set readSet;
  char msg[MSG_ARRAY_SIZE], c;

  cout << "Entrez le nom du serveur ou son adresse IP : ";

  memset(msg, 0x0, MSG_ARRAY_SIZE);  // Mise à zéro du tampon
  cin.get(msg, MAX_MSG, '\n');

  // gethostbyname() reçoit un nom d'hôte ou une adresse IP en notation
  // standard 4 octets en décimal séparés par des points puis renvoie un
  // pointeur sur une structure hostent. Nous avons besoin de cette structure
  // plus loin. La composition de cette structure n'est pas importante pour
  // l'instant.
  hostInfo = gethostbyname(msg);
  if (hostInfo == NULL) {
    cerr << "Problème dans l'interprétation des informations d'hôte : " << msg << "\n";
    exit(1);
  }

  cout << "Entrez le numéro de port du serveur : ";
  cin >> serverPort;
  cin.ignore(1,'\n'); // suppression du saut de ligne

  // Création de socket. "AF_INET" correspond à l'utilisation du protocole IPv4
  // au niveau réseau. "SOCK_DGRAM" correspond à l'utilisation du protocole UDP
  // au niveau transport. La valeur 0 indique qu'un seul protocole sera utilisé
  // avec ce socket.
  socketDescriptor = socket(AF_INET, SOCK_DGRAM, 0);
  if (socketDescriptor < 0) {
    cerr << "Impossible de créer le socket\n";
    exit(1);
  }

  // Initialisation des champs de la structure serverAddress
  serverAddress.sin_family = hostInfo->h_addrtype;
  memcpy((char *) &serverAddress.sin_addr.s_addr,
         hostInfo->h_addr_list[0], hostInfo->h_length);
  serverAddress.sin_port = htons(serverPort);

  cout << "\nEntrez quelques caractères au clavier.\n";
  cout << "Le serveur les modfiera et les renverra.\n";
  cout << "Pour sortir, entrez une ligne avec le caractère '.' uniquement\n";
  cout << "Si une ligne dépasse " << MAX_MSG << " caractères,\n";
  cout << "seuls les " << MAX_MSG << " premiers caractères seront utilisés.\n\n";

  // Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
  // limite MAX_MSG. Puis suppression du saut de ligne.
  cout << "Saisie du message : ";
  memset(msg, 0x0, MSG_ARRAY_SIZE);  // Mise à zéro du tampon
  cin.get(msg, MAX_MSG, '\n');
  // suppression des caractères supplémentaires et du saut de ligne
  cin.ignore(numeric_limits<streamsize>::max(),'\n'); 

  // Arrêt lorsque l'utilisateur saisit une ligne ne contenant qu'un point
  while (strcmp(msg, ".")) {
    // Envoi de la ligne au serveur
    if (sendto(socketDescriptor, msg, strlen(msg), 0,
               (struct sockaddr *) &serverAddress,
               sizeof(serverAddress)) < 0) {
      cerr << "Émission du message impossible\n";
      close(socketDescriptor);
      exit(1);
    }

    // Attente de la réponse pendant une seconde.
    FD_ZERO(&readSet);
    FD_SET(socketDescriptor, &readSet);
    timeVal.tv_sec = 1;
    timeVal.tv_usec = 0;

    if (select(socketDescriptor+1, &readSet, NULL, NULL, &timeVal)) {
      // Lecture de la ligne modifiée par le serveur.
      memset(msg, 0x0, MSG_ARRAY_SIZE);  // Mise à zéro du tampon
      numRead = recv(socketDescriptor, msg, MAX_MSG, 0);
      if (numRead < 0) {
        cerr << "Aucune réponse du serveur ?\n";
        close(socketDescriptor);
        exit(1);
      }

      cout << "Message traité : " << msg << "\n";
    }
    else {
      cout << "** Le serveur n'a répondu dans la seconde.\n";
    }

    // Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
    // limite MAX_MSG. Puis suppression du saut de ligne. Comme ci-dessus.
    cout << "Saisie du message : ";
    memset(msg, 0x0, MSG_ARRAY_SIZE);  // Mise à zéro du tampon
    cin.get(msg, MAX_MSG, '\n');
    // suppression des caractères supplémentaires et du saut de ligne
    cin.ignore(numeric_limits<streamsize>::max(),'\n'); 
  }

  close(socketDescriptor);
  return 0;
}