简介
mubsub 是一个基于 Node.js 和 MongoDB 的、用于实时数据传输的发布订阅工具。在前端领域中，常常会使用 WebSocket、socket.io 等工具进行实时数据传输，而 mubsub 则是一种基于 MongoDB 的实时数据传输方式。
使用 mubsub，可以在 Node.js 项目中方便地进行实时数据传输，例如聊天室、实时通知等场景。
安装
使用 npm 进行安装：
npm install --save mubsub
使用
基本用法
首先，需要在 Node.js 中连接 MongoDB 数据库，并创建 mubsub 连接：
const mubsub = require('mubsub');
const client = mubsub('mongodb://localhost:27017/mydb');其中，mongodb://localhost:27017/mydb 为 MongoDB 数据库连接的地址。可以根据自己的需求进行设置。创建连接后，需要创建一个发布者（publisher）：
const channel = client.channel('my channel');
const publisher = channel.publisher();然后，在需要发送数据时，使用 publish 方法进行发布：
publisher.publish('my event', { data: 'hello world' });这样，就可以在指定的 channel 中发布一个名为 my event 的事件，并将 { data: 'hello world' } 数据作为事件内容。
接着，需要创建一个订阅者（subscriber）：
const subscriber = channel.subscribe();
subscriber.on('my event', function(data) {
console.log(data);
});这样，就可以在 channel 中订阅名为 my event 的事件，并在事件触发时，调用回调函数并打印事件内容。
高级用法
除了基本用法之外，mubsub 还提供了一些高级用法，例如：
使用 Redis 订阅发布
可以使用 Redis 作为 mubsub 的消息代理。首先，在项目中安装 redis 包：
npm install --save redis
然后，可以创建一个 Redis 客户端，并将其作为 mubsub 的消息代理：
const client = mubsub('redis://localhost:6379');这样，就可以将 mubsub 的消息传输转换到 Redis 消息队列中。
指定订阅者 ID
可以为订阅者指定一个固定的 ID，便于在发布者发送消息时指定接收者：
const subscriber = channel.subscribe('user1');
subscriber.on('my event', function(data) {
console.log(data);
});这样，可以指定订阅者的 ID 为 user1，并在发布者发送消息时指定接收者：
publisher.publish('my event', { to: 'user1', data: 'hello world' });这样，只有 ID 为 user1 的订阅者才会接收到消息。
消息确认
可以让订阅者在接收到消息后，发送一个确认消息给发布者，表示已经成功接收到消息：
subscriber.on('my event', function(data, ack) {
console.log(data);
ack();
});这里的 ack 参数为回调函数，用于发送确认消息。订阅者在接收到消息后，会调用该回调函数。
示例代码
以下是一个使用 mubsub 实现的 Node.js 聊天室示例代码，包括客户端和服务器端。该示例中使用了 Express、Socket.io 和 jQuery。
服务器端代码
-- -------------------- ---- -------
----- ------- - -------------------
----- ---- - ----------------
----- -------- - ---------------------
----- ------ - ------------------
----- --- - ----------
----- ------ - -----------------------
----- -- - -----------------
-- ------- ----
----- -------- - ---------------------------------
-- -- ------ --
----- ------ - -----------------
----- ------- - -----------------------
----- --------- - --------------------
-- --------- --
------------------- ---------------- -
-------------- ---- ------------
-- ----
----- ---------- - --------------------
------------------- --------- -------------- ---- -
--------------------- - - ----------------------
------------- --------- ------
------
---
-- -----
----------------------- ---------- -
----------------- ---------------
-------------------
---
-- ----
--------------- --------- ------------- -
--------------------- - - -----
----------------------- --------- -----
---
---
-- -----
------------------- ---------- -
---------------------- -- ---------
---客户端代码
-- -------------------- ---- -------
--------- -----
------
------
-------------------
-------
- -
------------ ------ -----------
-
--------- -
---------------- -----
------- --
-------- --
-
--------- -- -
-------- --- -----
-
--------- ----------------- -
----------------- --------
-
----- -
------- --- ----- -----
-------------- ----
-------- -----
----------- -----
-
--------
-------
------
--- -------------------
---- ----------
------ ---------- ----------- ----------------- ---- ------- ------
------- -----------------------
------
------- ---------------------------------------
------- -----------------------------------------------------------
--------
------------ -
--- ------ - -----
-- ----
--------------------------- -
--- ------- - ------------------
----------------- --------- ---------
--------------------
------ ------
---
-- ----
--------------- --------- ------------- -
-------------------------------------------
------------------ ----------------------------
---
---
---------
-------
-------在使用该示例代码之前，需要先启动 MongoDB 服务，并使用 mongod 命令启动服务器。然后，使用 npm install 命令安装依赖包。最后，使用 npm start 命令启动服务器并访问 http://localhost:3000 即可进入聊天室。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/87359