Server-Sent Events一种允许服务器向客户端发送实时更新的 Web API
Server-Sent Events(SSE)是一种允许服务器向客户端发送实时更新的 Web API。它基于 HTTP 协议,提供了一种单向的、服务器到客户端的通信机制,客户端可以通过监听服务器发送的事件来接收实时数据。下面从原理、使用场景、代码示例等方面进行详细介绍。
原理
- 连接建立:客户端通过创建一个
EventSource对象并指定服务器的 URL 来发起一个 HTTP 请求,建立与服务器的连接。这个连接是一个持久的、单向的 HTTP 连接,服务器可以随时向客户端发送数据。 - 数据发送:服务器以特定的格式(通常是
text/event-stream)向客户端发送事件流。每个事件由事件类型、数据和可选的 ID 组成,使用简单的文本格式进行编码。 - 事件监听:客户端通过监听
EventSource对象的不同事件(如message、open、error)来处理服务器发送的数据。当接收到新的事件时,会触发相应的事件处理函数。 - 重连机制:如果连接中断,
EventSource会自动尝试重新连接到服务器,确保数据的连续性。
使用场景
- 实时新闻更新:新闻网站可以使用 SSE 实时向用户推送最新的新闻文章。
- 股票行情:金融应用可以通过 SSE 实时更新股票价格和市场数据。
- 聊天应用:在聊天应用中,服务器可以使用 SSE 向客户端实时推送新消息。
- 监控系统:监控系统可以使用 SSE 实时向管理员发送服务器状态、性能指标等信息。
代码示例
下面是一个使用 Server-Sent Events 的简单示例,包括服务器端和客户端(使用 JavaScript)。
服务器端代码(go +gin)
// StreamChat 流式输出聊天信息
// @Summary 流式输出聊天信息
// @Description 流式输出聊天信息,客户端可以实时接收数据。
// @Tags Chat
// @Accept json
// @Produce text/event-stream
// @Success 200 {string} string "data: 1\n\n"
// @Router /web/StreamChat [get]
func (u ChatController) StreamChat(c *gin.Context) {// 设置响应头,指定内容类型为流式输出c.Writer.Header().Set("Content-Type", "text/event-stream")c.Writer.Header().Set("Cache-Control", "no-cache")c.Writer.Header().Set("Connection", "keep-alive")c.Writer.Header().Set("Access-Control-Allow-Origin", "*")// 循环输出 1 到 100 的数字for i := 1; i <= 100; i++ {// 发送数据c.Writer.Write([]byte("data: " + string(i+'0') + "\n\n"))// 刷新缓冲区,将数据发送给客户端c.Writer.(http.Flusher).Flush()// 每隔 1 秒输出一个数字time.Sleep(time.Second)}}# Routers
web.GET("/StreamChat", func(c *gin.Context) {controllers.ChatController{}.StreamChat(c)})
客户端代码(HTML + JavaScript)
<!DOCTYPE html>
<html lang="en"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>Server-Sent Events Example</title>
</head><body><h1>Real-time Updates</h1><ul id="messages"></ul><script>const eventSource = new EventSource('/web/StreamChat');eventSource.onmessage = (event) => {const messagesList = document.getElementById('messages');const newMessage = document.createElement('li');newMessage.textContent = event.data;messagesList.appendChild(newMessage);};eventSource.onerror = (error) => {console.error('EventSource failed:', error);};</script>
</body></html>
代码解释
-
服务器端:设置响应头:在 streamNumbers 函数里,设置了一系列响应头,以此确保响应为流式输出,并且防止缓存。循环输出数字:借助 for 循环,从 1 到 100 输出数字,每次输出一个数字后,刷新缓冲区把数据发送给客户端。定时输出:使用 time.Sleep 函数,使每个数字的输出间隔为 1 秒。
-
客户端:创建一个
EventSource对象并监听/web/StreamChat事件,当接收到新的事件时,将事件数据添加到页面的列表中。同时监听error事件,处理连接错误。
优缺点
优点
- 简单易用:基于 HTTP 协议,使用简单,不需要复杂的握手和连接管理。
- 自动重连:客户端会自动处理连接中断和重连,确保数据的连续性。
- 文本格式:数据以文本格式传输,易于理解和处理。
缺点
- 单向通信:只能从服务器向客户端发送数据,不支持客户端向服务器发送数据。
- 浏览器兼容性:虽然现代浏览器大多支持 SSE,但在一些旧版本的浏览器中可能不支持。
- 性能开销:与 WebSocket 相比,SSE 的性能开销相对较大,因为它是基于 HTTP 协议的。
Server-Sent Events 是一种简单、易用的实时通信机制,适用于服务器向客户端单向推送实时数据的场景。
相关文章:
Server-Sent Events一种允许服务器向客户端发送实时更新的 Web API
Server-Sent Events(SSE)是一种允许服务器向客户端发送实时更新的 Web API。它基于 HTTP 协议,提供了一种单向的、服务器到客户端的通信机制,客户端可以通过监听服务器发送的事件来接收实时数据。下面从原理、使用场景、代码示例等…...
彻底解决VS2008编译错误:fatal error C1083 无法打开包括文件“stdint.h“
彻底解决VS2008编译错误:fatal error C1083 无法打开包括文件"stdint.h" 一、错误现象与本质原因 当在Visual Studio 2008中编译包含C99标准整数类型(如int8_t、uint32_t)的代码时,常出现以下编译错误: f…...
react从零开始的基础课
全文约5万字。 1.hello,.. // App.jsx import { useState } from react import reactLogo from ./assets/react.svg import viteLogo from /vite.svg import ./App.cssfunction App() {const [count, setCount] useState(0)return (<><Greeting name"world&qu…...
算法题型讲解
一.双指针 主要分为俩种类型: 1.左右指针:双指针指向开头,以一定标准移动或交换,对区域进行划分,或找到特殊点的位置 (如:快慢指针判断有无环,移动零) 2.对撞指针&am…...
操作主机的管理
1.在AD林范围内,有哪几个操作主机角色 架构主机(Schema Master) 功能:负责整个AD林中所有对象和属性的定义,是唯一可以更新目录架构的DC。架构更新会从架构主机复制到目录林中的所有其他域控制器。 作用范围…...
Redis和数据库一致性问题
操作模拟 1、先更新数据库还是先更新缓存? 1.1先更新缓存,再更新数据库 按并发的角度来说,有两个线程A、B,操作同一个数据,线程A先更新缓存为1,在线程A更新数据库之前,这时候线程B进来&#…...
第R8周:RNN实现阿尔茨海默病诊断(pytorch)
>- **🍨 本文为[🔗365天深度学习训练营]中的学习记录博客** >- **🍖 原作者:[K同学啊]** 本人往期文章可查阅: 深度学习总结 一、准备工作 🏡 我的环境: 语言环境:Python3.1…...
《穿透表象,洞察分布式软总线“无形”之奥秘》
分布式系统已成为众多领域的关键支撑技术,而分布式软总线作为实现设备高效互联的核心技术,正逐渐走入大众视野。它常被描述为一条“无形”的总线,这一独特属性不仅是理解其技术内涵的关键,更是把握其在未来智能世界中重要作用的切…...
C++基础精讲-02
文章目录 1.C/C申请、释放堆空间的方式对比1.1C语言申请、释放堆空间1.2C申请、释放堆空间1.2.1 new表达式申请数组空间 1.3回收空间时的注意事项1.4malloc/free 和 new/delete 的区别 2.引用2.1 引用的概念2.2 引用的本质2.3 引用与指针的联系与区别2.4 引用的使用场景2.4.1 引…...
【网络安全】Linux 命令大全
未经许可,不得转载。 文章目录 前言正文文件管理文档编辑文件传输磁盘管理磁盘维护网络通讯系统管理系统设置备份压缩设备管理其它命令前言 在网络安全工作中,熟练掌握 Linux 系统中的常用命令对于日常运维、日志分析和安全排查等任务至关重要。 以下是常用命令的整理汇总,…...
双相机结合halcon的条码检测
以下是针对提供的C#代码的详细注释和解释,结合Halcon库的功能和代码结构进行说明: --- ### **代码整体结构** 该代码是一个基于Halcon库的条码扫描类GeneralBarcodeScan,支持单台或双台相机的条码检测,并通过回调接口返回结果。…...
C++学习之ORACLE①
目录 1.ORACLE数据库简介 2..ORACLE数据库安装 3..ORACLE体系结构 4..ORACLE基本概念 5..ORACLE基本元素 6..ORACLE数据库启动和关闭 7.SQLPLUS登录ORACLE数据库相关操作 8.SQLPLUS的基本操作 9.oracle中上课使用的方案 10.SQL语言分类 11.SQL中的select语句语法和注…...
setInterval问题以及前端如何实现精确的倒计时
一、为什么setInterval不能实现 原因有两:1、js是单线程,基于事件循环执行其他任务(这里建议读者可以多去了解一下浏览器线程与事件循环相关知识) 2、setinterval是每隔delay时间,把逻辑放到任务队列中,而…...
企业级开发SpringBoost玩转Elasticsearch
案例 Spring Boot 提供了 spring-data-elasticsearch 模块,可以方便地集成 Elasticsearch。 下面我们将详细讲解如何在 Spring Boot 中使用 Elasticsearch 8,并提供示例代码。 1. 添加依赖: 首先,需要在 pom.xml 文件中添加 spring-data-e…...
从零开始的图论讲解(1)——图的概念,图的存储,图的遍历与图的拓扑排序
目录 前言 图的概念 1. 顶点和边 2. 图的分类 3. 图的基本性质 图的存储 邻接矩阵存图 邻接表存图 图的基本遍历 拓扑排序 拓扑排序是如何写的呢? 1. 统计每个节点的入度 2. 构建邻接表 3. 将所有入度为 0 的节点加入队列 4. 不断弹出队头节点,更新其…...
SpringBoot框架—启动原理
1.SpringBootApplication注解 在讲解启动原理之前先介绍一个非常重要的注解SpringBootApplication,这个注解在Springboot程序的入口文件Application.java中必须添加。SpringBootApplication是一个整合了三个核心注解的组合注解。 三个核心注解的作用机制࿱…...
Chapter 7: Compiling C++ Sources with CMake_《Modern CMake for C++》_Notes
Chapter 7: Compiling C Sources with CMake 1. Understanding the Compilation Process Key Points: Four-stage process: Preprocessing → Compilation → Assembly → LinkingCMake abstracts low-level commands but allows granular controlToolchain configuration (c…...
怎么检查网站CDN缓存是否生效
为什么要使用CDN缓存? 网站使用缓存可显著提升加载速度,减少服务器负载和带宽消耗,优化用户体验,增强架构稳定性,助力SEO优化,实现资源高效利用与性能平衡。 通过合理配置 CDN 缓存策略,可降低…...
【自然语言处理】深度学习中文本分类实现
文本分类是NLP中最基础也是应用最广泛的任务之一,从无用的邮件过滤到情感分析,从新闻分类到智能客服,都离不开高效准确的文本分类技术。本文将带您全面了解文本分类的技术演进,从传统机器学习到深度学习,手把手实现一套…...
vba讲excel转换为word
VBA将excel转换为word Sub ExportToWordFormatted() 声明变量Dim ws As Worksheet 用于存储当前活动的工作表Dim rng As Range 用于存储工作表的使用范围(即所有有数据的单元格)Dim rowCount As Long, colCount As Long 用于存储数据范围的行数和列数…...
ubuntu安装openWebUI和Dify【自用详细版】
系统版本:ubuntu24.04LTS 显卡:4090 48G 前期准备 先安装好docker和docker-compose,可以参考我之前文章安装: ubuntu安装docker和docker-compose【简单详细版】 安装openWebUI 先docker下载ollama docker pull ghcr.nju.edu.c…...
基于Flask的勒索病毒应急响应平台架构设计与实践
基于Flask的勒索病毒应急响应平台架构设计与实践 序言:安全工程师的防御视角 作为从业十年的网络安全工程师,我深刻理解勒索病毒防御的黄金时间法则——应急响应速度每提升1分钟,数据恢复成功率将提高17%。本文介绍的应急响应平台ÿ…...
Solidity基础入门—web3
Remix介绍 官网地址 Remix 是一个基于浏览器的 Solidity 开发环境,主要用于编写、测试、调试和部署以太坊智能合约。 Solidity基本数据类型 类型说明示例uint / int无符号 / 有符号整数uint256, int8, int256bool布尔类型(true / false)bo…...
spark数据清洗案例:流量统计
一、项目背景 在互联网时代,流量数据是反映用户行为和业务状况的重要指标。通过对流量数据进行准确统计和分析,企业可以了解用户的访问习惯、业务的热门程度等,从而为决策提供有力支持。然而,原始的流量数据往往存在格式不规范、…...
git commit时自动生成Change-ID
创建全局钩子目录: 创建一个全局的Git hooks目录: mkdir -p ~/.githooks 下载并设置commit-msg钩子脚本: 下载Gerrit的commit-msg钩子脚本,并放置在全局钩子目录中(如下载不了,可从本页面附件中下载,“…...
list的使用以及模拟实现
本章目标 1.list的使用 2.list的模拟实现 1.list的使用 在stl中list是一个链表,并且是一个双向带头循环链表,这种结构的链表是最优结构. 因为它的实现上也是一块线性空间,它的使用上是与string和vector类似的.但相对的因为底层物理结构上它并不像vector是线性连续的,它并没有…...
分布式防护节点秒级切换:实战配置与自动化运维
摘要:针对DDoS攻击导致节点瘫痪的问题,本文基于群联AI云防护的智能调度系统,详解如何实现节点健康检查、秒级切换与自动化容灾,并提供Ansible部署脚本。 一、分布式节点的核心价值 资源分散:攻击者难以同时击溃所有节…...
【今日三题】小乐乐改数字 (模拟) / 十字爆破 (预处理+模拟) / 比那名居的桃子 (滑窗 / 前缀和)
⭐️个人主页:小羊 ⭐️所属专栏:每日两三题 很荣幸您能阅读我的文章,诚请评论指点,欢迎欢迎 ~ 目录 小乐乐改数字 (模拟)十字爆破 (预处理模拟)比那名居的桃子 (滑窗 / 前缀和) 小乐乐改数字 (模拟) 小乐乐改数字…...
基于 Qt 的图片处理工具开发(一):拖拽加载与基础图像处理功能实现
一、引言 在桌面应用开发中,图片处理工具的核心挑战在于用户交互的流畅性和异常处理的健壮性。本文以 Qt为框架,深度解析如何实现一个支持拖拽加载、亮度调节、角度旋转的图片处理工具。通过严谨的文件格式校验、分层的架构设计和用户友好的交互逻辑&am…...
CentOS 7 yum 无法安装软件的解决方法
一、解决方法 1、备份原有的 CentOS 7 默认 YUM 源配置文件 mv /etc/yum.repos.d/CentOS-Base.repo /etc/yum.repos.d/CentOS-Base.repo.backup2、从阿里云镜像源下载 CentOS 7 的 YUM 源配置文件,并覆盖原有的配置文件 wget -O /etc/yum.repos.d/CentOS-Base.re…...
