前言
WebSockets 聊天应用程序是一个常见的 Web 开发项目。它使用 WebSocket 协议来实现实时通信,具有很多优点,例如协议简单、实时性好、可以节省带宽等等。在本文中,您将学习如何在 Deno 中构建一个简单的聊天应用程序,该应用程序将使用 WebSocket 实现实时聊天功能。
前提知识
为了理解本文,您需要具备以下知识:
- TypeScript:本文中代码示例均使用 TypeScript 编写。如果您不熟悉 TypeScript,可以先阅读 TypeScript 入门 文档。
- Deno:本文将使用 Deno 运行环境来构建应用程序。如果您还不了解 Deno,请先查看 Deno 入门 文档。
步骤
在本节中,我们将按照以下步骤构建聊天应用程序:
- 创建 WebSocket 服务器。
- 处理 WebSocket 连接请求。
- 处理 WebSocket 发送的消息。
- 处理 WebSocket 连接断开。
1. 创建 WebSocket 服务器
在 Deno 中,我们可以使用标准库中的 WebSocketServer
类创建 WebSocket 服务器。为此,我们需要导入 ws
模块并创建 WebSocketServer
实例,如下所示:
-- -------------------- ---- ------- ------ - ----- - ---- --------------------------------------- ------ - ---------------- --------------- - ---- ---------------------------------- ----- ---- - ----- ----- ------ - ------- ---- --- ----- --- - --- ------------------ ---------------------- ------ -- ------- -- ----------- --- ----- ------ --- -- ------- - ----- - ----- -- ---------- -- ---------- ------- - - ---- --- - ----- -- - ----- ----------------- ----- ---------- ---------- -------- --- -------------------- - ----- ------- - ------------------------ ---------- ------- ----------- - -
在上述代码中,我们创建了一个 HTTP 服务器并将其绑定到了指定的端口上。然后,我们创建了一个 WebSocketServer
实例并开始监听连接请求。当收到连接请求时,我们调用上面的 acceptWebSocket()
方法来接受连接请求,然后调用 handleWebSocket()
方法来处理 WebSocket 连接。
2. 处理 WebSocket 连接请求
在本节中,我们将实现 handleWebSocket()
方法来处理 WebSocket 连接请求。当连接建立时,我们将对连接进行身份验证,然后向客户端发送欢迎消息。
-- -------------------- ---- ------- ----- -------- ------------------- ---------- - ---------------------- ---------- ------------------------ ----- ------ - ----- ----------------- -- --------- - ----------- - ---- - ------------------------ ----- ---------- ------ ---- ------------------------ --------- ---------- ------ --- ------- ------------------------------- ---- ------------------- - -
在上述代码中,我们调用 authenticate()
方法来对 WebSocket 连接进行身份验证。如果验证失败,我们将立即关闭连接。否则,我们向客户端发送欢迎消息,并广播有新用户加入的信息。然后我们开始处理 WebSocket 发送的消息,并在关闭连接前从用户列表中移除该用户。
3. 处理 WebSocket 发送的消息
在本节中,我们将实现 handleWebSocketMessages()
方法来处理 WebSocket 发送的消息。当客户端发送消息时,我们将对其进行解析并广播该消息给所有连接的客户端。
-- -------------------- ---- ------- ----- -------- ------------------------------- ------- --- ---------- - --- - --- ----- ------ ------- -- --- - -- ------- ------- --- --------- - ----- - ----- ---- - - ------------------- -- - ----- ------- ----- ------ -- -- ----- --- ---------- - ------------------------ ------- ------ - - - - ----- ------- - ------------------------ -------- ------- - -
在上述代码中,我们将消息解析为 JSON 对象,并根据 type
属性决定广播的方式。如果 type
为 "message"
,则我们将广播文本消息。否则,我们将忽略该消息。
4. 处理 WebSocket 连接断开
在本节中,我们将实现 broadcastMessage()
方法来广播消息给所有连接的客户端。该方法将遍历所有连接的 WebSocket 实例并向它们发送消息。
-- -------------------- ---- ------- -------- ---------------------- ------- --- ------- ----- ------- - --- ------ ------ -- ------------ - -- ----------------- - -------------------------- - ---- -- -------------- --- --- - ---------------------------- ----- ---------- ----- ---- ---- - - -
在上述代码中,我们将遍历 WebSocket 服务器中的所有客户端实例。如果客户端已经关闭,则我们将从用户列表中移除该用户。否则,我们将检查客户端的 userId
属性是否与 to
参数匹配。如果客户端与目标用户不匹配,则我们将向其发送消息。
完整代码示例
下面是完整的代码示例:
-- -------------------- ---- ------- ------ - ----- - ---- --------------------------------------- ------ - ---------------- --------------- - ---- ---------------------------------- ----- ---- - ----- ----- ------ - ------- ---- --- ----- --- - --- ----------------------------- ---------------------- ------ -- ------- -- ----------- --- ----- ------ --- -- ------- - ----- - ----- -- ---------- -- ---------- ------- - - ---- --- - ----- -- - ----- ----------------- ----- ---------- ---------- -------- --- -------------------- - ----- ------- - ------------------------ ---------- ------- ----------- - - ----- -------- ------------------- ---------- - ---------------------- ---------- ------------------------ ----- ------ - ----- ----------------- -- --------- - ----------- - ---- - ------------------------ ----- ---------- ------ ---- ------------------------ --------- ---------- ------ --- ------- ------------------------------- ---- ------------------- - - ----- -------- ------------------------------- ------- --- ---------- - --- - --- ----- ------ ------- -- --- - -- ------- ------- --- --------- - ----- - ----- ---- - - ------------------- -- - ----- ------- ----- ------ -- -- ----- --- ---------- - ------------------------ ------- ------ - - - - ----- ------- - ------------------------ -------- ------- - - -------- ---------------------- ------- --- ------- ----- ------- - --- ------ ------ -- ------------ - -- ----------------- - -------------------------- - ---- -- -------------- --- --- - ---------------------------- ----- ---------- ----- ---- ---- - - - -------- ---------------- ----------- -------------- - ----- - -- ----- --------- -------------- ----- ------ ------------------------- - -------- ------------------ ------- - -- ----- --------- ------ ---- ----- -
总结
在本文中,我们介绍了如何在 Deno 中使用 WebSocket 协议构建实时聊天应用程序。我们使用 WebSocketServer
类创建了 WebSocket 服务器,并通过遍历所有客户端实例来对消息进行广播。虽然本文中的应用程序非常简单,但您可以使用类似的技术来构建更复杂的应用程序,例如多用户游戏、实时通知等等。
来源:JavaScript中文网 ,转载请注明来源 https://www.javascriptcn.com/post/64788603968c7c53b04bf240