Node.js的观察者模式与发布订阅模式：区别解析

前端

2023-01-17 10:47:32

观察者模式与发布订阅模式：提升应用程序通信

在构建应用程序时，通信至关重要。两个强大的设计模式——观察者模式和发布订阅模式——可以帮助您管理复杂的多对一通信。让我们深入了解它们各自的优点、缺点和适用场景。

观察者模式：紧密耦合的通知

观察者模式是一种对象间一对多的依赖关系，当被观察对象（主题）的状态发生变化时，它会通知其所有观察者。主题管理着观察者，并在状态改变时负责通知它们。观察者则监听主题状态的变化并做出响应。

优点：

紧密耦合，确保主题状态变化后的快速响应
简化事件通知，尤其是在需要立即响应时

缺点：

耦合度高，更改主题可能导致观察者受影响
可扩展性差，观察者数量过多可能导致性能问题

代码示例：

class Subject {
  constructor() {
    this.observers = [];
  }

  addObserver(observer) {
    this.observers.push(observer);
  }

  removeObserver(observer) {
    this.observers = this.observers.filter((obs) => obs !== observer);
  }

  notifyObservers() {
    this.observers.forEach((obs) => obs.update());
  }
}

class Observer {
  constructor(subject) {
    this.subject = subject;
    subject.addObserver(this);
  }

  update() {
    console.log("Observer notified of state change");
  }
}

const subject = new Subject();
const observer1 = new Observer(subject);
const observer2 = new Observer(subject);
subject.notifyObservers();

发布订阅模式：松散耦合的广播

发布订阅模式也是一对多通信模式，但它引入了一个中间层——消息队列。发布者将消息发布到队列中，而订阅者订阅特定主题，并在队列中收到与该主题相关的消息时进行响应。

优点：

松散耦合，发布者和订阅者之间没有直接依赖关系
高可扩展性，订阅者数量不会影响性能
灵活，发布者和订阅者可以轻松地添加或删除

缺点：

延迟交付，消息可能不会立即到达订阅者
可靠性依赖于消息队列的可靠性

代码示例：

class Publisher {
  constructor(queue) {
    this.queue = queue;
  }

  publish(message) {
    this.queue.publish("my-topic", message);
  }
}

class Subscriber {
  constructor(queue) {
    this.queue = queue;
    queue.subscribe("my-topic", this.onMessage.bind(this));
  }

  onMessage(message) {
    console.log(`Subscriber received message: ${message}`);
  }
}

const queue = new MessageQueue();
const publisher = new Publisher(queue);
const subscriber1 = new Subscriber(queue);
const subscriber2 = new Subscriber(queue);
publisher.publish("Hello, world!");