介绍
@anderspitman/ws-streamify 是一个 npm 包，它可以使 WebSockets 流化。这个库的主要目的是在 Node.js 环境中最大化 WebSockets 的效用，使你更容易地将流传输添加到你的项目中。这个库提供了两个 API，分别是 toWebSocketStream 和 fromWebSocketStream，这两个 API 使得我们能够对来自和前往 WebSockets 的数据流进行转换。
安装
你可以通过 npm 来安装 @anderspitman/ws-streamify：
$ npm install @anderspitman/ws-streamify
用法
下面我们来解释如何使用 @anderspitman/ws-streamify。首先，让我们看一下 toWebSocketStream 和 fromWebSocketStream 的使用。
toWebSocketStream
-- -------------------- ---- ------- ----- --------- - -------------- ----- - ----------------- - - -------------------------------------- ----- ------ - --- --------------------------------- ----- ------ - -------------------------- ----------------- ---- -- - ----------------------------- --- ------------- -- - ----------------------- ------------- -- ------
在这个示例中，我们使用 Node.js 的 WebSocket 库来创建一个 WebSocket 客户端。使用 toWebSocketStream 函数，我们将 WebSocket 对象传递给函数，然后函数返回一个 Node.js 可读流对象。你可以对这个对象调用 Node.js 流 API 的方法，例如 write、end 等。这个流会通过 WebSocket 与服务端进行通信。
fromWebSocketStream
-- -------------------- ---- ------- ----- --------- - -------------- ----- - ------------------- - - -------------------------------------- ----- ------ - --- --------------------------------- ----- ------ - ---------------------------- ----------------------- ------------- ----------------- ---- -- - ----------------------------- ---
在这个示例中，我们使用 fromWebSocketStream 函数从我们创建的 WebSocket 上创建了一个 Node.js 可写流。你可以对这个流调用 Node.js 流 API 的方法，例如 write、end 等，并且写入的数据会通过 WebSocket 与服务端进行通信。
综合示例
接下来，我们使用综合示例，将 toWebSocketStream 和 fromWebSocketStream 结合起来，以从客户端向服务端发送文本消息。
-- -------------------- ---- -------
----- --------- - --------------
----- - ------------------ ------------------- - - --------------------------------------
----- ------ - --- ------------------ ----- ---- ---
----------------------- ------ -- -
----- ------ - ----------------------------
----------------- ---- -- -
--------------------- -------- ---------------------
---
----------------------- -- ---------
-------------
---
----- ------ - --- ---------------------------------
----- ------ - --------------------------
----------------- ---- -- -
--------------------- -------- ---------------------
---
----------------------- -- ---------
-------------在这个示例中，我们创建了一个 WebSocket 服务器，并添加了 connection 监听器。在监听器中，我们使用 fromWebSocketStream 函数从 WebSocket 流上创建了一个 Node.js 可读流对象，然后等待读取与服务端建立连接时发送的消息。在这里，我们向客户端发送了一条消息，然后结束了可写流。在客户端，我们使用 toWebSocketStream 函数从 WebSocket 对象上创建了一个 Node.js 可写流对象，并向服务端发送了一条消息。我们还添加了 data 监听器，等待从服务器收到消息。
结论
@anderspitman/ws-streamify 提供了一种使 WebSockets 流化的方法。它提供了 toWebSocketStream 和 fromWebSocketStream 两个函数，这两个函数分别将 WebSocket 对象与 Node.js 可读流对象和可写流对象进行转换。使用这个库，我们可以在我们的项目中更轻松地实现流传输。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600668f8d9381d61a3540f97