![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/pool_goulot-1.gif\")
<\/figure>\n<\/div>\n\n\n<\/p>\n\n\n\n
Qu’est ce qu’un pools de threads ?<\/h3>\n\n\n\n
Illustrons notre explication en prenant l’exemple des caisses d’un supermarch\u00e9<\/strong><\/p>\n\n\n\n Les clients sont r\u00e9partis sur l’ensemble des caisses et paient chacun leurs tours. <\/em><\/p>\n\n\n\n Ce n’est ni plus ni moins qu’un pool de threads !<\/p>\n\n\n\n En cas de forte affluence il est possible d’ouvrir de nouvelles caisses pour d\u00e9sengorger les files d’attentes.<\/em><\/p>\n\n\n\n En informatique chaque pool porte une responsabilit\u00e9 qui lui est propres, entr\u00e9es\/sorties, transactions, acc\u00e8s \u00e0 la base de donn\u00e9es etc etc.<\/p>\n\n\n\n <\/p>\n\n\n\n Il existe plusieurs fa\u00e7ons de d\u00e9clarer un pool de thread, notamment en lui d\u00e9finissant une taille minimal et maximal.<\/p>\n\n\n\n <\/p>\n\n\n\n Reprenons notre exemple du supermarch\u00e9:<\/p>\n\n\n\n En heure de pointe, il est toujours possible d’ouvrir des caisses pour traiter d’avantage de paiement, mais le magasin poss\u00e8de une surface finie!<\/em><\/p>\n\n\n\n Un pool est limit\u00e9 par sa taille et son hardware, sa scalabilit\u00e9 n’est pas infini!<\/p>\n\n\n\n Un pool de thread est un goulot d’\u00e9tranglement, il peut aussi \u00eatre vue comme un outils de Back-Pressure. Le dimensionnement d’un pool est un \u00e9l\u00e9ment critique de votre application et doit porter toute votre attention! Une \u00e9tude de la production est essentiel en tenant compte des pics de charge journaliers ainsi que des tests de charges. N’oubliez pas que la production reste malgr\u00e9 tout difficile \u00e0 pr\u00e9dire. <\/p>\n\n\n\n Chaque thread poss\u00e8de sa propre pile d\u2019ex\u00e9cution, multiplier les threads impacte la taille de la m\u00e9moire disponible pour les traitements m\u00e9tiers.<\/p>\n\n\n\n Avoir plusieurs threads implique de prendre en compte des probl\u00e9matiques de concurrence comme les locks qui bloquent les traitements de la Jvm etc.<\/p>\n\n\n <\/p>\n\n\n\n Nous le savons en informatique les threads sont ex\u00e9cut\u00e9s par le CPU et cela dans la limites des c\u0153urs disponibles. Au del\u00e0, la machine \u00e9mulera la parall\u00e9lisation en ex\u00e9cutant alternativement ses processus et effectuera ce que l’on appelle des switchs de context.<\/p>\n\n\n\n C’est le nom donn\u00e9 \u00e0 l’action du processeur lorsqu’il passe du traitement d’un thread \u00e0 un autre. <\/p>\n\n\n\n Pour cela le CPU \u00e0 besoin:<\/p>\n\n\n\n Cette op\u00e9ration n’est pas gratuite et ce n’est pas une op\u00e9rations que l’on souhaite invoquer outre mesure !<\/p>\n\n\n\n La commande pidstat permet d’observer les commutations de contextes:<\/p>\n\n\n\n <\/p>\n\n\n\n La r\u00e9ponse est oui et ce n’est pas une nouveaut\u00e9 ! Les applications avec interface graphique comme AWT\/Swing et plus r\u00e9cemment NodeJs connaissent bien ces probl\u00e9matiques. <\/p>\n\n\n\n Ce pattern permet de traiter des \u00e9v\u00e9nements les un \u00e0 la suite des autres. Il s’agit d’une variante du pattern Observateur mais traitant des \u00e9v\u00e8nements de plusieurs sources. On le nomme autrement boucle de d\u00e9multiplexage.<\/p>\n\n\n\n Pour mieux comprendre je vous propose de lire l’impl\u00e9mentation de Julien Ponges tir\u00e9 du livre Vert.x in Action.<\/p>\n\n\n\n Output:<\/p>\n\n\n\n <\/p>\n\n\n\n Les taches sont trait\u00e9es les une apr\u00e8s les autres de mani\u00e8re s\u00e9quentielle. Ce n’est pas un pattern sans failles ! Les traitements longs ne doivent pas \u00eatre ex\u00e9cut\u00e9s au sein de la boucle, cela reviendrait \u00e0 bloquer tous les autres traitements! <\/p>\n\n\n\n Soyons honn\u00eate je ne connais pas un seul programme ne poss\u00e9dant pas de longues taches bloquantes. L’id\u00e9e est de les d\u00e9composer en taches courtes, mais cela n’est pas toujours possible! Les exemples ne manquent pas, les appels \u00e0 une base de donn\u00e9es, un appel \u00e0 une API Rest tiers etc etc. Vert.x en grand seigneur laisse la possibilit\u00e9 d’utiliser des pools de threads plus conventionnels permettant d’ex\u00e9cuter ces longs traitements. Ils sont appel\u00e9s les Workers.<\/p>\n\n\n <\/p>\n\n\n\n Vert.x repose sur une variante de ce m\u00e9canisme, le pattern Multi-Reactor.<\/p><\/blockquote><\/figure>\n\n\n\n Vert.x am\u00e9liore l’usage de ce pattern en multipliant le nombre d’events loop. Chacune d’entre elles sont associ\u00e9es \u00e0 un c\u0153ur, permettant ainsi de r\u00e9soudre la probl\u00e9matique de commutation de contexte. Son nombre peut varier et est en cons\u00e9quence limit\u00e9 par l’architecture du processeur.<\/p>\n\n\n\n Pour y voir plus clair essayons de calculer le nombre maximum d’event loop pour ma machine:<\/p>\n\n\n\n <\/p>\n\n\n\n Vert.x applique la r\u00eagle suivante:<\/p>\n\n\n\n Nombre de processeurs * 2 <\/p>\n<\/blockquote>\n\n\n\n ce qui donne dans mon cas: 16 * 2 = 32<\/p>\n\n\n\n C’est cod\u00e9 en une ligne ici<\/a><\/p>\n\n\n\n <\/p>\n\n\n\n A noter que Vert.x est en quelque sorte, une sur-couche au c\u00e9l\u00e8bre framework Netty et facilite son usage.<\/p>\n\n\n\n <\/p>\n\n\n <\/p>\n\n\n\n Dans ce programme je cr\u00e9e un serveur Http qui nous dit bonjour. Ce code \u00e9tend un objet central de Vert.x, les Verticles.<\/p>\n\n\n\n <\/p>\n\n\n\n Ce model <\/a>a \u00e9t\u00e9 con\u00e7u pour faciliter la conception d’application ayant de fortes contraintes concurrentielles.<\/p>\n\n\n\n Au m\u00eame titre que la programmation objet consid\u00e8re que tout est objet, le model Acteur consid\u00e8re que tout est acteur.<\/p>\n\n\n\n Un acteur est une entit\u00e9 capable de calculer et qui en r\u00e9ponse d’un message, peut:<\/p>\n\n\n\n En r\u00e9sum\u00e9 un Verticle est un acteur:<\/p>\n\n\n\n En appart\u00e9, il est extr\u00eamement simple de multiplier les instances d’un Verticle.<\/p>\n\n\n\n <\/p>\n\n\n\n La communication entre les Verticles s’effectue via un bus d’\u00e9v\u00e9nement partag\u00e9 \u00e0 l’ensemble des Verticles on y acc\u00e8de de la mani\u00e8re suivante:<\/p>\n\n\n\n Le message est envoy\u00e9 \u00e0 une instance cliente en suivant une strat\u00e9gie de round robin.<\/p>\n\n\n\n Le message est envoy\u00e9 \u00e0 l’ensemble des clients en \u00e9coute.<\/p>\n\n\n\n <\/p>\n\n\n\n Vous le trouverez partout et pour cause, il s’agit de d\u00e9finir un petit traitement qui sera ensuite envoy\u00e9 dans l’event loop. Prenons l’exemple d’un traitement qui parse un long flux d’objet Json.<\/p>\n\n\n\n En regardant de plus pr\u00eat l’activit\u00e9 de la JVM d’une application au paradigme Imp\u00e9ratif, vous remarquerez que votre application passe beaucoup de temps \u00e0 attendre. C’est un gaspillage de ressource ! A contrario Vert.x utilise massivement l\u2019asynchrone.<\/p>\n\n\n\n <\/p>\n\n\n\n Voici quelques op\u00e9rateur de l’objet Future:<\/p>\n\n\n\n <\/p>\n\n\n\n Vert.x dispose de sa propre impl\u00e9mentation des Futures, sachez qu’elle est enti\u00e8rement compatible avec l’API CompletionStage fournit par le JDK et qu’il est possible d’utiliser RxJava.<\/p>\n\n\n <\/p>\n\n\n\n RxJava est une impl\u00e9mentation Java de l’initiative ReactiveX<\/a> qui propose de standardiser les API r\u00e9actives quelque soit le langage.<\/p>\n\n\n\n <\/p>\n\n\n\n Son application r\u00e9pond \u00e0 l’ensemble des crit\u00e8res du Manifest Reactif<\/a>:<\/p>\n\n\n De par sa conception avec le model Acteur, un traitement est isol\u00e9 au sein de son Verticle, en revanche son cot\u00e9 asynchrone rend les choses l\u00e9g\u00e8rement plus compliqu\u00e9. Pour palier ce probl\u00e8me Vert.x nous fournit plusieurs outils.<\/p>\n\n\n\n Dans l’exemple ci-dessous, nous souhaitons v\u00e9rifier que notre serveur http est correctement lanc\u00e9.<\/p>\n\n\n\n <\/p>\n\n\n\n Vert.x vous laisse l’usage de votre librairie d’assertion pr\u00e9f\u00e9r\u00e9, il suffira d’encapsuler votre v\u00e9rification dans l’une des m\u00e9thodes suivantes verify, succeeding ou failing du VertxTestContext.<\/p>\n\n\n\n <\/p>\n\n\n\n Ce m\u00e9canisme permet de v\u00e9rifier les traitements multiples en d\u00e9finissant un nombre de d\u00e9clenchement \u00e0 atteindre.<\/p>\n\n\n\n Pour ceux qui me suivent, vous connaisez ma passion pour l’aquariophilie. Il s’agira cette fois d’une simple application r\u00e9pertoriant les poissons que j’ai pu acheter. Il s’agit d’une application toute simple exposant des op\u00e9rations de type CRUD via une API Rest. <\/p>\n\n\n\n Faisons ensemble un tour de quelques fonctionnalit\u00e9s que j’ai pu utiliser.<\/p>\n\n\n\n <\/p>\n\n\n\n <\/p>\n\n\n\n <\/p>\n\n\n\n Le contrat de mon API est d\u00e9clar\u00e9e dans un fichier yaml.<\/p>\n\n\n\n <\/p>\n\n\n\n Cot\u00e9 Java l’application source ce fichier de la fa\u00e7on suivante:<\/p>\n\n\n\n Et je route mes contextes vers mes op\u00e9rations en base de donn\u00e9es.<\/p>\n\n\n\n En plus de pouvoir y brancher un Swagger, utiliser OpenAPI facilite la validation des param\u00e8tres et l’int\u00e9gration d’un syst\u00e8me d’authentification.<\/p>\n\n\n\n <\/p>\n\n\n\n Pour d\u00e9finir un HealthCheck digne de ce nom, il faut qu’il soit en mesure de v\u00e9rifier que la base de donn\u00e9es est disponible. Pour cela l’API de Health monitoring de Vert.x permet de facilement ajouter autant de contr\u00f4les que vous le souhaitez.<\/p>\n\n\n\n <\/p>\n\n\n\n Le r\u00e9sultat est consultable sur la route que vous avez d\u00e9finit et retourne un Json. <\/p>\n\n\n\n Elle est compos\u00e9e de deux parties:<\/p>\n\n\n\n L’API de Health est enti\u00e8rement compatible avec les normes du Cloud. Dans mon cas je me suis content\u00e9 d’impl\u00e9menter un seul HealthCheck mais rien ne vous emp\u00e8che d’impl\u00e9menter un contexte pour le Live et Ready ness.<\/p>\n\n\n\n <\/p>\n\n\n\n Pour information Vert.x utilise deux objects pour se lancer, un Launcher et un Verticle. Par d\u00e9faut vous n’avez rien \u00e0 faire, pour la mise en place de Micrometer nous avons besoin de les impl\u00e9menter.<\/p>\n\n\n\n <\/p>\n\n\n\n Ici je d\u00e9cide d’utiliser Micrometer (plusieurs impl\u00e9mentations sont disponibles). Sa mise en place s’effectue \u00e0 l’exterieur d’un Verticle. <\/p>\n\n\n\n <\/p>\n\n\n\n Et voila un flux tout beau tout propre pr\u00eat \u00e0 \u00eatre exploit\u00e9 par Prometheus !<\/p>\n\n\n\n <\/p>\n\n\n\n En bonus un petit service qui fait toujours plaisirs, une CLI pour interagir votre application!<\/p>\n\n\n\n <\/p>\n\n\n <\/p>\n\n\n\n Je vous invite a consulter l’int\u00e9gralit\u00e9 du code sur GitLab, vous y trouverez la partie persistance, l’utilisation de Service proxy, la gestion des confs le Hot Reload etc etc.<\/p>\n\n\n\n <\/p>\n\n\n Code source<\/em><\/p>\n\n\n\n C’est un framework tr\u00e8s bas niveau compliqu\u00e9 \u00e0 utiliser ?<\/strong><\/p>\n\n\n\n Non, ces concepts sont diff\u00e9rents de ceux utilis\u00e9s dans le monde du backend Java standard, mais son API est particuli\u00e8rement riche et agr\u00e9able \u00e0 utiliser. Un d\u00e9veloppeur Front-End ne serait absolument pas d\u00e9pays\u00e9. Vous trouverez \u00e9norm\u00e9ment de documentation sur le net.<\/p>\n\n\n\n Est-il possible d’utiliser Spring et Vert.x en meme temps ?<\/strong><\/p>\n\n\n\n Oui n’oubliez pas qu’il s’agit d’une boite \u00e0 outils et non d’un framework, vous trouverez facilement des tutoriaux <\/a>sur le net.<\/p>\n\n\n\n Est il possible d’utiliser un Spring Config Server Store ?<\/strong><\/p>\n\n\n\n Oui, direction la documentation officielle<\/a>.<\/p>\n\n\n\n Pour quel genre d’application est il pertinent d’utiliser Vert.x ?<\/strong><\/p>\n\n\n\n Vert.x exc\u00e8le dans le traitement des flux volumineux. je vous invite \u00e0 consulter sa fonctionnalit\u00e9 de parsing des Streams<\/a> et son API de traitement de fichiers<\/a>.<\/p>\n\n\n\n Dois-je utiliser Vert.x si la base de donn\u00e9es de mon application est de type Sql relationnel ?<\/strong><\/p>\n\n\n\n Vous l’avez vu dans l’exemple, il est tout \u00e0 fait possible d’utiliser JDBC avec Vert.x, cependant n’oubliez pas que JDBC n’en reste pas moins une API bloquante. A noter que pour palier ce probl\u00e8me Vert.x d\u00e9ploiera un pool de type worker. <\/p>\n\n\n\n Est il possible de convertir son application Vert.x en code natif via GraalVM?<\/strong> <\/p>\n\n\n\n Oui<\/a><\/p>\n\n\n\n Je n’ai jamais entendu parler de Vert.x qui l’utilise ?<\/strong><\/p>\n\n\n\n Vert.x est tr\u00e8s largement utilis\u00e9, voici une liste non exhaustive:<\/p>\n\n\n <\/p>\n\n\n\n https:\/\/twitter.com\/timfox<\/a><\/p>\n\n\n\n https:\/\/twitter.com\/clementplop<\/a><\/p>\n\n\n\n https:\/\/twitter.com\/jponge<\/a><\/p>\n\n\n\n https:\/\/twitter.com\/tsegismont<\/a><\/p>\n\n\n\n https:\/\/twitter.com\/vertx_project<\/a><\/p>\n\n\n\n https:\/\/vertx.io\/<\/a><\/p>\n\n\n\n https:\/\/start.vertx.io\/<\/a><\/p>\n\n\n\n https:\/\/www.reactivemanifesto.org\/fr<\/a><\/p>\n\n\n\n http:\/\/reactivex.io\/<\/a><\/p>\n\n\n\n https:\/\/www.manning.com\/books\/vertx-in-action<\/a><\/p>\n\n\n\n https:\/\/fr.wikipedia.org\/wiki\/Mod%C3%A8le_d%27acteur<\/a><\/p>\n\n\n\n https:\/\/access.redhat.com\/documentation\/en-us\/red_hat_enterprise_linux_atomic_host\/7\/html\/managing_containers\/finding_running_and_building_containers_with_podman_skopeo_and_buildah<\/a><\/p>\n\n\n\n https:\/\/www.youtube.com\/watch?v=8aGhZQkoFbQ&ab_channel=JSConf<\/a><\/p>\n\n\n\n https:\/\/www.youtube.com\/watch?v=3_CRKfs4Zzo&ab_channel=OracleDevelopers<\/a><\/p>\n\n\n\n https:\/\/github.com\/burrsutter\/vertx_ha_demo<\/a><\/p>\n\n\n\n https:\/\/github.com\/vert-x3\/vertx-examples<\/a><\/p>\n\n\n\nThreadPoolExecutor executorPool = new ThreadPoolExecutor(5, 10; 3, TimeUnit.SECONDS, new ArrayBlockingQueue(50));<\/code><\/pre>\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/executor_service.png\")
<\/figure>\n<\/div>\n\n\nLes limites<\/h3>\n\n\n\n
Sa taille:<\/h4>\n\n\n\n
Son empreinte m\u00e9moire:<\/h4>\n\n\n\n
La concurrence:<\/h4>\n\n\n\n
![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/multi-threading.png\")
<\/figure>\n<\/div>\n\n\nMais que se passe t’il sous le capot?<\/h5>\n\n\n\n
Le switch de context:<\/h6>\n\n\n\n
\n
[baptiste@localhost ~]$ pidstat -w -d -t -p 3583 -h\n Linux 5.9.16-200.fc33.x86_64 (localhost.localdomain) 28\/12\/2020 x86_64<\/em> (16 CPU)\n Time UID TGID TID kB_rd\/s kB_wr\/s kB_ccwr\/s iodelay cswch\/s nvcswch\/s Command\n03:14:46 1000 - 3714 0,00 0,00 0,00 0 2,76 0,01 |__default I\/O-1\n03:14:46 1000 - 3715 0,00 0,00 0,00 0 2,76 0,02 |__default I\/O-2\n03:14:46 1000 - 3716 0,00 0,00 0,00 0 2,72 0,02 |__default I\/O-3\n03:14:46 1000 - 3717 0,00 0,00 0,00 0 2,76 0,02 |__default I\/O-4\n03:14:46 1000 - 3718 0,00 0,00 0,00 0 2,83 0,01 |__default I\/O-5\n03:14:46 1000 - 3719 0,00 0,00 0,00 0 6,34 0,46 |__default <\/code><\/pre>\n\n\n\ncswch\/s\nNombre total de commutation de contexte volontaire effectu\u00e9 par seconde. Une commutation de contexte volontaire est r\u00e9alis\u00e9e quand un traitement ne parvient pas \u00e0 acc\u00e9der \u00e0 une ressource.<\/pre>\n\n\n\n
nvcswch\/s\nNombre total de commutation de contexte involontaire effectu\u00e9 par seconde. Une commutation de contexte involontaire est r\u00e9alis\u00e9e quand une tache lors de sa fen\u00eatre d'\u00e9xecution est forc\u00e9e de renoncer \u00e0 son traitement.<\/pre>\n\n\n\n
\n\n\n\nExiste-t-il une architecture qui permet d’\u00e9viter ces probl\u00e8mes ?<\/h2>\n\n\n\n
Le design pattern Reactor:<\/h3>\n\n\n
![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/event-loop.png\")
<\/figure>\n<\/div>\n\n\nimport java.util.concurrent.ConcurrentHashMap;\nimport java.util.concurrent.ConcurrentLinkedDeque;\nimport java.util.function.Consumer;\n\npublic final class EventLoop {\n\n public static final class Event {\n private final String key;\n private final Object data;\n\n public Event(String key, Object data) {\n this.key = key;\n this.data = data;\n }\n }\n\n private final ConcurrentLinkedDeque<Event> events = new ConcurrentLinkedDeque<>();\n private final ConcurrentHashMap<String, Consumer<Object>> handlers = new ConcurrentHashMap<>();\n\n public EventLoop on(String key, Consumer<Object> handler) {\n handlers.put(key, handler);\n return this;\n }\n\n public void dispatch(Event event) {\n events.add(event);\n }\n\n public void run() {\n while (!(events.isEmpty() && Thread.interrupted<\/em>())) {\n if (!events.isEmpty()) {\n Event event = events.pop();\n if (handlers.containsKey(event.key)) {\n handlers.get(event.key).accept(event.data);\n } else {\n System.err<\/em>.println(\"No handler for key \" + event.key);\n }\n }\n }\n }\n\n public void stop() {\n Thread.currentThread<\/em>().interrupt();\n }\n\n public static void main(String[] args) {\n EventLoop eventLoop = new EventLoop();\n\n new Thread(() -> {\n for (int n = 0; n < 6; n++) {\n delay<\/em>(1000);\n eventLoop.dispatch(new EventLoop.Event(\"tick\", n));\n }\n eventLoop.dispatch(new EventLoop.Event(\"stop\", null));\n }).start();\n\n new Thread(() -> {\n delay<\/em>(2500);\n eventLoop.dispatch(new EventLoop.Event(\"hello\", \"beautiful world\"));\n delay<\/em>(800);\n eventLoop.dispatch(new EventLoop.Event(\"hello\", \"beautiful universe\"));\n }).start();\n\n eventLoop.dispatch(new EventLoop.Event(\"hello\", \"world!\"));\n eventLoop.dispatch(new EventLoop.Event(\"foo\", \"bar\"));\n\n eventLoop\n .on(\"hello\", s -> System.out<\/em>.println(\"hello \" + s))\n .on(\"tick\", n -> System.out<\/em>.println(\"tick #\" + n))\n .on(\"stop\", v -> eventLoop.stop())\n .run();\n\n System.out<\/em>.println(\"Bye!\");\n }\n\n private static void delay(long millis) {\n try {\n Thread.sleep<\/em>(millis);\n } catch (InterruptedException e) {\n throw new RuntimeException(e);\n }\n }\n}\n<\/code><\/pre>\n\n\n\nhello world!\n tick #0\n No handler for key foo\n tick #1\n hello beautiful world\n tick #2\n hello beautiful universe\n tick #3\n tick #4\n tick #5\n Bye!<\/code><\/pre>\n\n\n\n![\"\"](\"https:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/event-loop_bloking.png\")
<\/figure>\n<\/figure>\n\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/01\/vertx-threads.png\")
<\/figure>\n<\/div>\n\n\n[baptiste@localhost bin]$ lscpu\n Architecture : x86_64\n Processeur(s) : 16\n Liste de processeur(s) en ligne : 0-15\n Thread(s) par c\u0153ur : 2\n C\u0153ur(s) par socket : 8\n Socket(s) : 1\n N\u0153ud(s) NUMA : 1<\/code><\/pre>\n\n\n\n\n
mvn dependency:tree\n...\n[INFO] +- io.vertx:vertx-service-proxy:jar:4.0.2:compile\n[INFO] | \\- io.vertx:vertx-core:jar:4.0.2:compile\n[INFO] | +- io.netty:netty-common:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-buffer:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-transport:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-handler:jar:4.1.52.Final:compile\n[INFO] | | \\- io.netty:netty-codec:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-handler-proxy:jar:4.1.52.Final:compile\n[INFO] | | \\- io.netty:netty-codec-socks:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-codec-http:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-codec-http2:jar:4.1.52.Final:compile\n[INFO] | +- io.netty:netty-resolver:jar:4.1.52.Final:compile\n[INFO] | \\- io.netty:netty-resolver-dns:jar:4.1.52.Final:compile\n[INFO] | \\- io.netty:netty-codec-dns:jar:4.1.52.Final:compile<\/code><\/pre>\n\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/netty_icon_64px.svg\"){kind=icon}
<\/figure>\n<\/div>\n\n\n
\n\n\n\nCommen\u00e7ons par cr\u00e9er notre premier programme<\/h2>\n\n\n\n
import io.vertx.core.AbstractVerticle;\nimport io.vertx.core.DeploymentOptions;\nimport io.vertx.core.Promise;\nimport io.vertx.core.Vertx;\n\npublic class MainVerticle extends AbstractVerticle {\n @Override\n public void start(Promise<Void> startPromise) throws Exception {\n vertx.createHttpServer().requestHandler(req -> {\n req.response()\n .putHeader(\"content-type\", \"text\/plain\")\n .end(\"Hello from Vert.x!\");\n }).listen(8888, http -> {\n if (http.succeeded()) {\n startPromise.complete();\n System.out<\/em>.println(\"HTTP server started on port 8888\");\n } else {\n startPromise.fail(http.cause());\n }\n });\n }\n}<\/code><\/pre>\n\n\n\nVert.x repose sur le pattern Actor Model.<\/h3>\n\n\n\n
\n
\n
Vertx.vertx().deployVerticle(FishDatabaseVerticle.class.getName(), new DeploymentOptions().setInstances(5));<\/code><\/pre>\n\n\n\nComment envoyer un message ?<\/h3>\n\n\n\n
EventBus eb = vertx.eventBus();<\/code><\/pre>\n\n\n\nIl est possible d’effectuer une communication de type point \u00e0 point:<\/h4>\n\n\n\n
eventBus.send(\"fish.purchase\", \"Discus\");<\/code><\/pre>\n\n\n\nDe type Broadcast:<\/h4>\n\n\n\n
eventBus.publish(\"fish.sell\", \"Hi everyone, the Discus fish was sold\");<\/code><\/pre>\n\n\n\nPoint \u00e0 point avec r\u00e9ponse:<\/h4>\n\n\n\n
eventBus.request(\"fish.purchase\", \"Scalare\", ar -> {\n if (ar.succeeded()) {\n System.out.println(ar.result().body());\n }\n });<\/code><\/pre>\n\n\n\nMessageConsumer<String> consumer = eventBus.consumer(\"fish.purchase\"); <\/code>\nconsumer.handler(message -> { <\/code>\nSystem.out.println(\"I have received a purchase: \" + message.body()); <\/code>\n message.reply(\"The price of the fish is \" + priceMapping.get(message.body())); <\/code>\n});<\/code><\/code><\/pre>\n\n\n\n
\n\n\n\nLes Handlers<\/h2>\n\n\n\n
JsonParser.newParser<\/em>(asyncFishFile).objectValueMode()\n.handler(event -> {\n if (Objects.nonNull<\/em>(event.value())) {\n Fish fish = event.mapTo(Fish.class);\n System.out<\/em>.println(\"Fish = \" + fish);\n }\n })\n .exceptionHandler(t -> {\n t.printStackTrace();\n asyncFishFile.close();\n })\n.endHandler(v -> {\n System.out<\/em>.println(\"Done!\");\n asyncFishFile.close();\n });<\/code><\/pre>\n\n\n\n
\n\n\n\nVert.x est r\u00e9actif<\/h2>\n\n\n\n
Les futures<\/h3>\n\n\n\n
Map <\/strong>effectue une op\u00e9ration sur le future.<\/pre>\n\n\n\n
Recover <\/strong>est une sorte de catch, il permet de lancer un traitement en cas d'exception..<\/pre>\n\n\n\n
Eventualy<\/strong> est une sorte de finally, il est syst\u00e9matiquement appel\u00e9.<\/pre>\n\n\n\n
onSuccess, onFailure <\/strong>sont des syst\u00e8mes de notification, ils ne modifient pas le future.<\/pre>\n\n\n\n
Bien d'autres m\u00e9thodes<\/strong><\/pre>\n\n\n\n
vertx.fileSystem().props(\"fishs.json\")\n .map(FileProps::size)<\/code>\n .recover(err -> Future.succeededFuture<\/em>(0l))\n .onSuccess(size -> System.out<\/em>.println(\"File size = \" + size))\n .onFailure(res ->System.out<\/em>.println(\"Failure: \" + res.getCause().getMessage()));<\/code><\/code><\/pre>\n\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/reactivex.svg\")
<\/figure>\n<\/div>\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/reactif_manifesto-1-1024x608.png\")
<\/figure>\n<\/div>\n\n\n
\n\n\n\nComment tester ?<\/h2>\n\n\n\n
VertxTestContext:<\/h4>\n\n\n\n
@ExtendWith(VertxExtension.class) <\/code>\nclass DatabaseVerticleDeploymentTest { <\/code>\n\n Vertx vertx = Vertx.vertx(); <\/code>\n\n @Test <\/code>\n void it_should_start_database_verticle() throws Throwable { <\/code>\n VertxTestContext testContext = new VertxTestContext();\n\n vertx.deployVerticle(new FishDatabaseVerticle())\n .onSuccess(res -> testContext.completeNow()) (1)\n .onFailure(res -> System.out<\/em>.println(\"An error occur\"));\n\n assertThat<\/em>(testContext.awaitCompletion(5, TimeUnit.SECONDS<\/em>)).isTrue(); (2)\n\n if (testContext.failed()) {\n throw testContext.causeOfFailure(); (3)\n }\n } <\/code>\n}<\/code>\n (1) est l'instruction qui d\u00e9finit le succ\u00e8s de notre test.\n (2) awaitCompletion v\u00e9rifie que completeNow soit d\u00e9clench\u00e9 avant 5 secondes.\n (3) dans le cas contraire le test sera en echec. <\/code><\/pre>\n\n\n\n@Test\nvoid it_should_insert_fish(Vertx vertx, VertxTestContext testContext) {\n String fishName = \"Scalare\";\n WebClient client = WebClient.create<\/em>(vertx);\n client.post(PORT<\/em>, HOST<\/em>, APPLICATION_CONTEXT <\/em>+ \"?name=\" + fishName)\n .as(BodyCodec.string<\/em>())\n .send(testContext.succeeding(response -> testContext.verify(() -> {\n assertThat<\/em>(response.body()).isNotBlank();\n testContext.completeNow();\n })));\n}<\/code><\/code><\/pre>\n\n\n\nLes checkpoints:<\/h3>\n\n\n\n
@Test\nvoid it_should_get_existing_fish2(VertxTestContext testContext) {\n String fish1 = \"Discus\";\n String fish2 = \"Scalare\";\n Checkpoint checkpoint = testContext.checkpoint(2); (1)\n\n createFish(fish1).map(createFish(fish2)).onSuccess(nothing -> {\n dbService.existFishByName(fish1, res -> {\n if (res.succeeded()) {\n checkpoint.flag(); (2)\n }});\n dbService.existFishByName(fish2, res -> {\n if (res.succeeded()) {\n checkpoint.flag(); (3)\n }});\n });\n}<\/code>\n(1) Ici je d\u00e9clare un compteur de deux unit\u00e9s\n(2) (3) L'instruction flag va d\u00e9compter une unit\u00e9 de son compteur<\/code><\/pre>\n\n\n\n
\n\n\n\nEt si on codait une v\u00e9ritable application ?<\/h2>\n\n\n\n
Je lance mon application de la fa\u00e7on suivante:<\/h5>\n\n\n\n
[baptiste@localhost target]$ java -jar target\/vertx-fishs-1.0.0-SNAPSHOT-fat.jar<\/code><\/pre>\n\n\n\nAvec un poids de<\/h4>\n\n\n\n
[baptiste@localhost target]$ ls -alhs | grep -i snapshot \n 24M -rw-rw-r--. 1 baptiste baptiste 24M 16 f\u00e9vr. 21:23 vertx-fishs-1.0.0-SNAPSHOT-fat.jar<\/code><\/pre>\n\n\n\nEt une empreinte m\u00e9moire de<\/h4>\n\n\n\n
[baptiste@localhost target]$ jcmd 5780 GC.heap_info\n 5780:\n garbage-first heap total 516096K, used 62101K [0x000000060d200000, 0x0000000800000000)\n region size 2048K, 29 young (59392K), 4 survivors (8192K)\n Metaspace used 32591K, capacity 33798K, committed 33920K, reserved 1079296K\n class space used 3700K, capacity 4192K, committed 4224K, reserved 1048576K<\/code><\/pre>\n\n\n\n
\n\n\n\nOpenApi<\/h3>\n\n\n\n
openapi: 3.0.0\ninfo:\n version: 1.0.0\n title: Swagger Fishstore\n license:\n name: MIT\nservers:\n - url: http:\/\/localhost:8080\/v1\npaths:\n \/fishs:\n get:\n summary: List fishs\n operationId: listFishs\n tags:\n - fishs\n parameters:\n - name: name\n in: query\n description: Restrict fish detail by name\n required: false\n schema:\n type: string\n responses:\n 200:\n description: List of fishs\n content:\n application\/json:\n schema:\n $ref: \"#\/components\/schemas\/Fishs\"\n...\ncomponents:\n schemas:\n Fish:\n type: object\n required:\n - id\n - name\n properties:\n id:\n type: integer\n format: int64\n name:\n type: string\n tag:\n type: string\n Fishs:\n type: array\n items:\n $ref: \"#\/components\/schemas\/Fish\"<\/code><\/pre>\n\n\n\nRouterBuilder.create<\/em>(vertx, \"src\/main\/resources\/webroot\/fishStore.yaml\").onComplete(ar -> {\n if (ar.succeeded()) {\n Router global = this.getOpenApiRouter(ar.result());\n\n vertx.createHttpServer()\n .requestHandler(global)\n .onSuccess(res -> {});\n}<\/code><\/pre>\n\n\n\nprivate Router getOpenApiRouter(RouterBuilder routerBuilder) {\n routerBuilder\n .operation(\"listFishs\")\n .handler(this::allFishsHandler)\n .failureHandler(this::faillureHandler);\n\n routerBuilder.operation(\"createFish\")\n .handler(this::fishCreateHandler)\n .failureHandler(this::faillureHandler);\n\n...\n\n Router global = Router.router<\/em>(vertx);\n\n Router generated = routerBuilder.createRouter();\n global.mountSubRouter(\"v1\"<\/em>, generated);<\/code><\/pre>\n\n\n\n
\n\n\n\nHealthCheck<\/h3>\n\n\n\n
private HealthCheckHandler healthHandler() {\n HealthCheckHandler healthCheckHandler = HealthCheckHandler.create<\/em>(vertx);\n healthCheckHandler.register(\"check-database\", promise -> {\n dbService.isAvailable(res -> {\n promise.complete(res.succeeded() ? Status.OK<\/em>() : Status.KO<\/em>());\n });\n });\n return healthCheckHandler;\n}<\/code><\/pre>\n\n\n\n\n
{\"status\":\"UP\",\"checks\":[{\"id\":\"check-database\",\"status\":\"UP\"}],\"outcome\":\"UP\"}<\/code><\/pre>\n\n\n\n
\n\n\n\nMetrics<\/h3>\n\n\n\n
public class FishLauncher extends Launcher {\n public static void main(String[] args) {\n new FishLauncher().dispatch(args);\n }\n\n @Override\n public void beforeStartingVertx(VertxOptions options) {\n \/\/ METRICS\n options.setMetricsOptions(new MicrometerMetricsOptions()\n .setPrometheusOptions(new VertxPrometheusOptions().setEnabled(true)\n .setStartEmbeddedServer(true)\n .setEmbeddedServerOptions(new HttpServerOptions().setPort(8081))\n .setEmbeddedServerEndpoint(\"\/metrics\"))\n .setEnabled(true));\n }\n...\n}<\/code><\/pre>\n\n\n\n# HELP vertx_http_server_request_bytes Size of requests in bytes \n# TYPE vertx_http_server_request_bytes \nhistogram vertx_http_server_request_bytes_bucket{method=\"GET\",le=\"1.0\",} 3.0 \n...\nvertx_pool_usage_seconds_count{pool_type=\"worker\",} 1617.0 \nvertx_pool_usage_seconds_sum{pool_type=\"worker\",} 1.147378429 \n# HELP vertx_pool_usage_seconds_max Time using a resource \n# TYPE vertx_pool_usage_seconds_max gauge vertx_pool_usage_seconds_max{pool_type=\"datasource\",} 0.0 vertx_pool_usage_seconds_max{pool_type=\"worker\",} 0.001223763 \n# HELP vertx_eventbus_delivered_total Number of messages delivered to handlers \n# TYPE vertx_eventbus_delivered_total counter \nvertx_eventbus_delivered_total{side=\"local\",} 2.0 \n# HELP vertx_eventbus_processed_total Number of processed messages \n# TYPE vertx_eventbus_processed_total counter \nvertx_eventbus_processed_total{side=\"local\",} 2.0 \n# HELP vertx_pool_completed_total Number of elements done with the resource \n# TYPE vertx_pool_completed_total counter \nvertx_pool_completed_total{pool_type=\"datasource\",} 2.0 \nvertx_pool_completed_total{pool_type=\"worker\",} 1617.0<\/code><\/pre>\n\n\n\n
\n\n\n\nVert.x Shell<\/h3>\n\n\n\n
ShellService service = ShellService.create<\/em>(vertx,\n new ShellServiceOptions().setTelnetOptions(\n new TelnetTermOptions().\n setHost(\"localhost\").\n setPort(4000)\n )\n);\nservice.start();<\/code><\/pre>\n\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/image-1024x354.png\")
<\/figure>\n<\/div>\n\n\n![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2020\/11\/gitlab.png\")
<\/a><\/figure>\n<\/div>\n\n\n
\n\n\n\nConclusion<\/h1>\n\n\n
![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/conclusion-2-1024x490.png\")
<\/figure>\n<\/div>\n\n\n
\n\n\n\nLes questions que tu te poses <\/h2>\n\n\n\n
![\"\"](\"http:\/\/baptiste-meynier.com\/wp-content\/uploads\/2021\/02\/banderole_companies.png\")
<\/figure>\n<\/div>\n\n\n
\n\n\n\nTwitter<\/h2>\n\n\n\n
\n\n\n\nSources<\/h2>\n\n\n\n