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

EventSource和websocket该用哪种技术

news 2025/11/9 11:55:52

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

龙虎榜——20250610

上证指数放量收阴线，个股多数下跌，盘中受消息影响大幅波动。深证指数放量收阴线形成顶分型，指数短线有调整的需求，大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技代表标的：御银股份、雄帝科技驱动…...

编程新知 2025/11/9 9:12:23

观成科技：隐蔽隧道工具Ligolo-ng加密流量分析

1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具，该工具基于TUN接口实现其功能，利用反向TCP/TLS连接建立一条隐蔽的通信信道，支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式，适应复杂网…...

编程新知 2025/11/9 2:17:02

手游刚开服就被攻击怎么办？如何防御DDoS？

开服初期是手游最脆弱的阶段，极易成为DDoS攻击的目标。一旦遭遇攻击，可能导致服务器瘫痪、玩家流失，甚至造成巨大经济损失。本文为开发者提供一套简洁有效的应急与防御方案，帮助快速应对并构建长期防护体系。一、遭遇攻击的紧急应…...

编程新知 2025/11/9 3:59:38

k8s从入门到放弃之Ingress七层负载

k8s从入门到放弃之Ingress七层负载在Kubernetes（简称K8s）中，Ingress是一个API对象，它允许你定义如何从集群外部访问集群内部的服务。Ingress可以提供负载均衡、SSL终结和基于名称的虚拟主机等功能。通过Ingress，你可…...

编程新知 2025/9/7 0:12:53

遍历 Map 类型集合的方法汇总

1 方法一先用方法 keySet() 获取集合中的所有键。再通过 gey(key) 方法用对应键获取值 import java.util.HashMap; import java.util.Set;public class Test {public static void main(String[] args) {HashMap hashMap new HashMap();hashMap.put("语文",99);has…...

编程新知 2025/11/7 20:35:11

Java - Mysql数据类型对应

Mysql数据类型java数据类型备注整型INT/INTEGERint / java.lang.Integer–BIGINTlong/java.lang.Long–––浮点型FLOATfloat/java.lang.FloatDOUBLEdouble/java.lang.Double–DECIMAL/NUMERICjava.math.BigDecimal字符串型CHARjava.lang.String固定长度字符串VARCHARjava.lang…...

编程新知 2025/9/25 14:10:40

ffmpeg（四）：滤镜命令

FFmpeg 的滤镜命令是用于音视频处理中的强大工具，可以完成剪裁、缩放、加水印、调色、合成、旋转、模糊、叠加字幕等复杂的操作。其核心语法格式一般如下： ffmpeg -i input.mp4 -vf "滤镜参数" output.mp4或者带音频滤镜： ffmpeg…...

编程新知 2025/11/9 11:32:13

Nginx server_name 配置说明

Nginx 是一个高性能的反向代理和负载均衡服务器，其核心配置之一是 server 块中的 server_name 指令。server_name 决定了 Nginx 如何根据客户端请求的 Host 头匹配对应的虚拟主机（Virtual Host）。 1. 简介 Nginx 使用 server_name 指令来确定…...

编程新知 2025/9/6 16:47:17

ServerTrust 并非唯一

NSURLAuthenticationMethodServerTrust 只是 authenticationMethod 的冰山一角要理解 NSURLAuthenticationMethodServerTrust, 首先要明白它只是 authenticationMethod 的选项之一, 并非唯一 1 先厘清概念点说明authenticationMethodURLAuthenticationChallenge.protectionS…...

编程新知 2025/11/8 7:31:24

技术栈RabbitMq的介绍和使用

目录 1. 什么是消息队列？2. 消息队列的优点3. RabbitMQ 消息队列概述4. RabbitMQ 安装5. Exchange 四种类型5.1 direct 精准匹配5.2 fanout 广播5.3 topic 正则匹配 6. RabbitMQ 队列模式6.1 简单队列模式6.2 工作队列模式6.3 发布/订阅模式6.4 路由模式6.5 主题模式…...

编程新知 2025/11/7 21:05:07

EventSource (SSE)

WebSocket

如何选择

1. 使用 EventSource (SSE)

服务器端 (Node.js)

客户端 (HTML + JavaScript)

2. 使用 WebSocket

服务器端 (Node.js)

客户端 (HTML + JavaScript)

总结

相关文章：

1. 使用 `EventSource` (SSE)

2. 使用 `WebSocket`