当前位置：首页 > news >正文

EventSource和websocket该用哪种技术

news 2026/2/9 14:19:09

EventSource（也称为Server-Sent Events, SSE）和WebSocket都是实现实时通信的技术，但是它们的设计目的和使用场景有所不同。在选择使用哪种技术时，需要根据具体的应用需求来决定。下面是一些关键点，可以帮助你做出选择：

EventSource (SSE)

单向通信：SSE 是一种服务器向客户端推送数据的机制，只能实现从服务器到客户端的单向通信。
简单性：相比 WebSocket，SSE 更加简单易用，不需要额外的握手过程，只需要一个标准的 HTTP 请求。
自动重连：SSE 内置了重连机制，当连接断开时可以自动尝试重新建立连接。
文本数据：SSE 只支持文本数据的传输，通常是以 UTF-8 编码的。
HTTP 协议：基于 HTTP/1.1 协议，可以很好地与现有的 HTTP 基础设施集成。
适用场景：适用于需要服务器向客户端发送更新或通知的场景，如股票价格更新、新闻推送等。

WebSocket

双向通信：WebSocket 支持全双工通信，允许客户端和服务器之间互相发送数据。
复杂性：WebSocket 需要一个特殊的握手过程来建立连接，比 SSE 更加复杂。
数据类型：支持二进制数据和文本数据的传输，更加灵活。
协议独立：虽然 WebSocket 通常通过 HTTP 进行初始握手，但一旦连接建立，它就不再受限于 HTTP，可以用于任何类型的网络应用。
适用场景：适用于需要频繁双向通信的应用，如在线游戏、实时聊天应用等。

如何选择

如果应用需要简单的服务器到客户端的数据推送，且对数据格式没有特殊要求（即可以接受文本格式），那么 SSE 是一个轻量级且易于实现的选择。
如果应用需要更复杂的双向通信，或者需要传输二进制数据，那么 WebSocket 更适合，尽管它的实现会相对复杂一些。
考虑现有基础设施：如果你的应用已经大量依赖于 HTTP 协议，那么使用 SSE 可能会更加方便，因为它本身就是基于 HTTP 的。相反，如果你的应用需要更强大的功能，WebSocket 提供了更多的可能性。

下面是一些使用 Node.js 实现 EventSource (SSE) 和 WebSocket 的示例。

1. 使用 `EventSource` (SSE)

服务器端 (Node.js)

首先，安装必要的依赖：

npm install express

然后创建一个简单的 Express 服务器来发送服务器发送事件 (SSE)：

const express = require('express');
const app = express();
const port = 3000;app.get('/events', (req, res) => {res.setHeader('Content-Type', 'text/event-stream');res.setHeader('Cache-Control', 'no-cache');res.setHeader('Connection', 'keep-alive');const sendEvent = (data) => {res.write(`data: ${JSON.stringify(data)}\n\n`);};// 模拟每隔两秒发送一次事件const intervalId = setInterval(() => {sendEvent({ message: 'Hello, SSE!', timestamp: new Date().toISOString() });}, 2000);// 当客户端断开连接时清理资源req.on('close', () => {clearInterval(intervalId);res.end();});
});app.listen(port, () => {console.log(`Server is running on http://localhost:${port}`);
});

客户端 (HTML + JavaScript)

创建一个简单的 HTML 文件来接收并显示 SSE 事件：

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>SSE Example</title>
</head>
<body><h1>Server-Sent Events</h1><div id="messages"></div><script>const eventSource = new EventSource('/events');eventSource.onmessage = function(event) {const data = JSON.parse(event.data);const messagesDiv = document.getElementById('messages');const messageElement = document.createElement('p');messageElement.textContent = `${data.message} at ${data.timestamp}`;messagesDiv.appendChild(messageElement);};eventSource.onerror = function(error) {console.error('EventSource failed:', error);};</script>
</body>
</html>

2. 使用 `WebSocket`

服务器端 (Node.js)

首先，安装必要的依赖：

npm install express ws

然后创建一个简单的 Express 服务器并集成 WebSocket：

const express = require('express');
const { Server } = require('ws');
const app = express();
const http = require('http');
const port = 3000;const server = http.createServer(app);
const wss = new Server({ server });wss.on('connection', (ws) => {console.log('Client connected');ws.on('message', (message) => {console.log('Received:', message);ws.send(`Echo: ${message}`);});ws.on('close', () => {console.log('Client disconnected');});// 模拟每隔两秒发送一次消息const intervalId = setInterval(() => {ws.send(JSON.stringify({ message: 'Hello, WebSocket!', timestamp: new Date().toISOString() }));}, 2000);ws.on('close', () => {clearInterval(intervalId);});
});app.get('/', (req, res) => {res.sendFile(__dirname + '/index.html');
});server.listen(port, () => {console.log(`Server is running on http://localhost:${port}`);
});

客户端 (HTML + JavaScript)

创建一个简单的 HTML 文件来连接 WebSocket 并显示消息：

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>WebSocket Example</title>
</head>
<body><h1>WebSocket Example</h1><div id="messages"></div><script>const socket = new WebSocket('ws://localhost:3000');socket.onopen = function() {console.log('Connected to WebSocket server');};socket.onmessage = function(event) {const data = JSON.parse(event.data);const messagesDiv = document.getElementById('messages');const messageElement = document.createElement('p');messageElement.textContent = `${data.message} at ${data.timestamp}`;messagesDiv.appendChild(messageElement);};socket.onclose = function() {console.log('Disconnected from WebSocket server');};socket.onerror = function(error) {console.error('WebSocket error:', error);};// 发送消息到服务器document.addEventListener('DOMContentLoaded', () => {const sendMessageButton = document.createElement('button');sendMessageButton.textContent = 'Send Message';document.body.appendChild(sendMessageButton);sendMessageButton.addEventListener('click', () => {socket.send('Hello, Server!');});});</script>
</body>
</html>

总结

EventSource (SSE)：适用于简单的服务器到客户端的数据推送，实现简单，维护成本低。
WebSocket：适用于需要双向通信的场景，功能强大，但实现相对复杂。

EventSource和websocket该用哪种技术

EventSource（也称为Server-Sent Events, SSE）和WebSocket都是实现实时通信的技术，但是它们的设计目的和使用场景有所不同。在选择使用哪种技术时，需要根据具体的应用需求来决定。下面是一些关键点，可以帮助你做出选择&…...

编程日记 2024/10/9 13:18:23

通信工程学习：什么是三网融合

三网融合三网融合，又称“三网合一”，是指电信网、广播电视网、互联网在高层业务应用上的深度融合。这一概念在近年来随着信息技术的快速发展而逐渐受到重视，并成为推动信息化社会建设的重要力量。以下是对三网融合的详细解释： 一…...

编程日记 2024/10/9 13:16:20

自定义类型结构体(上)

目录结构体类型的声明结构体的概念结构体的声明特殊的声明结构的自引用结构体变量的创建和初始化结构成员访问操作符结构体类型的声明结构体的概念结构体是一些值的集合，这些值称为成员变量。结构的每个成员可以是不同类型的变量举个例子:杰克的英语只考了6…...

编程日记 2024/10/9 13:14:19

b站-湖科大教书匠】4 网络层 - 计算机网络微课堂

【b站-湖科大教书匠】4 网络层 - 计算机网络微课堂_湖科大的计算机网络网课-CSDN博客...

编程日记 2024/10/9 13:13:17

国际 Android WPS Office v18.13 解锁版

WPS Office 移动版，设计不断优化，性能再次提升！融入Google Android最新设计标准，Material Design设计风格，完美支持沉浸式！简化文档操作，全新移动办公力作。全新界面更清晰舒适，功能…...

编程日记 2024/10/9 13:11:15

【中间件学习】Git的命令和企业级开发

一、Git命令 1.1 创建Git本地仓库仓库是进行版本控制的一个文件目录。我们要想对文件进行版本控制，就必须创建出一个仓库出来。创建一个Git本地仓库对应的命令是 git init ，注意命令要在文件目录下执行。 hrxlavm-1lzqn7w2w6:~/gitcode$ pwd /home/hr…...

编程日记 2024/10/9 13:08:11

FTP连接池与多线程FTP上传下载算法（Java）

设计一个能够处理FTP连接池在多线程环境下，尤其是涉及到故障重连时避免竞争条件的算法，需要综合考虑线程同步、连接状态管理和重试机制。以下是一个设计思路和实现方案：设计思路连接池管理：维护一个连接池，其中包含多个FTP连接对象。每个FTP连接对象需有状态标记（如…...

编程日记 2024/10/9 13:05:09

Spring Cloud微服务详解

Spring Cloud微服务详解在当今的数字化时代，微服务架构已成为构建大型、复杂应用系统的主流方式。Spring Cloud，作为微服务领域的一颗璀璨明星，以其强大的功能和灵活的架构，吸引了无数开发者的目光。本文将深入探讨Spring Cloud…...

编程日记 2024/10/9 13:00:03

QT学习笔记1.2（QT的应用）

QT原生用于c的开发， 主要应用于电脑、桌面手机桌面软件的开发，主要是widget样式模板。 Qt Widgets、Qt Quick 和 Qt for Python 是 Qt 框架中的三种不同的技术，分别用于不同的应用场景。以下是它们的详细介绍和对比： 1. Qt Widg…...

编程日记 2024/10/9 12:59:01

数学建模算法与应用第1章线性规划

第1章线性规划线性规划是数学规划领域的重要分支，广泛应用于资源配置、生产计划、物流管理等领域。它主要用于解决如何在满足一定约束条件下，使目标函数（如成本、利润等）达到最大或最小的问题。第一章将介绍线性规划的基本概念…...

编程日记 2024/10/9 12:58:00

使用 systemd 设置 PHP 程序为服务

使用 systemd 设置 PHP 程序为服务在现代 Linux 系统中，systemd 是用于管理和控制服务的标准工具。通过 systemd，我们可以轻松地将 PHP 程序配置为后台运行的系统服务，从而实现自动化启动、重启和日志记录等功能。本文将介绍如何为 PHP 程序…...

编程日记 2024/10/9 12:56:59

HRNET模型实现钢板表面缺陷检测

关于深度实战社区我们是一个深度学习领域的独立工作室。团队成员有：中科大硕士、纽约大学硕士、浙江大学硕士、华东理工博士等，曾在腾讯、百度、德勤等担任算法工程师/产品经理。全网20多万粉丝，拥有2篇国家级人工智能发明专利。社区特色…...

编程日记 2024/10/9 12:54:50

28 基于51单片机的两路电压检测(ADC0808)

目录一、主要功能二、硬件资源三、程序编程四、实现现象一、主要功能基于51单片机，通过ADC0808获取两路电压，通过LCD1602显示二、硬件资源基于KEIL5编写C代码，PROTEUS8.15进行仿真，全部资源在页尾，提供…...

编程日记 2024/10/9 12:51:47

SpringBootTest Mockito 虚实结合编写测试

SpringBootTest & Mockito 虚实结合测试起因单一使用mockito，会出现很多mock困难的问题，导致测试编写过程太长，太恶心单一使用springboottest，会遇到需要外部接口的地方，这个时候就非得去真实调用才行。也很恶…...

编程日记 2024/10/9 12:50:45

国内外网络安全政策动态（2024年9月）

国内网络安全政策动态 ▶︎ 1.三项智能网联汽车强制性国家标准正式发布 9月4日，工业和信息化部组织制定的GB 44495—2024《汽车整车信息安全技术要求》、GB 44496—2024《汽车软件升级通用技术要求》和GB 44497—2024《智能网联汽车自动驾驶数据记录系统》三项强制…...

编程日记 2024/10/9 12:48:44

使用Android studio进行Unit Test中遇到的问题记录

1、模块本身代码运行不起来提示： Cannot resolve method ‘getVolumes’ in ‘StorageManager’ Cannot resolve method ‘registerListener’ in ‘StorageManager’ Cannot resolve method ‘unregisterListener’ in ‘StorageManager’ 查看Android 源码&…...

编程日记 2024/10/9 12:46:41

智能运维与问题诊断工具：提升生产环境的安全稳定性

引言在当今复杂的IT环境中，确保生产系统的安全稳定运行是一项巨大挑战。随着技术的进步，智能运维和问题诊断工具应运而生，为IT团队提供了强大的支持。本文将介绍一系列先进的工具，这些工具利用人工智能、机器学习和自动化技术，帮助组织提高系统可靠性、加速问题解决、优…...

编程日记 2024/10/9 12:43:38

【MAUI】CommunityToolkit社区工具包介绍

一、为什么需要声明式开发 .NET的MVVM，始于WPF，很古典，它甚至可能是现代前端框架“声明式开发”的鼻祖。声明式开发，之所以出现，是因为命令式开发在UI层和代码层上无法解耦的问题。如下图所示： 1、命令式开发：后台代码需要调用UI层的控件（label.Text），如果更新UI层…...

编程日记 2024/10/9 12:42:37

【答疑解惑】图文深入详解undo和redo的区别及其底层逻辑

题记：最近有些人问我，undo和redo到底是什么关系，他们中不乏已经入行3-4年的同学，今天咱们就来深入探讨下到底什么是undo和redo，他们分别做什么，底层逻辑原理是什么等等。 1. undo 1.1 undo的存储结构 Un…...

编程日记 2024/10/9 12:39:34

低通滤波、反相放大器电路

1 简介这种可调低通滤波、反相放大器电路可将信号电平放大 26dB 或 20V/V。R2 和 C1 会为此电路设置截止频率。此电路的频率响应与无源 RC 滤波器的相同，除非输出按放大器的通带增益进行放大。低通滤波器通常用于音频信号链，此滤波器有时也称为低音增强…...

编程日记 2024/10/9 12:37:32

【网络】每天掌握一个Linux命令 - iftop

在Linux系统中，iftop是网络管理的得力助手，能实时监控网络流量、连接情况等，帮助排查网络异常。接下来从多方面详细介绍它。目录【网络】每天掌握一个Linux命令 - iftop工具概述安装方式核心功能基础用法进阶操作实战案例面试题场景生产场景…...

编程新知 2025/10/10 17:03:53

如何在看板中体现优先级变化

在看板中有效体现优先级变化的关键措施包括：采用颜色或标签标识优先级、设置任务排序规则、使用独立的优先级列或泳道、结合自动化规则同步优先级变化、建立定期的优先级审查流程。其中，设置任务排序规则尤其重要，因为它让看板视觉上直观地体…...

编程新知 2026/1/23 12:42:28

聊聊 Pulsar：Producer 源码解析

一、前言 Apache Pulsar 是一个企业级的开源分布式消息传递平台，以其高性能、可扩展性和存储计算分离架构在消息队列和流处理领域独树一帜。在 Pulsar 的核心架构中，Producer（生产者） 是连接客户端应用与消息队列的第一步。生产者…...

编程新知 2026/2/5 21:34:41

Robots.txt 文件

什么是robots.txt？ robots.txt 是一个位于网站根目录下的文本文件（如：https://example.com/robots.txt），它用于指导网络爬虫（如搜索引擎的蜘蛛程序）如何抓取该网站的内容。这个文件遵循 Robots…...

编程新知 2025/9/9 5:38:23

Java入门学习详细版（一）

大家好，Java 学习是一个系统学习的过程，核心原则就是“理论实践坚持”，并且需循序渐进，不可过于着急，本篇文章推出的这份详细入门学习资料将带大家从零基础开始，逐步掌握 Java 的核心概念和编程技能。 …...

编程新知 2025/12/14 14:47:02

Java面试专项一-准备篇

一、企业简历筛选规则一般企业的简历筛选流程：首先由HR先筛选一部分简历后，在将简历给到对应的项目负责人后再进行下一步的操作。 HR如何筛选简历例如：Boss直聘（招聘方平台） 直接按照条件进行筛选例如&#xff1a…...

编程新知 2026/1/26 19:10:48

Device Mapper 机制

Device Mapper 机制详解 Device Mapper（简称 DM）是 Linux 内核中的一套通用块设备映射框架，为 LVM、加密磁盘、RAID 等提供底层支持。本文将详细介绍 Device Mapper 的原理、实现、内核配置、常用工具、操作测试流程，并配以详细的…...

编程新知 2025/12/14 13:11:33

听写流程自动化实践，轻量级教育辅助

随着智能教育工具的发展，越来越多的传统学习方式正在被数字化、自动化所优化。听写作为语文、英语等学科中重要的基础训练形式，也迎来了更高效的解决方案。这是一款轻量但功能强大的听写辅助工具。它是基于本地词库与可选在线语音引擎构建，…...

编程新知 2026/1/30 1:47:17

HashMap中的put方法执行流程（流程图）

1 put操作整体流程 HashMap 的 put 操作是其最核心的功能之一。在 JDK 1.8 及以后版本中，其主要逻辑封装在 putVal 这个内部方法中。整个过程大致如下： 初始判断与哈希计算： 首先，putVal 方法会检查当前的 table（也就…...

编程新知 2026/2/8 3:32:52

视频行为标注工具BehaviLabel（源码+使用介绍+Windows.Exe版本）

前言： 最近在做行为检测相关的模型，用的是时空图卷积网络（STGCN），但原有kinetic-400数据集数据质量较低，需要进行细粒度的标注，同时粗略搜了下已有开源工具基本都集中于图像分割这块&#xff0c…...

编程新知 2026/2/6 5:04:18

EventSource (SSE)

WebSocket

如何选择

1. 使用 EventSource (SSE)

服务器端 (Node.js)

客户端 (HTML + JavaScript)

2. 使用 WebSocket

服务器端 (Node.js)

客户端 (HTML + JavaScript)

总结

相关文章：

1. 使用 `EventSource` (SSE)

2. 使用 `WebSocket`