在 Web 应用程序中使用 SSE（Server-Sent Events） 可以实现服务器向客户端推送数据，而不需要客户端轮询服务器。这种方式更加实时、可靠且性能更好比起轮询和长轮询等方式。在本篇文章中，我们将介绍如何使用 Express 和 MongoDB 实现 SSE 服务器。
准备工作
在开始之前，我们需要准备以下工具和环境：
- 安装 Node.js
- 安装 MongoDB
- 一个文本编辑器，如 VS Code
初始化项目
首先，我们需要创建一个新的 Node.js 项目。打开命令行，输入以下命令：
mkdir sse-server && cd sse-server npm init -y
然后，我们需要安装 Express 和相关的依赖，包括 cors、body-parser 和 mongoose:
npm install express cors body-parser mongoose --save
以上步骤完成后，我们需要新建一个入口文件 index.js ，并引入所需的依赖：
const express = require('express');
const cors = require('cors');
const bodyParser = require('body-parser';
const mongoose = require('mongoose');配置 MongoDB
我们需要在本地环境下安装和启动 MongoDB，如果您没有安装，可以在官网进行下载和安装。启动 MongoDB，输入以下命令：
mongod
然后，我们需要为 SSE 创建一个新的 MongoDB 数据库，用于存储与 SSE 相关的数据，比如消息。创建一个新的数据库：
mongo use sse
配置 express
我们需要配置 Express 应用程序，以便 SSE 能够与客户端进行通信。这里我们需要引入需要的依赖（上一步已完成），并添加以下代码：
const app = express();
app.use(cors());
app.use(bodyParser.urlencoded({extended: false}));
app.use(bodyParser.json());创建消息模型
我们需要创建一个模型来定义 SSE 服务器中的消息。在 models/message.js 中，定义如下：
-- -------------------- ---- -------
----- -------- - --------------------
----- ------ - ----------------
----- ------------- - --- --------
----- -------
-- ------------ -------
-------------- - ------------------------- ---------------创建 SSE 服务器
接下来，我们需要创建 SSE 服务器，并且为客户端提供一个路由来连接 SSE 服务器。在 routes/sse.js 中，定义如下：
-- -------------------- ---- -------
----- ------- - -------------------
----- ------ - -----------------
----- ------- - -----------------------------
--------------------- ----- ----- ---- -- -
------------------ -
--------------- --------------------
---------------- -----------
------------- ------------
---
----- -------- - ----- --------------------------------- -------------------
--- ------ ------- -- --------- -
---------------- ---------------------------------
-
----- ---------- - ----- ----------------------------
----- ------------ - --------------------------- ---------------
--------------------------------- ----- ------ -- -
-- ------------------- --- --------- -
----- ------- - ----- ---------------------------------------
---------------- ---------------------------------
-
---
--------------- -- -- -
-------------------
---
---
-------------- - -------路由和启动应用
最后，我们需要在 index.js 创建路由，并且启动应用程序：
-- -------------------- ---- -------
----- --------- - ------------------------
--------------- -----------
------------------------------------------- ----------------- ----- ------------------- -------------- -- -
--------------------- -------------
---------------- -- -- -
------------------- ------- -- ---- -------
---
---现在，通过访问 http://localhost:3000/sse/stream，我们可以与 SSE 服务器建立连接，并且接收来自服务器的消息。
总结
在本篇文章中，我们介绍了使用 Express 和 MongoDB 实现 SSE 服务器的全流程，从初始化项目、配置 MongoDB、配置 Express、创建消息模型，到创建 SSE 服务器。并且我们可以通过 SSE 实现向客户端实时推送有用的信息和数据，以此更好地提高应用程序的性能和响应。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64635fdf968c7c53b0467b14