Les différents reactors étendus

Introduction

Reactor est une bibliothèque de programmation réactive qui offre une approche fondée sur les flux pour la programmation asynchrone. Elle est utilisée pour créer des applications réactives en Java. Voici des précisions sur les différents projets Reactor.

Reactor Netty

Nous avons vu qu’il est possible de faire de la programmation avec Netty, mais que cela est fastidieux et qu’il y a beaucoup de code boilerplate.

Programmation Netty avec Spring

Reactor Netty est un framework qui permet de développer des applications réseau asynchrones fondées sur des événements. Il offre des fonctionnalités de client et de serveur pour les protocoles TCP, HTTP et UDP, qui sont non bloquants et prennent en charge la contre-pression. Ce framework est construit sur la base solide du framework Netty.

Reactor Netty est le serveur par défaut utilisé par Spring WebFlux. Lorsque vous créez une application WebFlux avec Spring, le serveur Reactor Netty est automatiquement configuré pour gérer les requêtes et les réponses asynchrones grâce à la programmation réactive. Vous pouvez également configurer d’autres serveurs si vous le souhaitez. Néanmoins, Reactor Netty étant l’option par défaut, elle est recommandée pour profiter pleinement des avantages de la réactivité dans Spring WebFlux.

Nous pouvons utiliser la librairie Spring Reactor Netty pour faire de la programmation réseau dans un style fonctionnel, comme ce que nous faisions précédemment avec un moteur tel que Vert.x, avant la mise à disposition de Spring Reactor Netty.

Protocole TCP

Reactor peut être utilisé pour concevoir une application TCP pour :

Reactor Netty fournit un outil facile à utiliser et à configurer. Il s’agit de la classe TcpServer qui masque la plupart des fonctionnalités Netty nécessaires à la création d’un serveur TCP tout en ajoutant une contre-pression Reactive Streams.

Nous allons commencer par un couple client/serveur qui nous servira à expliquer le comportement et les variantes possibles plus en détail par la suite. Nous allons utiliser reactor-netty dans le cadre d’une application Spring-boot.

Le lanceur :

@SpringBootApplication 
public class ReactorNettyServerApplication implements CommandLineRunner { 
 
  public static void main(String[] args) { 
    SpringApplication.run(ReactorNettyServerApplication.class, args); 
  } 
 
  @Override 
  public void run(String... args) throws Exception { 
  } 
} 

Le serveur :

@Slf4j 
@Component 
public class ServerSimple { 
 
  // Injection de la valeur pour le port du serveur depuis application.properties 
  @Value("${server.port}") ...

Serveur HTTP

En général, l’utilisation du serveur HTTP de Spring Reactor Netty est limitée car nous avons déjà WebFlux pour cela. Le serveur HTTP de Spring Reactor Netty est généralement réservé à des cas spécifiques, tels que ceux proches de Vert.x ou dans des scénarios avec des ports multiples pour des besoins de simulation (comme des mocks).

L’un des avantages de l’utilisation de Spring Reactor Netty pour un serveur HTTP est la possibilité de gérer la contre-pression. Cela permet de mieux contrôler le flux de données entre le serveur et les clients, évitant ainsi des problèmes de surcharge ou de congestion.

Cependant, il est important de noter que Spring a créé un projet spécialement dédié pour répondre à ce besoin : Spring WebFlux. Spring WebFlux est la version réactive du Spring MVC traditionnel et offre une solution complète pour gérer les applications réactives et les serveurs HTTP.

Dans la plupart des cas, il est recommandé d’utiliser Spring WebFlux plutôt que le serveur HTTP de Spring Reactor Netty, car cela permet de bénéficier de toutes les fonctionnalités et des avantages d’une approche réactive complète.

L’utilisation du serveur HTTP de Spring Reactor Netty sera...

Serveur UDP

Reactor Netty offre également la possibilité de créer des serveurs UDP. Le serveur UDP est très similaire au serveur TCP en termes d’implémentation et de configuration. Cependant, il existe des différences fondamentales entre les protocoles UDP (User Datagram Protocol) et TCP (Transmission Control Protocol).

UDP est un protocole de communication réseau qui permet d’envoyer des datagrammes de manière non fiable et sans connexion. Contrairement à TCP, qui garantit la livraison des paquets dans l’ordre et gère les retransmissions en cas de perte, UDP ne fournit pas de mécanismes de garantie de livraison ou de retransmission.

La légèreté et la rapidité d’UDP en font un choix attractif pour certaines applications où la perte de quelques paquets n’est pas critique, comme les applications multimédias en streaming ou les jeux en ligne. Cependant, cette rapidité et cette légèreté peuvent entraîner une perte de données en cas de congestion ou de perturbations sur le réseau.

Bien que le serveur UDP de Reactor Netty offre une alternative légère et rapide pour certaines applications spécifiques, il est important de prendre en compte les limitations d’UDP en termes de fiabilité de la livraison des paquets et d’ordre des messages.

Voici cinq cas d’utilisation courants d’un serveur UDP avec Spring Reactor Netty :

Conclusion sur Reactor Netty

En conclusion, Reactor Netty est une puissante bibliothèque qui offre une approche réactive pour construire des serveurs et des clients réseau hautement performants. Grâce à son architecture fondée sur le modèle de programmation réactive, Reactor Netty permet de gérer efficacement de nombreux clients simultanés tout en maintenant une utilisation optimale des ressources.

Les fonctionnalités offertes par Reactor Netty, telles que la gestion des connexions asynchrones, la prise en charge de protocoles réseau variés (TCP, UDP), la personnalisation fine des paramètres réseau et la compatibilité avec les outils de monitoring tels que Micrometer, en font un choix idéal pour les applications exigeantes en termes de performance et de scalabilité.

L’utilisation de Reactor Netty est particulièrement pertinente dans le contexte de la programmation réactive, où la gestion des flux de données est primordiale. Son intégration transparente avec le framework Spring permet également de tirer pleinement parti des capacités réactives de l’écosystème Spring.

Cependant, il est important de noter que Reactor Netty peut être plus complexe à utiliser que certaines alternatives pour des cas d’utilisation plus simples. Par conséquent...

Reactor Rabbit MQ

RabbitMQ est un système de messagerie open source, fondé sur le protocole AMQP (Advanced Message Queuing Protocol), qui facilite l’échange de messages asynchrones et fiables entre différentes applications ou composants d’un système distribué. Il utilise des files d’attente pour permettre aux producteurs d’envoyer des messages et aux consommateurs de les récupérer et de les traiter. RabbitMQ garantit la livraison sécurisée des messages et offre des fonctionnalités telles que la persistance des messages, un routage flexible, des modèles de messagerie avancés, une extensibilité via des plugins, une haute performance, et des mécanismes de gestion des files d’attente. Il est largement utilisé dans les architectures distribuées pour la communication entre les services, la gestion des files d’attente de tâches, la mise en œuvre de workflows, etc., offrant ainsi une solution fiable et scalable pour les systèmes nécessitant une communication asynchrone et la garantie de livraison des messages.

docker run -it --rm --name mon_rabbitmq -p 5672:5672 -p  
15672:15672 rabbitmq:3.12-management 

Reactor Kafka