Event Bus 与观察者模式在 JavaScript (Node.js) 中的应用——构建灵活的事件驱动系统

Event Bus 与观察者模式在 JavaScript (Node.js) 中的应用

在现代 Node.js 开发中，经常需要在不创建组件间硬性依赖的情况下，组织应用程序不同部分之间的交互。观察者模式及其更强大的实现——Event Bus（事件总线）——为此提供了优雅的解决方案。本文将详细讲解如何在 Node.js 环境中使用纯 JavaScript 实现这些模式，并探讨它们的优势和典型使用场景。

什么是观察者模式？

观察者模式定义了对象之间一对多的依赖关系：当一个对象（主题）改变状态时，所有依赖它的对象（观察者）都会自动收到通知。在 Node.js 的上下文中，该模式是内置模块 events 的基础，该模块提供了 EventEmitter 类。

Event Bus：概念的扩展

Event Bus 是一个集中式事件总线，允许应用程序中的任何组件发送和接收消息，而无需直接了解彼此。这在微服务架构、具有模块化结构的复杂应用或构建插件系统时特别有用。

在 Node.js 中实现 Event Bus

让我们从零开始创建自己的 Event Bus。我们的类将支持以下核心方法：订阅事件 (on)、一次性订阅 (once)、移除订阅者 (off) 和触发事件 (emit)。

class EventBus {    constructor() {        this.events = {};    }

    on(event, listener) {        if (!this.events[event]) {            this.events[event] = [];        }        this.events[event].push(listener);        return () => this.off(event, listener);    }

    once(event, listener) {        const wrapper = (...args) => {            listener(...args);            this.off(event, wrapper);        };        this.on(event, wrapper);        return () => this.off(event, wrapper);    }

    off(event, listener) {        if (!this.events[event]) return;        this.events[event] = this.events[event].filter(l => l !== listener);    }

    emit(event, ...args) {        if (!this.events[event]) return false;        this.events[event].forEach(listener => listener(...args));        return true;    }}

// 使用示例const bus = new EventBus();

const unsubscribe = bus.on('user:login', (username) => {    console.log(`用户 ${username} 已登录系统`);});

bus.once('app:start', () => {    console.log('应用程序已启动（一次性通知）');});

// 触发事件bus.emit('app:start'); // "应用程序已启动（一次性通知）"bus.emit('user:login', '安娜'); // "用户 安娜 已登录系统"

// 取消订阅unsubscribe();bus.emit('user:login', '伊万'); // 什么也不会发生

使用 Node.js 内置的 EventEmitter

Node.js 在 events 模块中提供了现成的 EventEmitter 实现。然而，基于它构建的 Event Bus 可以集中管理应用程序的所有事件。

const EventEmitter = require('events');

class AppEventBus extends EventEmitter {    constructor() {        super();        this.setMaxListeners(50); // 增加订阅者数量限制    }

    // 添加日志记录以便调试    emit(event, ...args) {        console.log(`[EventBus] 事件: ${event}`);        return super.emit(event, ...args);    }}

const appBus = new AppEventBus();

// 订阅事件appBus.on('order:created', (order) => {    console.log(`订单 #${order.id} 已创建。正在发送通知。`);});

appBus.on('order:created', (order) => {    console.log(`订单 #${order.id} 已创建。正在更新库存。`);});

// 触发事件appBus.emit('o