Event Bus et le pattern Observer en JavaScript (Node.js) : implémentation et exemples

Event Bus et le pattern Observer en JavaScript (Node.js)

Dans le développement moderne avec Node.js, il est souvent nécessaire d'organiser une interaction faiblement couplée entre les composants d'une application. Pour résoudre ce problème, le pattern Observer (Observateur) et son implémentation pratique — Event Bus (Bus d'événements) — sont parfaitement adaptés. Dans cet article, nous allons détailler ce qu'est un Event Bus, comment il est lié au pattern Observer, et créer notre propre implémentation en JavaScript pur pour Node.js.

Qu'est-ce que le pattern Observer ?

Le pattern Observer définit une relation "un à plusieurs" entre les objets. Lorsqu'un objet (sujet ou éditeur) modifie son état, tous les objets qui en dépendent (observateurs ou abonnés) en sont automatiquement notifiés. Dans Node.js, ce pattern est intégré au noyau via la classe EventEmitter.

Composants principaux du pattern :

\n
• Subject (Sujet) — l'objet qui génère les événements.
\n
• Observer (Observateur) — l'objet qui s'abonne aux événements.
\n
• Subscription (Abonnement) — le mécanisme d'enregistrement de l'observateur auprès du sujet.
\n

Qu'est-ce qu'un Event Bus ?

Un Event Bus est un intermédiaire centralisé qui implémente le pattern Observer. Au lieu que chaque composant s'abonne directement à un autre composant, tous communiquent via un bus d'événements unique. Cela offre les avantages suivants :

\n
• Faible couplage des composants.
\n
• Simplicité d'ajout de nouveaux abonnés sans modifier le code de l'éditeur.
\n
• Possibilité de gestion centralisée des événements (journalisation, filtrage, débogage).
\n

EventEmitter intégré dans Node.js

Node.js fournit le module intégré events, qui contient la classe EventEmitter. C'est une implémentation prête à l'emploi d'Event Bus. Examinons un exemple de base :

const EventEmitter = require('events');\nconst eventBus = new EventEmitter();\n\n// Abonnement à l'événement 'user:login'\neventBus.on('user:login', (user) => {\n    console.log(`Utilisateur ${user.name} connecté`);\n});\n\n// Abonnement avec un autre gestionnaire\neventBus.on('user:login', (user) => {\n    console.log(`Envoi d'un e-mail de bienvenue à ${user.email}`);\n});\n\n// Déclenchement de l'événement\neventBus.emit('user:login', { name: 'Ivan', email: 'ivan@example.com' });\n// Sortie :\n// Utilisateur Ivan connecté\n// Envoi d'un e-mail de bienvenue à ivan@example.com

Création de votre propre Event Bus

Parfois, l'EventEmitter intégré ne suffit pas — par exemple, si vous devez ajouter la prise en charge de gestionnaires asynchrones, de priorités ou d'une typage strict. Créons notre propre implémentation d'Event Bus à partir de zéro :

class EventBus {\n    constructor() {\n        this.events = {};\n    }\n\n    // Abonnement à un événement\n    on(eventName, callback) {\n        if (!this.events[eventName]) {\n            this.events[eventName] = [];\n        }\n        this.events[eventName].push(callback);\n        \n        // Retourne une fonction pour se désabonner\n        return () => {\n            this.events[eventName] = this.events[eventName]\n                .filter(cb => cb !== callback);\n        };\n    }\n\n    // Abonnement à un événement unique\n    once(eventName, callback) {\n        const wrapper = (...args) => {\n            callback(...args);\n            this.off(eventName, wrapper);\n        };\n        this.on(eventName, wrapper);\n    }\n\n    // Déclenchement d'un événement\n    emit(eventName, ...args) {\n        const callbacks = this.events[eventName];\n        if (!callbacks) return false;\n        \n        callbacks.forEach(callback => {\n            try {\n                callback(...args);\n            } catch (error) {\n                console.error(`Erreur dans le gestionnaire de l'événement ${eventName}:`, error);\n            }\n        });\n        return true;\n