npm 包 pull-notify 使用教程

前言

在面对开发中需要实现实时通知的情况时，我们往往需要引用各种监控、推送、消息等相关的服务。这些服务在数据量不大时效果显著，但是一旦数据量变大时，服务能力则会成为一个瓶颈，而这时候我们往往需要实现一个简单、高效、可扩展的通知服务。

在这篇文章中，我们将介绍如何使用 npm 包 pull-notify 来实现一个高效的通知服务。

pull-notify

pull-notify 是一个基于 Node.js 的实时通知工具包，它的设计理念是通过 pull 模式获取数据，并实现消息的实时推送。

使用 pull-notify，我们可以很容易的实现一个支持多路订阅、推送和通知分片传递的通知系统，对于开发者来说是一个极佳的利器。

安装

在使用 pull-notify 之前，首先需要安装它。打开终端窗口并输入以下命令：

npm install pull-notify --save

使用

订阅

使用 pull-notify 的第一步是订阅消息。我们可以通过调用 subscribe 方法来订阅一个消息，订阅后，我们就可以接收到这个消息的通知了。

下面是订阅一个名为 test 的消息的示例代码：

var notify = require('pull-notify');
var sub = notify.subscribe('test');

通过上面的代码，我们订阅了一个名为 test 的消息，并用一个变量 sub 来接收订阅消息的句柄。

推送

订阅者接收到的消息是由推送者推送的。使用 pull-notify 可以很容易的实现对订阅者的消息推送。

下面是发送一个名为 test 的消息的示例代码：

var notify = require('pull-notify');
notify.emit('test', {msg: 'hello world!'});

以上代码中，我们通过调用 emit 方法来发送一个名为 test 的消息，并传递一个包含 msg 属性的 JSON 对象作为消息体。

取回/推送消息

通过订阅一个消息，我们成功的接收了这个消息。当然，我们也需要通过调用一个方法来获取订阅的消息。

下面是一个简单的例子：

var notify = require('pull-notify');
var sub = notify.subscribe('test');
sub(function (err, data) {
  console.log('received message: ', data);
});

在上面的代码中，我们首先订阅了名为 test 的消息，并用一个变量 sub 来接收订阅消息的句柄。接着我们使用订阅消息的句柄 sub 来获取消息，并在获取到消息后打印消息体。

取消订阅

在不需要接收某个订阅消息时，我们需要取消这个订阅。这时候，我们可以通过调用 unsubscribe 方法来取消订阅。

下面是取消对名为 test 的消息订阅的示例代码：

var notify = require('pull-notify');
var sub = notify.subscribe('test');
sub(function (err, data) {
  console.log('received message: ', data);
  sub.unsubscribe();
});

通过以上代码，我们成功的取消了名为 test 的消息的订阅。

总结

使用 pull-notify 可以很容易的实现一个高效的实时通知服务。在本文中，我们介绍了如何安装和使用 pull-notify，包括如何订阅、推送、取回消息以及取消订阅。如果你正在寻找一款高效的实时通知工具包，那么 pull-notify 是一个值得使用的选择。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/pull-notify