WebSocket, et comment on teste?

18 juin 2014

Tags : Assertj, Awaitility, Java, Jetty, SimpleWeb4j, websocket

On a vu comment implémenter des websockets avec SimpleWeb4j dans un précédant article, nous allons maintenant voir comment tester de manière automatisée la partie serveur websocket.


Librairies tierces

Pour garder un code relativement propre, je vais utiliser trois librairies :


Je veux faire quoi comme test?

Je cherche à tester le code du billet précédant qui, pour rappel, était un système de chat. Le serveur de websocket reçoit donc des messages qu'il redistribue à tous les clients connectés.

Scénario de test :

  • Ouverture d'une session 1.
  • Envoi d'un message par la session 1 (message 1).
  • Ouverture d'une session 2.
  • Envoi d'un message par la session 2 (message 2).
  • Envoi d'un message par la session 1 (message 3).
  • Fermeture de la session 1.
  • Envoi d'un message par la session 2 (message 4).
  • Fermeture de la session 2.

Vérifications à faire :

  • La session 1 a reçu 3 messages (les messages 1 à 3)
  • La session 2 a reçu 3 messages (les messages 2 à 4)


Code de test

Assez parler, place au code. J'espère que les commentaires sont suffisants, si ce n'est pas le cas, n'hésitez pas à le dire j'en ajouterais.

Commentaires

WebSocket et SimpleWeb4j

11 juin 2014

Tags : java8, javascript, SimpleWeb4j, websocket

Nous allons voir comment faire du websocket avec SimpleWeb4j.

WebSocket c'est quoi

WebSocket est un protocole permettant la communication de type push entre un browser et un serveur de manière bi-directionnelle.


On fait quoi comme exemple?

Comme je suis super original, on va partir sur un chat (le truc pour discuter, pas l'animal !), ça nous rappellera la grande époque de caramail :)

Pour mettre en place un chat, on a besoin d'un service côté serveur qui peut recevoir des messages en push depuis les clients, et quand il en reçoit un le redistribue à tous les clients.


La partie serveur

Nous allons commencer par créer notre objet métier représentant un message, celui-ci contient l'utilisateur, le texte et la date du message. Il servira pour les messages que l'on envoie aux clients (pour les flux client -> serveur, nous utiliserons une simple String).

Nous allons maintenant créer la route de la websocket avec la méthode SimpleWeb4j.websocket, cette méthode prend en paramètre une String représentant l'url et un WebSocketAdapter. Un WebSocketAdapter et une factory qui contient une méthode prenant en paramètres les "RouteParameters" et qui construit un WebSocketListenner. On a donc le code suivant pour l'instant :

Voyons maintenant comment construire le "WebSocketListener", nous avons pour ça un builder. Nous souhaitons construire un listener en implémentant un comportement sur 3 événements :

  • onConnect : on ajoute la session dans un set pour connaître les sessions ouvertes.
  • onClose : on supprime la session de notre set.
  • onMessage : on envoi le message reçu à tout les clients.
Voici donc le résultat final :


La partie cliente

Pour la partie cliente, on a un objet javascript "WebSocket" qui prend l'url en paramètre du constructeur.

Il nous reste après à définir les callback "onmessage" et "onopen". Pour envoyer un message au serveur, il suffit d'utiliser la méthode WebSocket.send. Si vous voulez plus de détails, vous pouvez aller voir la page de mozilla.

Voici donc la page html complète, comme d'habitude, j'utilise angular.js :) >/p>

Alors, ça vous parait compliqué de faire du WebSocket?

Commentaires

Server Sent Events réactifs avec SimpleWeb4j

04 juin 2014

Tags : EventSource, java8, reactive, Server-Sent-Events, SimpleWeb4j, SSE

Nous avons vu hier un exemple simple de Server Sent Events avec SimpleWeb4j, passons maintenant à plus complexe, un exemple dit "réactif", ce n'est pas le flux qui demande la valeur suivante, mais bien un "service" extérieure qui déclenche l'envoi à tous les flux ouverts.

Pour l'exemple, nous allons créer trois générateurs d'événements, avec chacun un délai aléatoire entre les événements.

Nous allons donc tout d'abord créer une classe "Event", cette classe contient un nom, une valeur et l'heure de création. La valeur est créée de manière aléatoire.

Nous allons ensuite créer un générateur, qui est un Runnable infini, et envoi des événements aux handlers SimpleWeb4j.

Un handler SimpleWeb4j est une classe fournie par SimpleWeb4j qui contient une méthode "next" permettant d'envoyer les événements. Nous stockerons ces handlers dans un ConcurrentHashSet pour pouvoir tous les adresser (et pas seulement le dernier flux créé.

Une fois tous ces composants créés, il suffit de déclarer la route, voici donc le résultat final :


J'espère vous avoir montré l'intérêt de SimpleWeb4j sur ce cas beaucoup moins simple que le précédent.

Si le sujet vous intéresse, vous pouvez regarder ma présentation donnée au Breizhcamp sur parleys :

Commentaires

Server Sent Events avec SimpleWeb4j

03 juin 2014

Tags : EventSource, java8, Server-Sent-Events, SimpleWeb4j, SSE

Je vous ai montré hier comment faire du SSE avec Jetty. Nous allons maintenant voir comment faire avec SimpleWeb4j.

L'exemple avec jetty était une horloge déclenchée toutes les secondes à partir de l'accès à l'url, voyons donc comment coder cela avec SimpleWeb4j : Simple, non?


Dans la vrai vie, on souhaite sans doute pouvoir déclencher simplement l'envoie d'un événement sans être dépendant d'un délai quelconque. Ce sera l'objet de l'article de demain :)

Commentaires

Services REST avec SimpleWeb4J

30 mai 2014

Tags : Java, json, REST, SimpleWeb4j

Cet article est le deuxième article de la série sur SimpleWeb4j

Dans le première article on a vu comment démarrer SimpleWeb4j en une ligne de code, dans l'article d'aujourd'hui, nous allors voir comment exposer des services REST en json.

Premiers cas : exposer une String "Hello World"

J'espère que le code est suffisamment simple pour ne pas avoir besoin d'explication.

On peux voir qu le résultat est entouré de guillemets, ceci est du au fait que SimpleWeb4j transforme la chaîne de caractère en json.


Deuxième cas : utilisation d'une variable de route

Cet exemple mérite peut-être un peu plus d'explications. SimpleWeb4j permet d'ajouter des paramètres à la route, ces paramètres sont préfixés de ':'. Pour les récupérer on utilise le paramètre RouteParameters qui est le deuxième argument de notre lambda. Le premier argument quand à lui contient l'objet envoyé dans le request body de la requête, nous ne l'utilisons donc pas.


Troisième cas : objet complexe

Nous avons vu que renvoyer une chaîne de caractère était plutôt simple, voyons maintenant comment renvoyer un objet plus complexe.

On peut donc voir que renvoyer un objet n'est pas plus compliqué, SimpleWeb4j s'occupe de transformer celui-ci en json



J'espère vous avoir donner envie de regarder SimpleWeb4j de plus près, si quelque chose vous manque, n'hésitez pas à le dire ou à faire une pull request sur github.

Commentaires

SimpleWeb4J - quick start

28 mai 2014

Tags : Java, SimpleWeb4j

Ceux qui me suivent connaissent sans doute déjà SimpleWeb4j. Il s'agit d'encore un framework web donc le but est de pouvoir faire du web en java de manière très simple.

Je n'ai jamais écrit d'article sur SimpleWeb4j, je vais donc écrire une série d'articles sur ce sujet afin de vous montrer la simplicité de ce framework.

Je vais commencer par le classique Quick Start, ou comment démarrer un serveur Web capable de servir des ressources statiques.

Dépendance maven

Ressources statiques

Mettez vos ressources statiques au sein d'un package "public" dans votre classpath.

Classe main

Il vous suffit ensuite de démarrer le serveur :

Et voilà, vous avez un serveur prêt sur http://localhost:9999, pas besoin de déclaration xml ou autre complexité, un simple appel à start suffit.

Commentaires