如何使用 Mongoose 与 Node.js 实现实时通知

在现代 Web 应用程序中,实时通知已经成为一种必须的功能,帮助用户及时了解应用程序的状态、更新和错误等。在本文中,我们将介绍如何使用 Mongoose 和 Node.js 实现实时通知。

什么是 Mongoose

Mongoose 是一个针对 MongoDB 的 Node.js ORM 库。它提供了在 MongoDB 中快速和容易地定义模式、验证、查询和操作插入/更新/删除等操作的方式。

实时通知的实现

在本文中,我们将使用以下技术:

  • Node.js v10.0.0+
  • Mongoose 5.0.0+
  • Socket.io 2.1.0+

在这个示例中,我们将创建一个简单的聊天室,它能够实现实时通知的功能。当有新的消息发送到服务器时,所有连接到聊天室的客户端都会接收到实时通知。

首先,我们需要创建一个 Node.js 项目,并通过 NPM 安装 Mongoose 和 Socket.io。

----- ---------------------------
-- ---------------------------

--- ---- --
--- - -------- ---------

接下来,我们需要连接到 MongoDB 数据库。在此示例中,我们将在本地运行 MongoDB。为了连接到 MongoDB 数据库,我们需要在 Node.js 代码中添加以下代码:

----- -------- - --------------------

-------------------------------------------- -
   ---------------- ----
---

在本示例中,我们命名数据库为 "chat"。您可以根据自己的需要更改数据库的名称和 MongoDB 的连接 URL。

现在,我们需要定义一个简单的消息模式。以下是一个基本的消息模式的示例:

----- ------------- - --- -----------------
   ----- -
      ----- -------
      --------- -----
      ----- ----
   --
   -------- -
      ----- -------
      --------- -----
      ----- ----
   --
   ---------- -
      ----- -----
      -------- --------
   -
---

----- ------- - ------------------------- ---------------

现在,我们可以使用 Mongoose 模型来执行插入、更新和删除操作。

接下来,我们需要使用 Socket.io 库来实现实时通知。以下是创建 Socket.io 服务器的代码示例:

----- ---- - ----------------
----- --- - ---------------------
----- ------ - -----------------------
----- -- - -----------------------------

------------------- -------- -- -
   -------------- ---- ------------
---

------------------- -- -- -
   ---------------------- -- ---------
---

在上面的代码中,我们使用了 Express 库来创建 Web 服务器,并将其传递给 Socket.io 服务器。

现在,我们需要添加一些代码以实现发送和接收消息。以下是扩展 Socket.io 服务器的代码:

------------------- -------- -- -
   -------------- ---- ------------

   -------------------- ------ -- -
      ----- ------- - --- --------------

      ------------------ -- -
         -- ----- -
            -------------------
         - ---- -
            ------------------ ------
         -
      ---
   ---
---

在上述代码中,我们通过 Socket.io 监听客户端的 message 事件。当客户端发送新的消息时,我们创建一个新的消息对象,并将其保存到 MongoDB 数据库中。

如果存在任何错误,我们将在控制台上打印错误。如果一切顺利,我们将使用 io.emit() 方法向所有连接到聊天室的客户端发送一个 message 事件和数据对象。

接下来,我们需要更新客户端代码以实现接收实时通知的功能。以下是客户端 Socket.io 代码示例:

----- ------ - -----

-------------------- ------ -- -
   ------------------
---

上述代码将客户端连接到 Socket.io 服务器,并监听 message 事件。当服务器发送新消息时,客户端将在控制台上打印数据对象。

现在,我们可以开始测试我们的应用程序了。运行以下命令来启动服务器:

---- ---

然后在浏览器中打开两个或多个选项卡,并使用以下代码将客户端 JavaScript 包含在 HTML 页面中:

------- ---------------------------------------
--------
   ----- ------ - -----

   --------------------------------------------------------- ------- -- -
      -----------------------

      ----- --------- - -------------------------------------------
      ----- ------------ - ----------------------------------------------
      ----- ---- - -----------------------
      ----- ------- - --------------------------

      -- ----- -- -------- -
         ---------------------- - ----- ------- ---

         --------------- - ---
         ------------------ - ---
      -
   ---

   -------------------- ------ -- -
      ----- ------------ - ------------------------------------
      ----- ------- - -----------------------------

      ------------------- - -------------- -----------------

      ----------------------------------
   ---
---------

------
   ------ ----------- ----------- ----------------- ------
   ------ ----------- -------------- ----------------- ---------
   ---------------------
-------

--- ----------------------

现在,您可以使用不同的用户名在不同的浏览器选项卡之间发送消息,并看到所有消息都在所有选项卡上实时更新。

结论

本文介绍了如何使用 Mongoose 和 Socket.io 实现实时通知的示例。我们展示了如何使用 Mongoose 定义数据库模式,并通过 Socket.io 实现实时通知功能。通过执行这些操作,您可以创建任何需要实时通知的应用程序。

完整的示例代码可以在 Github 上找到。

来源:JavaScript中文网 ,转载请注明来源 本文地址:https://www.javascriptcn.com/post/6728b0092e7021665e213301