Communication en utilisant des datagrammes

L'envoi et la réception de messages par datagrammes nécessitent d'effectuer les opérations décrites ci-dessous.

• on crée un socket sur la machine locale pour envoyer ou recevoir des datagrammes en instanciant la classe java.net.DatagramSocket ;
• pour l'envoi d'un message : on construit un « paquet », qui est en fait une instance de la classe java.net.DatagramPacket, contenant des données ; ce paquet comporte aussi notamment l'adresse IP de destination du message. Autrement dit, on commence par écrire un message et on le met dans une enveloppe comportant l'adresse écrite à l'aide d'une instance de la classe java.net.InetAdress. On envoie le message à l'aide de l'instance de DatagramSocket qu'on a construite ;
• pour la réception d'un message : on crée un « paquet », instance de la classe java.net.DatagramPacket, avec un tampon vide susceptible de recevoir le message ; on attend l'arrivée du message en utilisant l'instance de DatagramSocket qu'on a construite ; on déchiffre le message.

Le programme EnvoiMessage envoie des messages par des datagrammes sur une machine dont le nom est indiqué sur la ligne de commande ; le numéro de port de la machine destinatrice sur lequel les messages seront attendus est aussi indiqué sur la ligne de commande ; ce numéro doit être compris entre 1024 et 65535. Chaque message est donné par l'entrée standard sur une seule ligne. Après l'envoi de chaque message, le programme attend un accusé de réception.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;

class EnvoiMessage {
	public static void main(String[] arg) {
		int portDestinataire;
		InetAddress adresseIP;
		DatagramSocket socketUDP;
		DatagramPacket message;
		BufferedReader entree;
		String ligne;
		int longueur;
		byte[] tampon;

		try {
			socketUDP = new DatagramSocket();
			System.out.println
("Port local : " + socketUDP.getLocalPort());
			adresseIP = InetAddress.getByName(arg[0]);
			portDestinataire = Integer.parseInt(arg[1]);
			entree = new BufferedReader(new InputStreamReader(System.in));

			while(true) {
				ligne = entree.readLine();

				// on construit le paquet a envoyer
				tampon = ligne.getBytes();
				longueur = tampon.length;
				message = new DatagramPacket(tampon, longueur, adresseIP, portDestinataire);
				socketUDP.send(message);

				// on attend un accusé de réception
				tampon = new byte[256];
				message = new DatagramPacket(tampon, tampon.length);
				socketUDP.receive(message);
				ligne = new String(tampon);
				ligne = ligne.substring(0, message.getLength());
				System.out.println("Du port " + message.getPort() + " de la machine " + 
                                        message.getAddress().getHostName() + " : " + ligne);
			}
		}
		catch(ArrayIndexOutOfBoundsException exc) {
			System.out.println("Avez-vous donne le nom de la machine destinatrice et le numero de port du client ?");
		}
		catch(UnknownHostException exc) {
			System.out.println("Destinataire inconnu");
		}
		catch(SocketException exc) {
			System.out.println("Probleme d'ouverture de la socket");
		}
		catch(IOException exc) {
			System.out.println("Probleme sur la reception ou l'envoi du message");
		}
		catch(NumberFormatException exc) {
			System.out.println("Le second argument doit etre un entier");
		}
	}
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

class ReceptionMessage {
	public static void main(String[] arg) {
		DatagramSocket socketUDP;
		DatagramPacket message;
		byte[] tampon;
		int portLocal;
		byte[] tamponAccuse = "accuse de reception".getBytes();
		int longueurAccuse = tamponAccuse.length;
		String texte ;

		try {
			portLocal = Integer.parseInt(arg[0]);
			socketUDP = new DatagramSocket(portLocal);
			while(true) {
				// on se prepare à recevoir un datagramme
				tampon = new byte[256];
				message = new DatagramPacket(tampon, tampon.length);
				socketUDP.receive(message);
				InetAddress adresseIP = message.getAddress();
				int portDistant = message.getPort();
				texte = new String(tampon) ;
				texte = texte.substring(0, message.getLength());
				System.out.println("Reception du port " + portDistant + " de la machine " + adresseIP.getHostName() + " : " + texte);

				// On envoie un accuse de reception
				message = new DatagramPacket(tamponAccuse, longueurAccuse, adresseIP, portDistant);
				socketUDP.send(message);
			}
		}

		catch(ArrayIndexOutOfBoundsException exc) {
			System.out.println("Avez-vous donne le numero de port sur lequel vous attendez le message ?");
		}
		catch(SocketException exc) { System.out.println("Probleme d'ouverture du socket");
		}
		catch(IOException exc) {
			System.out.println("Probleme sur la reception ou l'envoi du message");
		}
	}
}

Si on lance sur la machine gargantua.enst.fr :
    java ReceptionMessage 10302
puis si, sur la machine mars.eons.fr, on lance la commande :
    java EnvoiMessage gargantua.enst.fr 10302
puis qu'on indique par le clavier de cette machine :
    bonjour
alors, sur gargantua, on peut obtenir :
    Reception du port 56327 de la machine mars.eons.fr : bonjour
et sur mars :
    Port local : 56327
    Du port 10302 de la machine gargantua.enst.fr : accuse de reception

Vous pouvez accéder à :

• La classe EnvoiMessage.java
• La classe ReceptionMessage.java