Reactive Programming
Dernière mise à jour
Dernière mise à jour
L'idée du Reactive Programming est d'adopter au maximum une approche déclarative plutôt qu'impérative.
Le Reactive Programming permet de réduire le couplage entre les actions, les données, les traitements et le résultat des traitements. Cela améliore également la résilience et la "scalability" de l'architecture.
Le succès de cette approche est fortement lié à l'émergence des Microservices, des technologies telles que Kafka Streams, en frontend à des frameworks tels qu'Angular et à des plateformes de streaming telles que Netflix.
Les ordres de virement bancaire sont stockées dans une base de données.
Un "batch" est lancé chaque soir pour déclencher les virements.
Un "batch" est lancé quelques heures plus tard pour notifier les utilisateurs en fonction des résultats stockés par le "batch" précédent.
L'utilisateur s'inscrit aux notifications de virements.
Le système de notification est donc inscrit au flux de résultats de traitement de virements.
Le flux de résultats de traitement est produit par l'inscription au flux d'ordres de virements.
Le flux d'ordres de virements est alimenté par différentes sources.
L'implémentation la plus commune des Observables est ReactiveX et elle est disponible dans différents langages : RxJS, RxPython, RxJava, Rx.NET etc...
