如何在 Deno 中构建 WebSockets 聊天应用程序?

阅读时长 10 分钟读完

前言

WebSockets 聊天应用程序是一个常见的 Web 开发项目。它使用 WebSocket 协议来实现实时通信,具有很多优点,例如协议简单、实时性好、可以节省带宽等等。在本文中,您将学习如何在 Deno 中构建一个简单的聊天应用程序,该应用程序将使用 WebSocket 实现实时聊天功能。

前提知识

为了理解本文,您需要具备以下知识:

  • TypeScript:本文中代码示例均使用 TypeScript 编写。如果您不熟悉 TypeScript,可以先阅读 TypeScript 入门 文档。
  • Deno:本文将使用 Deno 运行环境来构建应用程序。如果您还不了解 Deno,请先查看 Deno 入门 文档。

步骤

在本节中,我们将按照以下步骤构建聊天应用程序:

  1. 创建 WebSocket 服务器。
  2. 处理 WebSocket 连接请求。
  3. 处理 WebSocket 发送的消息。
  4. 处理 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

纠错
反馈