• Exercice 1 : exemple d'un programme RabbitMQ avec Java
• Exercice 2 : premier programme RabbitMQ avec Java
• Exercice 3 :sérialisation/désérialisation/filtrage de messages : alerte pour la gestion de ligne de bus
• Exercice 4 : Controle sur la perte de message
• Exercice 5 : mise en oeuvre d'un client/serveur
• Corrections

Exercice 1 : exemple d'un programme RabbitMQ avec Java

L'objectif de cet exercice est de vous montrer comment créer une application avec RabbitMQ. Nous utiliserons des clients Java pour ce faire.

Dans un premier temps, il est nécessaire de mettre en place l'environnement pour l'utilisation de RabbitMQ avec java. Dans un terminal, lancer les commandes suivantes :

cd /home/tp/poc_rabbitmq
docker-compose up -d

• Login: user
• Password: bitnami

1. Lancer firefox en ouvrant l'URL http://localhost:8051
2. Vous connecter avec le login/password ci-dessous
3. Puis inspecter les différentes informations offertes par l'interface d'administration de RabbitMQ. Notez que c'est surtout quand vous ferrez tourner vos programmes que vous constaterez évoluer les informations présentées dans cette interface.

source rabbit.bash

make

java Subscriber paul 'legumes.*' &
java Subscriber jacques legumes.tomate &
java Subscriber eric legumes.radis legumes.tomate &

java Publisher legumes.radis coucou1
java Publisher legumes.tomate coucou2 
java Publisher plouf coucou3

Publisher : legumes.radis coucou1
Subscriber paul recoit legumes.radis : coucou1
Subscriber eric recoit legumes.radis : coucou1
Publisher : legumes.tomate coucou2
Subscriber paul recoit legumes.tomate : coucou2
Subscriber eric recoit legumes.tomate : coucou2
Subscriber jacques recoit legumes.tomate':'coucou2
Publisher : plouf coucou3

1. Quels ports/machines sont utilisés par ces programmes ?
2. Pourquoi le message coucou3 n'est pas reçu ?
3. Le programme qui lit les messages utilise-t-il des communications en mode push ou en mode pull ?
4. Quel est le nom de l'exchange utilisé pour ces communications ?
5. Lancer les 2 programmes selon plusieurs scénarios et naviguer dans l'interface d'administration pour voir l'effet de l'exécution de ces programmes.

Exercice 2 : premier programme RabbitMQ avec Java

Pour cet exercice, récupérez les fichiers à partir du répertoire EXO2 . Sauvez tous ces fichiers dans un répertoire nommé EXO2. Compléter les programme Lecteur_Depeche.java et Redacteur_Depeche.java de sorte que :

• Redacteur_Depeche.java prends 3 paramètres : 2 noms de ville et 1 message à envoyer. Ce programme envoit le message deux fois avec une clef différente: les deux noms de ville sont utilisés comme clef.
• Lecteur_Depeche.java qui lit et affiche les messages pour une ville donnée. Ce programme ne prend qu'un seul paramètre : le nom de ville dont le lecteur souhaite recevoir les informations. Ici aussi, le nom de ville est employé comme une clef.
• On vous donne un exemple d'utilisation avec le programme lance.sh qui doit générer le résultat suivant :
  
  

Exercice 3 : sérialisation/désérialisation/filtrage de messages : alerte pour la gestion de ligne de bus

Pour cet exercice, récupérez les fichiers à partir du répertoire EXO3 . Sauvez tous ces fichiers dans un répertoire nommé EXO3.

On vous demande d'implanter une application composée de 3 programmes et dont le but est d'émettre, de filtrer et de transmettre des messages permettant de connaitre l'état d'un réseau de lignes de bus.

• Le programme Emetteur.java produit et émet les messages vers le programme Filtrage.java. Ce programme est employé pour signaler un événement sur une ligne de bus.
  
  Chaque message émit/reçu décrit un événement intervenu sur une ligne de bus et décrit également son impact sur la ligne en question. Chaque message contient donc 3 informations: le numéro de ligne de bus concerné, l'événement et l'état de la ligne. Les classes Evenement.java et Statut.java décrivent respectivement les événements possibles et l'état de la ligne après l'événement.
  
  
• Le programme Filtrage.java réceptionne les messages émis par Emetteur.java et renvoie également différents messages vers Recepteur.java
  
  
• Le programme Recepteur.java permet de réceptionner les différents messages envoyés par Filtrage.java. Ce programme peut être utilisé soit par les usagers, soit par l'atelier de maintenance de la compagnie de bus. Les usagers et l'atelier utilisent tous le programme Recepteur.java pour recevoir leurs messages.

String s = Statut.Arret.name();

 String [] result = Message.split("#");
 

1. Transfèrer le message sans le modifier vers l'atelier.
2. Envoyer un message vers les usagers en indiquant l'état de ligne. Chacun de ces messages doit comporter le numéro de ligne concerné ainsi que l'état de la ligne (le message peut être construit avec la classe Statut.java).
3. Comptabiliser le nombre d'événements et envoyer cette information à l'atelier.

• Lorsque le programme Recepteur.java est utilisé par un usager des bus, le programme ne réceptionne que les messages indiquant l'état des lignes de bus et uniquement pour certains événements ayant modifiés l'état de la ligne. L'événement constitue une clef pour Recepteur.java : en d'autres termes, chaque récepteur indique pour quels événements il souhaite obtenir l'état des lignes. Ainsi, le script lance.sh indique que usager1 souhaite recevoir l'état des lignes lorsque des évenements Travaux et Accident interviennent.
• Lorsque le programme Recepteur.java est utilisé par l'atelier de la compagnie de bus, le programme doit recevoir tous les messages émis par Filtrage.java.

Exercice 4 : Controle sur la perte de message

Pour cet exercice, récuperer les fichiers qui sont disponibles dans ce répertoire . Sauvez tous ces fichiers dans un répertoire EXO4.

Dans cet exercice, on cherche à controler la perte de message, suite, par exemple, à l'arrêt d'un subscriber. On vous demande de réaliser une application permettant de gérer et contrôler des operations bancaires. L'application est composée des 3 programmes suivants :

• Le programme Web.java est un programme déclenché à chaque fois qu'un client de la banque demande une opération bancaire. A chaque fois qu'un utilisateur souhaite faire une opération de débit ou de crédit sur son compte bancaire, Web.java génère un message vers RabbitMQ. Chaque message est composé : 1) d'un numéro d'opération unique permettant d'identifier chaque opération ; 2) du numéro de compte concerné ; 3) du type d'opération qui peut être soit un débit soit un crédit ; 4) du montant (en euros) de l'opération. Chaque message est envoyée dans un exchange avec comme clef le numéro de compte. On remarque qu'au même instant, plusieurs programmes Web.java peuvent s'exécuter simultanément puisque plusieurs clients peuvent se connecter à leur banque simultanément.
  
  
• Le programme Compte.java gère un compte bancaire donné. Le programme lit depuis l'exchange tous les messages associés au compte qu'il gère : la clef constitue le numéro de compte associé au programme.
  
  Le rôle du programme Compte.java est de stocker dans un fichier texte chaque opération effectué sur le compte. Chaque opération est enregistrée sur une ligne du fichier texte. Chaque ligne dans le fichier contient également le solde du compte après applicationn de l'opération. On suppose qu'au lancement de Compte.java, le solde est égal à 0.
  
  Pour chaque message lu par Compte.java, le programme :
  1. Lit la dernière ligne du fichier texte afin de récupérer le solde du compte
  2. Calcule le solde du compte après application de l'opération contenue dans le message recu
  3. Puis stocke le message ainsi que le nouveau solde en ajoutant une ligne dans le fichier texte.
     
     Voici par exemple les messages produits par Web.java pour une opération de crédit et deux opérations de débit, pour respectivement 100 euros, -10 euros et -20. Ces trois opérations concerne le numéro de compte 1 (2ème champs du message). Le premier champs constitue le numéro d'opération (respectivement 1, 2 et 3 pour la dernière opération).

     tp@tphost:$java Web 1 1 credit 100
     Compte 1 recoit:1#1#credit#100
     tp@tphost:$ java Web 2 1 debit  -10
     Compte 1 recoit:2#1#debit#10
     tp@tphost:$ java Web 3 1 debit  -20
     Compte 1 recoit:3#1#debit#20
     

     Les 3 opérations conduisent à un fichier texte contenant 3 lignes. Chaque ligne contient l'ensemble des informations d'une opération ainsi que le solde actuel du compte. Ainsi, nous obtenons dans le fichier texte ci-dessous pour le compte numéro 1:

     1#1#credit#100#100
     2#1#debit#-10#90
     3#1#debit#-20#70
     

     Dans cet exemple de fichier, la 3ème ligne montre qu'après la 3ième opération (opération de débit de -20 euros) le solde du compte est de 70 euros. En effet, le 1er champs est le numéro d'opération. Le second champs est le numéro de compte. Le 3ème champs est l'opération. La 4ième champs est le montant de l'opération et le 5ième champs constitue le solde du compte bancaire. Pour les entrées/sorties sur fichier, vous pouvez utiliser le programme Linefile.java qui permet d'ajouter une ligne dans le fichier (méthode AppendLine), de lire la dernière ligne du fichier (méthode ReadLastLine) ou de lire l'intégralité du fichier ligne par ligne (méthode ReadAllLine).
  
  
  
• Le 3ième programme, Controleur.java gère la perte de message. On lance un programme Controleur.java pour chaque programme Compte.java. Le programme Controleur.java recoit tous les messages à destinations du programme Compte.java.
  A chaque message reçu, Controleur.java, après une attente de 10 secondes, vérifie que l'opération associée au message a bien été réalisée en lisant le fichier texte associé. Si l'opération n'est pas présente dans le fichier texte, alors Controleur.java renvoit le message vers le serveur RabittMQ afin que Compte.java puisse réaliser l'opération perdue.

Exercice 5 : mise en oeuvre d'un mini-broker client/serveur

Dans cet exercice, on illustre comment fonctionne un mini-broker d'objets répartis similaire à CORBA ou Java RMI. Ce mini-broker utilise RabbitMQ pour implanter les communications entre les clients et les serveurs qui hébergent les objets accessibles à distance.

Récupérer les fichiers de cet exercice à partir du répertoire EXO5 . Sauvez tous ces fichiers dans un répertoire EXO4.


Question 1:

• Compiler, tester et étudier ces programmes.
• Chaque classe correspond à une entité CORBA. Dites pour chaque classe à quoi elle correspond dans CORBA.
• Comment sont véhiculés les requêtes du client au serveur ?