使用pubsub-js来做消息的订阅和发布

安装pubsub-js

  • 使用npm安装:npm install pubsub-js
  • 使用yarn安装:yarn add pubsub-js

引入

import PubSub from ‘pubsub-js‘

// or when using CommonJS
const PubSub = require(‘pubsub-js‘);

基本案例

// create a function to subscribe to topics
var mySubscriber = function (msg, data) {
    console.log( msg, data );
};

// add the function to the list of subscribers for a particular topic
// we‘re keeping the returned token, in order to be able to unsubscribe
// from the topic later on
var token = PubSub.subscribe(‘MY TOPIC‘, mySubscriber);

// publish a topic asynchronously
PubSub.publish(‘MY TOPIC‘, ‘hello world!‘);

// publish a topic synchronously, which is faster in some environments,
// but will get confusing when one topic triggers new topics in the
// same execution chain
// USE WITH CAUTION, HERE BE DRAGONS!!!
PubSub.publishSync(‘MY TOPIC‘, ‘hello world!‘);

取消订阅

// create a function to receive the topic
var mySubscriber = function (msg, data) {
    console.log(msg, data);
};

// add the function to the list of subscribers to a particular topic
// we‘re keeping the returned token, in order to be able to unsubscribe
// from the topic later on
var token = PubSub.subscribe(‘MY TOPIC‘, mySubscriber);

// unsubscribe this subscriber from this topic
PubSub.unsubscribe(token);

取消某个函数的所有订阅

// create a function to receive the topic
var mySubscriber = function(msg, data) {
    console.log(msg, data);
};

// unsubscribe mySubscriber from ALL topics
PubSub.unsubscribe(mySubscriber);

取消某个topic的全部订阅

PubSub.subscribe(‘a‘, myFunc1);
PubSub.subscribe(‘a.b‘, myFunc2);
PubSub.subscribe(‘a.b.c‘, myFunc3);

PubSub.unsubscribe(‘a.b‘);
// no further notifications for ‘a.b‘ and ‘a.b.c‘ topics
// notifications for ‘a‘ will still get published

取消所有订阅

PubSub.clearAllSubscriptions();
// all subscriptions are removed

使用pubsub-js来做消息的订阅和发布

上一篇:Okhttp拦截器Interceptor学习和使用


下一篇:MyBatis-Plus 3.4.2 分页查询 total始终为0