使用 SSE 实现服务器与多个客户端实时通信

什么是 SSE

Server-Sent Events(SSE)是 HTML5 标准中一种不同于 WebSockets 的服务器推送技术。它允许服务器向客户端发送自定义消息,并通过长连接保持实时通信。与 WebSockets 不同的是,SSE 采用基于 HTTP 协议的简单机制,可在现有基础网络架构上实现实时通信,更适用于单向通信的场景。

SSE 能够提供以下特性:

  • 易于实现和部署
  • 实时推送事件流
  • 支持自定义事件类型
  • 只需要一个 HTTP 连接

SSE 原理

SSE 依赖于 HTTP 协议上的长轮询(Long Polling)技术。当客户端接收 SSE 事件流后,它会保持打开的 HTTP 连接,用来等待服务器端提供的事件。如果服务器端暂时没有事件能够发送给客户端,客户端就会阻塞并保持长连接。一旦服务器端有了新的事件,它就能够立即推送到客户端,这些事件就能通过 HTTP 响应发送到客户端。

浏览器支持 SSE

目前,主流的现代浏览器都已经支持 SSE 技术,包括 Chrome、Firefox、Opera、Safari 以及 Android 和 iOS 等移动设备浏览器。只有 Internet Explorer 不支持它。对于 IE 浏览器,我们可以使用 polyfill 库(如 EventSource.js)来实现 SSE 的支持。

使用 SSE 实现实时通信

下面通过一个简单的示例,展示如何使用 SSE 实现一个服务端向多个客户端推送事件的功能。

实现一个 SSE 服务器

首先,我们需要创建一个 SSE 服务器来向客户端推送事件。在 Node.js 环境下,我们可以使用 express 和 EventSource 模块来实现。

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

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

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

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

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

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

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

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

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

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

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

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

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

这段代码主要是实现一个 HTTP 服务, 客户端通过 /events 路径来连接 SSE 服务器。在连接时,服务器会向客户端发送一些元数据,告知客户端如何处理响应。同时,我们还为每个连接生成了一个唯一的 clientId,这样我们才能知道连接来自哪个客户端。

在客户端连接成功后,我们还需要从 /stream/:clientId 路径生成一个 SSE 流来向客户端推送事件。在这个例子中,我们简单地每隔 3 秒向客户端推送一条消息。

实现一个 SSE 客户端

接下来,我们需要实现一个 SSE 客户端来接收来自 SSE 服务器的事件。在浏览器中,我们可以使用 EventSource 接口来和 SSE 服务器建立连接,并接收来自服务器的推送事件。

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

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

这个 HTML 页面在客户端打开后,会向 /events 路径发送一个 GET 请求,创建一个 EventSource 对象来建立 SSE 连接,并监听 message 事件来获取服务器发送的消息。当收到新消息时,我们将它添加到页面中的一个无序列表中。

运行项目

在终端中输入以下命令来运行 SSE 服务器:

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

在浏览器中打开以下 URL,我们就能看到 SSE 客户端的页面:

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

现在我们就能在 SSE 客户端的页面上看到我们向客户端推送的事件流了。

总结

通过以上这个简单的例子,我们已经实现了一个 SSE 服务器和 SSE 客户端,并能够向多个客户端推送实时事件。使用 SSE 技术,我们能够在浏览器中实现单向实时通信,同时又能够避免使用 WebSockets 所需的握手协议和通信开销。

来源:JavaScript中文网 ,转载请联系管理员! 本文地址:https://www.javascriptcn.com/post/6481abd448841e989412822a


猜你喜欢

  • RESTful API 实现微服务间的通信

    随着微服务架构的流行,实现微服务间的通信变得越来越重要。RESTful API 是一种常见的实现微服务通信的方式。本文将介绍 RESTful API 的基本原理、实现方式以及如何在前端中使用它来实现微...

    1 年前
  • 如何在 Next.js 中处理表单

    在实现前端页面开发时,表单是一个非常重要的组件。而在 Next.js 中处理表单也很容易,下面就来介绍一下具体步骤。 1. 创建表单组件 首先,我们需要创建一个表单组件。

    1 年前
  • 在 JavaScript 中用 ES8 async/await 实现网页爬虫

    现如今,互联网已经成为人们获取各类信息的主要渠道,网站的数量也在不断地增长,这就给网络爬虫带来了很大的挑战。网页爬虫相当于网络中的“蚂蚁”,可以在网络上爬行收集数据,可以应用于搜索引擎、数据分析、人工...

    1 年前
  • 解决 Mongoose update 方法不起作用的问题

    Mongoose 是一种使用 Node.js 进行 MongoDB 数据库操作的工具,为开发者提供了便捷的数据操作方式。在使用 Mongoose 进行数据更新时,我们通常会使用 update 方法。

    1 年前
  • MongoDB 中使用 $unwind 将数组拆分的方法详细介绍

    在 MongoDB 中,$unwind 是一种非常有用的操作符,它可以将文档中的数组拆分成单独的文档。此操作符常常用于对数据进行分组和筛选,能够使查询更加灵活和高效。

    1 年前
  • Performance Optimization:使用 Travis CI 加速 CI/CD 流程

    在当前的软件开发行业中,快速迭代、快速交付已经成为了一种必备的能力。而如何快速测试和部署软件代码也成为了一个重要的挑战。Travis CI 作为一个持续集成和部署的工具,可以大大地提高开发人员的工作效...

    1 年前
  • PWA 开发中的文件和图片资源管理

    PWA 技术已经成为现代 Web 开发的一个重要方向,它将 Web 应用与原生应用相融合,在离线缓存、离线加载、响应式设计等方面具有很大的优势。在 PWA 开发中,文件和图片资源的管理是一个常见的问题...

    1 年前
  • Mocha 脚本运行过程中如何跳过某些测试用例

    在进行前端开发中,我们经常需要写一些测试用例来确保代码的质量和正确性。Mocha 是一个非常流行的 JavaScript 测试框架,它可以让我们轻松地编写和运行测试用例。

    1 年前
  • 如何在 Node.js 中使用 WebSocket 实现实时消息传递

    介绍 WebSocket 是一种网络协议,用于在客户端和服务器之间进行即时的、双向的通信。在传统的 HTTP 请求-响应模式中,要实现实时消息传递需要采用轮询或者长轮询等技术,这种方式效率低下且不符合...

    1 年前
  • Angular 中如何使用 RxJS

    随着现代 Web 应用程序趋向于复杂和交互性,前端框架及工具也在不断发展,以满足应用程序的需求。Angular 是其中一个受欢迎的框架,它提供了许多功能和工具,以快速构建现代 Web 应用程序。

    1 年前
  • Redux 和 React 之间的简单数据交流

    Redux 和 React 都是前端开发中非常流行的技术,它们各自的特点和优势让它们被大量使用。在 React 应用中,为了实现组件之间的数据共享,Redux 的出现让这项工作变得更加方便,同时增强了...

    1 年前
  • Kubernetes 监控之 Prometheus+Grafana 搭建教程

    前言 随着云原生和 Kubernetes 的发展,Kubernetes 监控变得越来越重要。而 Prometheus 和 Grafana 组合,已成为目前最受欢迎的 Kubernetes 监控方案之一...

    1 年前
  • Promise 和 setTimeout 异步执行的不同方式

    Promise 和 setTimeout 异步执行的不同方式 在前端开发中,经常会遇到需要异步执行代码的情况,这时我们通常会使用 Promise 或 setTimeout 进行异步处理。

    1 年前
  • 如何在 Express.js 中使用静态文件夹进行网站部署?

    在前端开发中,网站的部署是非常重要的一环。可以有多种方式来实现网站的部署,其中使用静态文件夹进行部署是常用的一种方式。这种方式可以使网站的访问速度更快、更稳定,同时也更为安全。

    1 年前
  • 在 Fastify 框架中使用 RabbitMQ 实现消息队列的方法

    消息队列在分布式系统中扮演着重要的角色,它能够将异步的任务分离出来,提高整个系统的反应速度和可靠性。在 Node.js 的开发中,RabbitMQ 是一种流行的消息队列解决方案,它能够提供高效的消息传...

    1 年前
  • Sequelize ORM之基础知识介绍

    前言 Sequelize是一个基于Node.js的ORM(Object-Relational Mapping)框架,它能够方便的操作数据库,将关系型数据库中的数据映射成对象的形式,提供了面向对象的数据...

    1 年前
  • 如何使用 ES11 中的 BigInt 类型来处理大数?

    在前端开发中,我们通常处理的数值是比较小的,比如整型、浮点型等。但是有时候我们需要处理比较大的整数,这时候 JavaScript 自带的 Number 类型就无法胜任了。

    1 年前
  • ES12 中的 Object.fromEntries 解决对象转化问题

    ES12 中的 Object.fromEntries 解决对象转化问题 在前端开发中,经常需要对对象做转化操作。但是,JavaScript 中原生的对象转化方法比较有限,不够直观和方便。

    1 年前
  • webpack 中 chunk 的理解以及如何按需加载

    在前端工程化中,webpack 是非常常用的工具之一。它提供了许多优秀的特性,其中 chunk 又是一个非常重要的概念。本文将详细介绍 webpack 中 chunk 的概念以及如何按需加载。

    1 年前
  • Serverless 遇到内存溢出错误怎么办?

    Serverless 架构中,函数是按需调用、深度扩缩容的资源抽象单元,将代码运行的计算能力与底层的基础设施完全分离。但是,函数在运行时往往会遇到各种问题,比如内存溢出错误。

    1 年前

相关推荐

    暂无文章