WebSocket 已成为现代 Web 应用程序中实时通信的主要方式。它提供了一种在客户端和服务器之间进行双向通信的机制，而无需使用轮询或长轮询技术。Fastify 是一个快速且低开销的 Node.js Web 框架，具有出色的性能和插件支持。本文将介绍如何在 Fastify 中使用 WebSocket 进行客户端与服务器之间的实时数据传输。
安装 Fastify 和 ws
首先，我们需要安装 Fastify 和 ws。通过运行以下命令在项目目录中安装 Fastify。
npm install fastify --save
然后，安装 WebSocket：
npm install ws --save
创建 WebSocket 服务器
要创建 WebSocket 服务器，请使用 Node.js 内置的 http 模块。我们还需要使用 ws 模块将 HTTP 服务器升级为一个 WebSocket 服务器。以下示例代码演示如何创建 WebSocket 服务器。
-- -------------------- ---- -------
----- ---- - ----------------
----- --------- - --------------
----- ------ - --------------------
----- --- - --- ------------------ ------ ---
-------------------- -------- -------------- -
---------------- -------- ----------------- -
--------------------- -------- -------------
------------ ---- ---------------
---
------------------ -- ---------
---
------------------- ---------- -
------------------- --------- -- ---- -------
---在上面的代码中，我们创建了一个 HTTP 服务器和一个 WebSocket 服务器。通过 ws.on('connection') 函数，我们可以在客户端连接时执行某些操作。在此示例中，我们可以使用 ws.send() 向客户端发送消息。
集成 WebSocket 到 Fastify
Fastify 现在已经有将 WebSocket Server 集成到其核心的插件，这使得 Fastify 成为开发 Ephemeral 类私人聊天应用程序以及任何用户可以通过浏览器进行 WebSocket 通信的应用程序的理想选择。下面是一个使用 Fastify WebSocket 插件的代码示例：
-- -------------------- ---- -------
----- ------- - ---------------------
----- --------- - -----------------------------
--------------------------- -
------- ---------------
---
-------- --------------------- -
--------------- -------- -------------- -
--------------- ---- ------------
---
--------------------- -- ---------
-
-------------------- ---------- -
------------------- --------- -- ---- -------
---在上面的代码中，我们将 Fastify WebSocket 插件注册到 Fastify 实例中。此插件有一个名为 handle 的选项，它将 WebSocket 连接路由到一个函数。在此示例中，我们将 handleWebSocket 函数传递给插件，它将从我们的 WebSocket 客户端接收数据并发送消息回客户端。
与 Fastify 密切合作的 WebSocket 库 adonis-websocket 库
Fastify WebSocket 插件是一个很好的解决方案，但有一些限制。例如，Fastify WebSocket 插件不支持 WebSocket ping/pong，这可能会导致客户端在一段时间后失去连接。同时，Fastify WebSocket 插件仅支持在 Fastify 实例上启用 WebSocket 服务器。因此，如果您想在 Fastify 应用程序的子路径上运行 WebSocket 服务器，则需要使用其他解决方案。
一种解决方案是使用 adonis-websocket 库，它是为 AdonisJS 框架开发的 WebSocket 库，但与 Fastify 密切合作。该库支持 WebSocket ping/pong 和在 Fastify 应用程序的任何路径上运行 WebSocket 服务器。以下示例演示如何在 Fastify 应用程序中使用 adonis-websocket 库。
-- -------------------- ---- -------
----- ------- - ---------------------
----- - ------------ - - ----------------
----- --------- - --------------
----- -------- - -------------------------------------
-- ---------- --------- ------ --
----- -------- - --- ----------
------- ----------------------------
---
-- ------ ----- --
-------------------------- -- --- ---- -- -- -
------------ ----- - - ------
---
-- -------- --------- ----- --
------------------------ - ---------- ---- -- ------ ---- -- -
-- ------ --------- ----- --- ---- --
------------------
-----
----
---- ------ - ---------------
---
---
-------------------- ---------- -
------------------- --------- -- ---- -------
---在上面的代码中，我们通过 adonis-websocket 库将 WebSocket 路由集成到 Fastify 应用程序中。 route 方法允许我们注册 WebSocket 路由，该路由将在客户端连接时执行某些操作。在此示例中，我们根据 /ws/:room 路径为每个房间定义 WebSocket 连接。每当客户端连接时调用 WebSocket 连接。
结论
WebSocket 提供了一种在 Web 应用程序中实现实时通信的一流机制。在本文中，我们介绍了如何在 Fastify 中使用 WebSocket 进行客户端与服务器之间的实时数据传输。我们还涵盖了几个方案，包括使用 Fastify WebSocket 插件和 adonis-websocket 库，以帮助您根据您的具体需求选择最佳方案。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6716d9c1ad1e889fe21e4f02