自学内容网 自学内容网

用 JS 实现一个发布订阅模式

在JavaScript中,发布订阅模式(Pub/Sub)是一种常用的设计模式,用于实现不同组件之间的解耦通信。在这种模式中,发布者(Publisher)不直接给订阅者(Subscriber)发送消息,而是将消息发送到一个中心主题(Topic),订阅了该主题的订阅者会收到这个消息。

下面是一个简单的发布订阅模式的实现示例:

class PubSub {  
    constructor() {  
        this.topics = {}; // 存储所有主题的订阅者  
    }  
  
    // 订阅主题  
    subscribe(topic, callback) {  
        if (!this.topics[topic]) {  
            this.topics[topic] = []; // 如果该主题不存在,则初始化一个空数组  
        }  
        this.topics[topic].push(callback); // 将回调函数添加到订阅者列表中  
        return () => { // 返回一个取消订阅的函数  
            this.unsubscribe(topic, callback);  
        };  
    }  
  
    // 取消订阅  
    unsubscribe(topic, callback) {  
        if (this.topics[topic]) {  
            const index = this.topics[topic].indexOf(callback);  
            if (index > -1) {  
                this.topics[topic].splice(index, 1); // 从订阅者列表中移除回调函数  
            }  
        }  
    }  
  
    // 发布消息  
    publish(topic, data) {  
        if (this.topics[topic]) {  
            this.topics[topic].forEach(callback => {  
                callback(data); // 遍历订阅者列表,调用每个订阅者的回调函数  
            });  
        }  
    }  
}  
  
// 使用示例  
const pubSub = new PubSub();  
  
// 订阅者1  
const subscriber1 = (data) => {  
    console.log('Subscriber 1:', data);  
};  
  
// 订阅者2  
const subscriber2 = (data) => {  
    console.log('Subscriber 2:', data);  
};  
  
// 订阅主题  
const unsubscribe1 = pubSub.subscribe('news', subscriber1);  
pubSub.subscribe('news', subscriber2);  
  
// 发布消息  
pubSub.publish('news', 'Hello, Pub/Sub!');  
  
// 取消订阅  
unsubscribe1();  
pubSub.publish('news', 'This message will not be seen by subscriber 1.');

在这个示例中,PubSub 类有三个主要方法:

  • subscribe(topic, callback):订阅一个主题,并传入一个回调函数。该方法返回一个函数,用于取消订阅。
  • unsubscribe(topic, callback):取消订阅一个主题上的回调函数。
  • publish(topic, data):向一个主题发布消息,所有订阅了该主题的回调函数都会被调用,并接收到发布的消息数据。

通过这种方式,发布者和订阅者之间实现了松耦合,它们不需要知道对方的存在,只需要通过主题进行通信。


原文地址:https://blog.csdn.net/qq_39056703/article/details/142391805

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!