EventSource和websocket该用哪种技术
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都是实现实时通信的技术,但是它们的设计目的和使用场景有所不同。在选择使用哪种技术时,需要根据具体的应用需求来决定。下面是一些关键点,可以帮助你做出选择&…...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

使用Android studio进行Unit Test中遇到的问题记录
1、模块本身代码运行不起来 提示: Cannot resolve method ‘getVolumes’ in ‘StorageManager’ Cannot resolve method ‘registerListener’ in ‘StorageManager’ Cannot resolve method ‘unregisterListener’ in ‘StorageManager’ 查看Android 源码&…...

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

【MAUI】CommunityToolkit社区工具包介绍
一、为什么需要声明式开发 .NET的MVVM,始于WPF,很古典,它甚至可能是现代前端框架“声明式开发”的鼻祖。声明式开发,之所以出现,是因为命令式开发在UI层和代码层上无法解耦的问题。如下图所示: 1、命令式开发:后台代码需要调用UI层的控件(label.Text),如果更新UI层…...

【答疑解惑】图文深入详解undo和redo的区别及其底层逻辑
题记:最近有些人问我,undo和redo到底是什么关系,他们中不乏已经入行3-4年的同学,今天咱们就来深入探讨下到底什么是undo和redo,他们分别做什么,底层逻辑原理是什么等等。 1. undo 1.1 undo的存储结构 Un…...

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

SpringBoot助力服装生产流程优化
1 绪论 1.1 研究背景 当今时代是飞速发展的信息时代。在各行各业中离不开信息处理,这正是计算机被广泛应用于信息管理系统的环境。计算机的最大好处在于利用它能够进行信息管理。使用计算机进行信息控制,不仅提高了工作效率,而且大大的提高…...

【机器学习】线性回归算法简介 及 数学实现方法
线性回归 简介 利用 回归方程(函数) 对 一个或多个自变量(特征值)和因变量(目标值)之间 关系进行建模的一种分析方式。 数学公式: ℎ_(w) w_1x_1 w_2x_2 w_3x_3 … b w^Txb 概念 利用回归方程(函数) 对 一个或多个自变量(特征值)和因变量(目标值)之间 关…...

设计模式的学习
OO:Object-Oriented 面向对象 --- 《Head First设计模式》 这本书是用java写的,我是写C的,用C来写相关的代码 --- p2(第二页) #ifndef DUCK_H #define DUCK_H/*** brief The Duck class 鸭子类*/ class Duck { public:D…...

wordpress发邮件SMTP服务器配置步骤指南?
wordpress发邮件功能如何优化?怎么用wordpress发信? 由于WordPress默认的邮件发送功能可能不够稳定,配置SMTP服务器成为了许多网站管理员的选择。AokSend将详细介绍如何在WordPress中配置SMTP服务器,以确保邮件能够顺利发送。 w…...

胤娲科技:机械臂「叛逃」记——自由游走,再悄然合体
夜深人静,你正沉浸在梦乡的前奏,突然意识到房间的灯还亮着。此刻的你,是否幻想过有一只无形的手,轻盈地飘过,帮你熄灭那盏碍眼的灯? 又或者,你正窝在沙发上,享受电视剧的紧张刺激&am…...

分布式事务讲解 - 2PC、3PC、TCC
分布式事务讲解 - 2PC、3PC、TCC 前置知识 BASE理论: BASE是Basically Availbale(基本可用)、Soft state(软状态)、Eventually consistent(最终一致性)三个词语的缩写。BASE理论是对CAP理论中AP的一个扩展,通过牺牲强一致性来获得可用性,当…...

前端基础面试题·第四篇——Vue(其二)
1.Vue中路由传参 1.params传参 params 传参是通过URL路径来传递参数,这种方式传递的参数是必选的。这种传参方式需要在路由配置时在路由路径位置提前指定参数。 路由配置 const router new VueRouter({routes: [{path: /user/:id, // 这里的:id就是参数name: u…...

PHP反射
文章目录 介绍基本用法基本的反射示例1. 反射类2. 反射方法3. 反射属性4.反射全局函数5.反射函数的参数 优势和注意事项优势:注意事项: 介绍 PHP反射是一种强大的机制,允许在运行时检查类、接口、方法、属性等的结构和元数据。它可以用于许多…...

Gated Transformer Networks for Multivariate Time Series Classification
博客贡献人 徐宁 作者 Minghao Liu , Shengqi Ren , Siyuan Ma , Jiahui Jiao , Yizhou Chen , Zhiguang Wang(Facebook AI) and Wei Song∗ 标签 多元时间序列分类,Transformer,门控 摘要 用于时间序列分类的深度学习模型(主要是卷积网…...

这一次,AI真的能帮你实现职场跃迁
你有没有想过: AI不仅能帮你实现工作提效 还能帮你实现职场跃迁! 根据行业报告,近年来**AIGC(AI Generated Content)**领域岗位数量井喷式增长,AI大模型产品经理作为连接技术与市场的桥梁,正扮…...