[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 << "cannot create 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 buf[LINE_ARRAY_SIZE];
  struct sockaddr_in serverAddress;

<snipped/>
if (sendto(socketDescriptor, buf, strlen(buf), 0,
           (struct sockaddr *) &serverAddress,
           sizeof(serverAddress)) < 0) {
  cerr << "cannot send data ";
  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, buf, MAX_LINE, 0);
if (numRead < 0) {
  cerr << "didn't get response from server?";
  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 :

#include <netdb.h>
#include <netinet/in.h>
#include <unistd.h>
#include <iostream>

#define MAX_LINE 100
// 3 caractères pour les codes ASCII 'cr', 'lf' et '\0'
#define LINE_ARRAY_SIZE (MAX_LINE+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 buf[LINE_ARRAY_SIZE], c;

  cout << "Enter server host name or IP address: ";

  memset(buf, 0x0, LINE_ARRAY_SIZE);  // Mise à zéro du tampon
  cin.get(buf, MAX_LINE, '\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(buf);
  if (hostInfo == NULL) {
    cout << "problem interpreting host: " << buf << "\n";
    exit(1);
  }

  cout << "Enter server port number: ";
  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 << "cannot create 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_LINE << " caractères,\n";
  cout << "seuls les " << MAX_LINE << " premiers caractères seront utilisés.\n\n";

  // Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
  // limite MAX_LINE. Puis suppression du saut de ligne.
  cout << "Input: ";
  memset(buf, 0x0, LINE_ARRAY_SIZE);  // Zero out the buffer.
  cin.get(buf, MAX_LINE, '\n');
  // suppression des caractères supplémentaires et du saut de ligne
  cin.ignore(1000,'\n'); 

  // Arrêt lorsque l'utilisateur saisit une ligne ne contenant qu'un point
  while (strcmp(buf, ".")) {
    // Envoi de la ligne au serveur
    if (sendto(socketDescriptor, buf, strlen(buf), 0,
               (struct sockaddr *) &serverAddress,
               sizeof(serverAddress)) < 0) {
      cerr << "cannot send data ";
      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(buf, 0x0, LINE_ARRAY_SIZE);  // Mise à zéro du tampon
      numRead = recv(socketDescriptor, buf, MAX_LINE, 0);
      if (numRead < 0) {
        cerr << "didn't get response from server?";
        close(socketDescriptor);
        exit(1);
      }

      cout << "Modified: " << buf << "\n";
    }
    else {
      cout << "** Server did not respond in 1 second.\n";
    }

    // Invite de commande pour l'utilisateur et lecture des caractères jusqu'à la
    // limite MAX_LINE. Puis suppression du saut de ligne. Comme ci-dessus.
    cout << "Input: ";
    memset(buf, 0x0, LINE_ARRAY_SIZE);  // Mise à zéro du tampon
    cin.get(buf, MAX_LINE, '\n');
    // suppression des caractères supplémentaires et du saut de ligne
    cin.ignore(1000,'\n'); 
  }

  close(socketDescriptor);
  return 0;
}