介绍
culvert 是一个基于 WebSocket 的 Node.js 消息队列。使用 culvert 可以在不同进程和不同服务器之间快速发送和接收消息。该 npm 包的特点是：轻量、易用、性能强。
安装
要安装 culvert，需要在命令行中使用 npm：
npm install culvert
使用 culvert
创建 culvert 服务器
我们可以使用 culvert 模块中提供的 WebSocket 服务器，使其成为消息队列服务器。下面是一个简单的示例：
-- -------------------- ---- -------
----- ------- - -------------------
----- ------ - -----------------------
----------------------- -------------------- -
------------------- ------------
--------------------- -------------- -
--------------------- ---------- -----------------
---
--------------------------
---------------------- ---------- -
------------------- ---------------
---
---
------------------- ---------- -
-------------------- ------ -- --------- -- ---- --------
---上面的代码使用 culvert.createServer() 创建了一个 WebSocket 服务器，并监听 connection 事件接受客户端连接。当连接建立时，服务器向客户端发送了一条 "Hello!" 消息，并监听 data 事件接受客户端发送的消息。当客户端断开连接时，服务器监听 close 事件并输出 Client disconnected 消息。
创建 culvert 客户端
我们也可以使用 culvert 创建客户端，向服务器发送消息：
-- -------------------- ---- ------- ----- ------- - ------------------- ----- ------ - -------------------------------------------- -------------------- ---------- - ---------------------- -- --------- ---------------- ---------- --- ----------------- -------------- - --------------------- ---------- ----------------- --- ------------------ ---------- - ------------------------- ---- --------- ---
上面代码使用 culvert.createClient() 创建了一个 WebSocket 客户端，并连接到服务器。客户端监听 connect 事件，当连接成功后向服务器发送一条 "Hi, server!" 消息。客户端也监听 data 事件接受服务器返回的消息，当断开连接时监听 close 事件并输出消息。
实现 culvert 消息队列
除了上述例子，我们也可以将 culvert 用在项目中实现消息队列，以下是一个示例：
-- -------------------- ---- -------
----- ------- - -------------------
----- ------------ - -------------------------------
----- ------------ ------- ------------ -
------------- ---------- --------- -- -
--------
-------------- - ----------
----------- - --------------------------------
------------------------- -- -- -
---------------------------------
----- ------------
------ ---------
----
---
---------------------- --------- -- -
--- -
------- - -------------------------------
-------------------- ---------
- ----- --- -
-------------------- ------- ---------- -----------
-
---
-
---------------- -
---------------------------------
----- ----------
------ ---------------
-------
----
-
-
-- ----
----- ------------ - --- --------------
---------- ----------------------
---------- ----------
---
-------------------------- --------- -- -
--------------------- ---------- ---------
---
----------------------
------ ------- --------
-------- ----- -- - ------- ---- ------- ------- -------
---上面代码中，MessageQueue 类使用 culvert 创建客户端并连接到服务器。在连接建立后，客户端向服务器发送了一条 "subscribe" 类型的消息，表示订阅了一个名为 my-queue 的消息队列。当客户端接受到服务器发送的消息时，判断其是否为 JSON 格式，并以 message 事件向外发出。publish() 方法用于向队列中发布一条消息。
在使用时我们只需要初始化 MessageQueue 类即可，如上面代码中的使用示例。在运行时，用户可以通过 messageQueue.publish() 方法向队列中发布消息，并通过 messageQueue.on('message', () => {}) 监听 message 事件来接受队列中的消息。
总结
culvert 简单易用、性能强是因其将 WebSocket 技术和消息队列结合的优秀实现。在实际项目中可以使用 culvert 快速实现消息队列，减少开发成本同时提高应用性能。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/57804