在现代 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。
mkdir real-time-notification-chat cd real-time-notification-chat npm init -y npm i mongoose socket.io
接下来,我们需要连接到 MongoDB 数据库。在此示例中,我们将在本地运行 MongoDB。为了连接到 MongoDB 数据库,我们需要在 Node.js 代码中添加以下代码:
const mongoose = require('mongoose'); mongoose.connect('mongodb://localhost/chat', { useNewUrlParser: true });
在本示例中,我们命名数据库为 "chat"。您可以根据自己的需要更改数据库的名称和 MongoDB 的连接 URL。
现在,我们需要定义一个简单的消息模式。以下是一个基本的消息模式的示例:
-- -------------------- ---- ------- ----- ------------- - --- ----------------- ----- - ----- ------- --------- ----- ----- ---- -- -------- - ----- ------- --------- ----- ----- ---- -- ---------- - ----- ----- -------- -------- - --- ----- ------- - ------------------------- ---------------
现在,我们可以使用 Mongoose 模型来执行插入、更新和删除操作。
接下来,我们需要使用 Socket.io 库来实现实时通知。以下是创建 Socket.io 服务器的代码示例:
-- -------------------- ---- ------- ----- ---- - ---------------- ----- --- - --------------------- ----- ------ - ----------------------- ----- -- - ----------------------------- ------------------- -------- -- - -------------- ---- ------------ --- ------------------- -- -- - ---------------------- -- --------- ---
在上面的代码中,我们使用了 Express 库来创建 Web 服务器,并将其传递给 Socket.io 服务器。
现在,我们需要添加一些代码以实现发送和接收消息。以下是扩展 Socket.io 服务器的代码:
-- -------------------- ---- ------- ------------------- -------- -- - -------------- ---- ------------ -------------------- ------ -- - ----- ------- - --- -------------- ------------------ -- - -- ----- - ------------------- - ---- - ------------------ ------ - --- --- ---
在上述代码中,我们通过 Socket.io 监听客户端的 message
事件。当客户端发送新的消息时,我们创建一个新的消息对象,并将其保存到 MongoDB 数据库中。
如果存在任何错误,我们将在控制台上打印错误。如果一切顺利,我们将使用 io.emit()
方法向所有连接到聊天室的客户端发送一个 message
事件和数据对象。
接下来,我们需要更新客户端代码以实现接收实时通知的功能。以下是客户端 Socket.io 代码示例:
const socket = io(); socket.on('message', (data) => { console.log(data); });
上述代码将客户端连接到 Socket.io 服务器,并监听 message
事件。当服务器发送新消息时,客户端将在控制台上打印数据对象。
现在,我们可以开始测试我们的应用程序了。运行以下命令来启动服务器:
node app
然后在浏览器中打开两个或多个选项卡,并使用以下代码将客户端 JavaScript 包含在 HTML 页面中:
-- -------------------- ---- ------- ------- --------------------------------------- -------- ----- ------ - ----- --------------------------------------------------------- ------- -- - ----------------------- ----- --------- - ------------------------------------------- ----- ------------ - ---------------------------------------------- ----- ---- - ----------------------- ----- ------- - -------------------------- -- ----- -- -------- - ---------------------- - ----- ------- --- --------------- - --- ------------------ - --- - --- -------------------- ------ -- - ----- ------------ - ------------------------------------ ----- ------- - ----------------------------- ------------------- - -------------- ----------------- ---------------------------------- --- --------- ------ ------ ----------- ----------- ----------------- ------ ------ ----------- -------------- ----------------- --------- --------------------- ------- --- ----------------------
现在,您可以使用不同的用户名在不同的浏览器选项卡之间发送消息,并看到所有消息都在所有选项卡上实时更新。
结论
本文介绍了如何使用 Mongoose 和 Socket.io 实现实时通知的示例。我们展示了如何使用 Mongoose 定义数据库模式,并通过 Socket.io 实现实时通知功能。通过执行这些操作,您可以创建任何需要实时通知的应用程序。
完整的示例代码可以在 Github 上找到。
来源:JavaScript中文网 ,转载请注明来源 https://www.javascriptcn.com/post/6728b0092e7021665e213301