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

EventSource和websocket该用哪种技术

news 2025/9/16 11:44:05

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

C++实现分布式网络通信框架RPC(3)--rpc调用端

目录一、前言二、UserServiceRpc_Stub 三、 CallMethod方法的重写头文件实现四、rpc调用端的调用实现五、 google::protobuf::RpcController *controller 头文件实现六、总结一、前言在前边的文章中，我们已经大致实现了rpc服务端的各项功能代…...

编程新知 2025/9/16 4:21:17

使用VSCode开发Django指南

使用VSCode开发Django指南一、概述 Django 是一个高级 Python 框架，专为快速、安全和可扩展的 Web 开发而设计。Django 包含对 URL 路由、页面模板和数据处理的丰富支持。本文将创建一个简单的 Django 应用，其中包含三个使用通用基本模板的页面。在此…...

编程新知 2025/9/14 10:33:45

渲染学进阶内容——模型

最近在写模组的时候发现渲染器里面离不开模型的定义，在渲染的第二篇文章中简单的讲解了一下关于模型部分的内容，其实不管是方块还是方块实体，都离不开模型的内容 🧱 一、CubeListBuilder 功能解析 CubeListBuilder 是 Minecraft Java 版模型系统的核心构建器，用于动态创…...

编程新知 2025/7/30 14:13:39

Spring AI与Spring Modulith核心技术解析

Spring AI核心架构解析 Spring AI（https://spring.io/projects/spring-ai）作为Spring生态中的AI集成框架，其核心设计理念是通过模块化架构降低AI应用的开发复杂度。与Python生态中的LangChain/LlamaIndex等工具类似，但特别为多语…...

编程新知 2025/9/10 1:53:18