- Mettez dans vos favoris le lien vers la documentation de Akka.
- Récupérez le projet "intro-akka" et importez le comme projet Maven dans IntelliJ.
- Étudiez le fichier "pom.xml" et explorez la structure du projet.
- Étudiez le contenu du package "m2dl.pcr.akka.helloworld1".
- Éxécutez la classe "System" de ce package.
- Étudiez le contenu du package "m2dl.pcr.akka.helloworld2".
- Éxécutez la classe "System" de ce package. Comment expliquer le comportement du système observé ?
- Étudiez le contenu du package "m2dl.pcr.akka.helloworld3".
- Éxécutez la classe "System" de ce package. Expliquez le comportement du système observé :
- que représentent les objets "hello" et "goodbye" ?
- que permet de faire l'exécution de "getContext().unbecome()" ?
- que signifie l'utilisation du deuxième paramètre de l'appel à "become" dans la définition de l'objet "hello" ?
Dans un nouveau package, implémentez un système à 3 acteurs. L'acteur parent, lorsqu'il reçoit un message msg correspondant à une chaîne de caractère, délègue en fonction de l'un de ses 2 comportements "hello" ou "goodbye" l'affichage d'un message "Hello" ou "Good bye" à un de ses enfants respectivement spécialisé pour afficher "Hello msg !" ou "Good bye msg !". Après chaque traitement de message, l'acteur parent change de comportement.
Rappel de l’algorithme vu en cours : les nombres premiers sont représentés par des acteurs qui forment une chaîne et se passent les uns les autres les nombres en filtrant (« cribler ») ceux qui sont des multiples du nombre qu’ils représentent. Chaque acteur a deux comportements possibles :
- soit l’acteur est en bout de chaîne et si le nombre qu’on lui envoie n’est pas filtré, alors il crée un acteur représentant ce nombre pour étendre la chaîne avec celui-ci et change de comportement pour le second afin de devenir un intermédiaire dans la chaîne ;
- soit l’acteur est un intermédiaire dans la chaîne et si le nombre qu’on lui envoi n’est pas filtré, alors il le passe à l’acteur suivant dans la chaîne (dont il a mémorisé l’adresse car l’ayant créé).
-
Dans un nouveau package, implémentez cet algorithme de telle sorte que l’on puisse passer les nombres de 3 à N (argument du programme) à un acteur représentant le nombre 2 que l’on aura créé auparavant.
-
À chaque fois qu’un nombre premier sera trouvé, il faudra l’afficher.
-
Modifiez le programme pour terminer en chaîne l’exécution des acteurs une fois que tout les nombres ont été envoyés.
En s’appuyant sur les méthodes disponibles dans la classe StringUtils fournie dans le package "m2dl.pcr.akka.stringservices", définir et implémenter dans ce même package une application dans laquelle cohabitent un service de cryptage CryptageProvider et un service d’ajout de contrôle d’erreur ErreurControleProvider pour des chaînes de caractères.
Chaque service sera représenté par un acteur, leurs caractéristiques sont les suivantes :
- CryptageProvider reçoit des messages contenant une chaîne de caractères et l’adresse d’un acteur récepteur (Recepteur). Il encrypte la chaîne de caractère et l’envoi à l’acteur Recepteur.
- ErreurControleProvider reçoit des messages contenant une chaîne de caractères et l’adresse d’un acteur récepteur (Recepteur). Il ajoute un contrôle d’erreur à la chaîne de caractère et l’envoi à l’acteur Recepteur.
Ces services seront utilisés séparément (pour les tester individuellement) ainsi que composés. L’acteur Recepteur sera susceptible de recevoir ces différents types de résultats (encrypté, avec contrôle d’erreur et composition).
Nous nous restreindrons aux 3 cas d’utilisation suivants :
- -> CryptageProvider -> Recepteur
- -> ErreurControleProvider -> Recepteur
- -> CryptageProvider -> ErreurControleProvider -> Recepteur
L’ActorSystem créera les différents services et le récepteur.
Le troisième cas d'utilisation correspond à la mise en œuvre de la composition séquentielle des services. Il est attendu une implantation conforme à la solution étudiée en cours.
L'objectif de cette partie est d'illustrer les capacités de Akka pour la gestion d'acteurs distribués (remote capabilities). Deux liens utils pour mener à bien votre travail :
Reprendre le 3ème cas d'utilisation de la partie 3 (composition) de telle sorte que votre application déployée dans une VM dédiée exploite les acteurs CryptageProvider et ErreurControleProvider déployés chacun sur une VM dédiée.
Dans un nouveau package, définir et implémenter une application dans laquelle un acteur "mobile" s'exécute séquentiellement sur plusieurs "places". Ici, les places sont des objets de type ActorSystem. Le comportement de base de cet acteur est d'afficher la place sur laquelle il se trouve en réponse au message "Where are you?". L'acteur réagit aussi à un autre type de message de type ActorSystem. Alors, il "se déplace" dans cette nouvelle place passée par message, conformément au protocole vu en cours.
Pour déployer et tester l'application, on ouvrira trois places de nom "Marseille", "Lyon" et "Paris". L'agent mobile sera initialement créé "à Marseille", puis on lui demandera de se déplacer succéssivement "à Lyon" puis "à Paris". Après la création et après chaque déplacement, on lui demandera d'afficher la place sur laquelle il se trouve. Tous ces messages seront envoyés à la référence initiale de l'acteur mobile.
Dans une étape suivante, on pourra répartir les places sur différentes machines virtuelles pour exécuter réellement dans un contexte réparti.
L'objectif de cette activité est le développement d'un serveur et d'un client de discussion (très) rudimentaire à l'aide d'Akka.
- Implantez le serveur de discussions.
- Implantez un client de votre serveur de discussions en utilisant les librairies d'interface de votre choix (JavaFX, Swing, ligne de commande).