在 Express 中使用 Server-Sent Events 实现实时通信

面试官：小伙子，你的数组去重方式惊艳到我了

引言

在前端开发中，实时通信是一个非常重要的功能。一般情况下，我们使用 WebSocket 或 SockJS 来实现实时通信。但是，如果你只需要一个简单而轻巧的解决方案，那么使用 Server-Sent Events（SSE）是一个不错的选择。

本文将介绍如何在 Express 中使用 SSE 实现实时通信。我们将从介绍 SSE 的基本概念开始，然后深入讲解如何在 Express 中实现 SSE，最后展示一个完整的示例代码。

SSE 简介

Server-Sent Events 是一种典型的事件流协议。客户端通过 HTTP 连接到服务器，并保持长连接，服务器会定期发送新的数据给客户端。与 WebSocket 不同的是，SSE 仅支持从服务器到客户端的单向通信，也就是客户端不能向服务器发送数据。

SSE 允许在一个 HTTP 连接上按照事件流的形式发送文本数据。事件流以一个标识符开头，这个标识符定义了事件的类型。在这个事件类型之后，可以添加任意名称/值的属性。最后是一个空行，然后是数据本身。下面是一个 SSE 事件流的示例：

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

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

在这个例子中，我们定义了两个事件。第一个事件类型为“myEvent”，带有一个 ID 属性为“123”，数据为一个包含一个“hello”键和一个“world”值的 JSON 对象。第二个事件类型为“anotherEvent”，没有 ID 属性，数据是一个简单的字符串。

在 Express 中实现 SSE

要在 Express 中实现 SSE，我们需要使用一个名为 sendEvent 的中间件。该中间件将设置正确的响应头并启用响应流模式：

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

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

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

这个中间件使用 text/event-stream 来设置响应类型并设置 Cache-Control 和 Connection 响应头。然后，我们为每个新的 SSE 客户端创建一个新的客户端对象，并将其添加到用户列表中。最后，我们定义关闭事件处理程序，以便在客户端关闭连接时从用户列表中删除客户端对象。

接下来，我们可以定义一个路由处理程序，用于向 SSE 客户端发送事件。我们通过广播函数来同时向所有客户端发送事件：

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

我们使用 res.write 函数将数据发送到客户端。请注意，在数据后面添加了两个换行符，这是 SSE 事件流的一部分。

最后，我们可以定义一个路由来处理使用 SSE 的客户端的请求：

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

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

在这个路由处理程序中，我们使用 sendEvent 中间件来设置响应头并将客户端添加到客户端列表中。然后，我们使用 res.flushHeaders 函数确保响应头立即发送。接着，我们通过 broadcast 函数向所有客户端发送消息。

最后，我们设置一个间隔，每 2 秒向所有客户端发送一个新事件。当客户端关闭连接时，我们清除该间隔。

示例代码

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

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

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

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

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

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

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

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

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

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

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

结论

在本文中，我们介绍了 Server-Sent Events（SSE）的基本概念，并详细讲解了如何在 Express 中使用 SSE 实现实时通信。我们使用 sendEvent 中间件设置 SSE 响应头并将客户端添加到客户端列表中。然后，我们通过广播函数向所有客户端发送消息。最后，我们展示了一个完整的示例代码，演示了如何在 Express 中使用 SSE。

来源：JavaScript中文网 ，转载请联系管理员！ 本文地址：https://www.javascriptcn.com/post/6703a9e4d91dce0dc84c050c

阅读全文

猜你喜欢

  • Sequelize，Node.js 和 MySQL：基本查询

    前言 随着互联网时代的不断发展，Web 应用程序越来越复杂。前端技术框架如雨后春笋一般迅速发展，提供了更快速、简单、灵活、可复用的开发方式。为了满足复杂的业务需求，后端技术也需要不断向前发展，因为 W...

    14 天前
  • Serverless 架构：优点和缺点

    在构建 Web 应用程序时，Serverless 架构是一个越来越流行和引人注目的选择。由于它的优点和独特性，并且它的云供应商现在提供越来越多的Serverless服务。

    14 天前
  • 如何在 Deno 中实现自动部署

    在当今的软件开发环境中，自动化部署已经变得非常重要。通过自动化部署，可以加快软件的开发周期并确保产品的质量和稳定性。在本文中，我们将讨论如何在 Deno 中实现自动部署。

    14 天前
  • ES6增强了什么？开发者应该如何学习

    ES6是ECMAScript的第6个版本，全称为ECMAScript 2015。它是JavaScript语言的一次巨大升级，引入了许多新特性和语法糖，使得前端开发变得更加灵活、高效、易于维护。

    14 天前
  • 无障碍测试与修复技术

    前言 如今，随着科技的不断发展，我们的生活已经开始了数字化转型之路，同时也给了很多残障人士更多的机会融入这个数字化的世界。但是，由于网络产品设计和开发者的知识和资历不同，导致其无法在使用辅助技术辅助下...

    14 天前
  • ECMAScript2019 (ES10) 和 ES2020 (ES11) 的新功能详解

    自从JavaScript成为前端开发的主流技术后，一直在不断地更新和升级。ECMAScript是JavaScript的标准，而ES10和ES11是最新的版本，引入了一些新的功能和特性。

    14 天前
  • Mongoose 中使用 $pull 方法删除数组类型数据相关记录

    在 MongoDB 中，可以使用数组类型数据记录相关信息。在 Mongoose 中，可以使用 $pull 方法删除这些信息。本篇文章将详细介绍 $pull 方法的用法和示例代码，以帮助开发者更好地应用...

    14 天前
  • MongoDB 集群环境的搭建与维护

    简介 MongoDB 是目前非常流行的 NoSQL 数据库，在 web 开发和大数据领域应用广泛。在大数据和高并发的情况下，为了保证数据安全和可用性，我们需要搭建 MongoDB 集群环境。

    14 天前
  • 响应式设计中的清除浮动问题及方案

    在进行响应式设计时，通常都会遇到浮动元素引起的问题。在使用浮动元素时，需要注意浮动元素的位置和大小，否则页面布局可能会出现混乱的情况。为了避免这种情况，我们需要在浮动元素后面加上清除浮动。

    14 天前
  • Docker 容器中如何安装 PostgreSQL？

    前言 在前端开发过程中，我们经常需要使用到各种数据库，比如 PostgreSQL。而在使用 Docker 搭建开发环境时，我们需要在容器中安装 PostgreSQL。

    14 天前
  • 为什么选择 Serverless 架构？

    随着云计算的发展，越来越多的企业开始关注 Serverless 架构。Serverless 架构是一种全新的应用架构模型，具有许多优点，如可扩展性、高可用性、低成本等。

    14 天前
  • 使用 TypeScript 编写 RESTful API 时遇到的坑和解决方案

    在开发 RESTful API 的过程中，使用 TypeScript 可以大大提高代码的可读性、可维护性和健壮性。但是，我们也会遇到一些坑点。在本文中，我们将分享一些在编写 TypeScript 中 ...

    14 天前
  • Cypress 测试 React 应用时如何模拟异步数据

    在前端开发的过程中，我们经常会遇到需要模拟异步数据来测试页面展示的情况。针对 React 应用，Cypress 提供了多种方法来模拟异步数据，使得我们的测试能够更加健壮可靠。

    14 天前
  • 如何使用 ES12 的 for-await-of 来处理异步 Iterable

    随着前端应用变得越来越复杂，异步编程（asynchronous programming）已成为非常重要的一部分，但在使用 Promise、async/await 等异步编程技术时也会遇到一些问题，例如...

    14 天前
  • 如何在 CSS Flexbox 布局中实现图文混排

    CSS Flexbox 布局是一种流行的前端布局技术，可以轻易地实现自适应、可伸缩的布局，同时也支持图文混排。本文将详细介绍如何在 Flexbox 布局中实现图文混排，并提供示例代码和实践指导，帮助读...

    14 天前
  • 无障碍演示技巧

    随着互联网的不断发展和普及，越来越多的人使用互联网进行学习、娱乐和工作等。但是有一类人群却面临着障碍，他们是视觉障碍者、听觉障碍者以及行动障碍者等。为了让我们的网站和应用更具包容性，我们需要考虑到障碍...

    14 天前
  • 如何在 Jest 测试中模拟简单重定向

    当开发一个前端应用时，我们需要经常测试我们的代码。针对每个组件和功能进行测试可以帮助我们确保应用程序正常工作，并且随时可以检测到和修复错误。在现代的前端应用程序中，我们通常使用 Jest 作为我们的测...

    14 天前
  • 经验分享：如何在 Webpack 中构建 Web Components？

    Web Components 是一种浏览器的原生组件，有着许多优秀的特性，包括封装、复用、解耦等。在现今的 Web 开发中越来越受到开发者们的关注和使用。 Webpack 作为前端领域最受欢迎的模块打...

    14 天前
  • 如何使用 JProfiler 进行 Java 程序性能分析与调优

    随着Web应用程序越来越复杂和庞大，优化程序的性能变得日益重要。 JProfiler是一款功能强大的Java性能分析器，可以帮助您找出性能问题，并提供有用的信息来改进您的代码。

    14 天前
  • 使用 Fastify 和 PostgreSQL 的 RESTful API 教程

    近年来，随着前端技术的飞速发展，越来越多的人开始热衷于开发 RESTful API。使用 Fastify 和 PostgreSQL 结合开发 RESTful API 成为了一种常见的方式。

    14 天前

相关推荐

    暂无文章