在 Web 开发中，实时通信在很多场景下都是必须的。传统的轮询技术已经无法满足实时性高、数据量大的要求，因此 WebSocket 技术的出现成为了解决这类问题的关键。
Express.js 是一款流行的 Node.js Web 框架，它可以方便地开发 Web 应用程序。接下来，我们将探讨如何在 Express.js 中使用 WebSocket 实现实时通信。
WebSocket 简介
WebSocket 是一种在单个 TCP 连接上进行全双工、双向通信的协议。与 HTTP 不同，它是一个持久连接，因此可以支持实时通信。
在使用 WebSocket 时，客户端通过 Websocket 对象与服务器端建立连接。这个连接的建立过程与 HTTP 连接类似，但是连接一旦建立就会一直保持下去。通过该连接，客户端和服务器端可以进行双向通信，并且任何一方都可以发送消息给另一方。
Express.js 中使用 WebSocket 的技巧
在 Express.js 中使用 WebSocket 的第一步是引入 websocket 库：
const WebSocket = require('websocket').server;接下来，我们需要实例化 WebSocket 并将其与 Express.js 应用程序绑定：
-- -------------------- ---- -------
----- ---- - ----------------
----- ------- - -------------------
----- --- - ----------
----- ------ - -----------------------
----- --------------- - --- -----------
----------- -------
---------------------- -----
---在上述代码中，我们首先创建了一个 Express.js 应用程序。接着，我们实例化了一个 http 服务器，并将其与 Express.js 应用程序绑定。最后，我们创建了一个 WebSocket 实例，并将其与服务器绑定。
一旦 WebSocket 对象实例化成功，并与服务器绑定，我们就可以开始处理来自客户端的连接请求：
-- -------------------- ---- -------
----------------------------- --------- -- -
----- ---------- - -------------------- ----------------
------------------------ --------- -- -
-- ------------- --- ------- -
-- -- ----- -----
-
---- -- ------------- --- --------- -
-- -------
-
---
---------------------- -------- ------------ -- -
-- ------
---
---在上述代码中，我们监听了 request 事件。每当有客户端连接请求到达时，就会触发该事件。我们可以通过 accept 方法接受该连接请求，并返回一个连接对象。连接对象具有 message 和 close 事件，我们可以用它们处理来自客户端的消息以及关闭事件。
在处理 message 事件时，我们需要区分不同类型的消息。WebSocket 支持两种类型的消息：utf8 和 binary。我们需要根据不同类型的消息作出相应的处理。
在处理 close 事件时，我们可以清理连接操作，例如从连接池中删除连接对象，以便在需要时维护连接数目。
示例代码
为了更好地理解如何在 Express.js 中使用 WebSocket，以下是一个完整的示例代码：
-- -------------------- ---- -------
----- --------- - ----------------------------
----- ---- - ----------------
----- ------- - -------------------
----- --- - ----------
----- ------ - -----------------------
----- --------------- - --- -----------
----------- -------
---------------------- -----
---
--- ----------- - ---
----------------------------- --------- -- -
----- ---------- - -------------------- ----------------
-----------------------------
------------------------ --------- -- -
-- ------------- --- ------- -
-------------------------- -- -
-------------------------------
---
-
---
---------------------- -------- ------------ -- -
----------- - ------------------------- -- -
------ ---- --- -----------
---
---
---
------------ ----- ---- -- -
---------------------- - ---------------
---
------------------- -- -- -
------------------- -- ------- -- ---- -------
---在上述示例中，我们创建了一个 Express.js 应用程序，一个 http 服务器以及一个 WebSocket 实例。我们还创建了一个连接池数组 connections，用于保存所有客户端连接对象。
在 WebSocket 的 request 事件中，我们将用户连接对象推入连接池数组中。在 message 事件中，我们处理 utf8 类型的消息，并将其广播给所有连接。在 close 事件中，我们从连接池数组中删除该连接对象。
最后，我们在 Express.js 应用程序中添加了一个路由，用于提供首页 HTML 文件，以显示 WebSocket 实时通信效果。我们从服务器开始侦听端口，并在控制台打印服务器已启动的消息。
总结
在本文中，我们说明了如何在 Express.js 中使用 WebSocket 实现实时通信。我们介绍了 WebSocket 的基本概念，并提供了一个示例代码，以帮助开发者更好地理解如何实现 WebSocket 实时通信。实际上，要在 Express.js 中使用 WebSocket 并不难，只需要遵循上文提到的步骤即可。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64edb1cff6b2d6eab37da8cb