十分钟学会WebSocket

WebSocket 简介

WebSocket 是一种在客户端和服务器之间实现双向通信的网络协议。它通过在单个 TCP 连接上提供全双工通信功能,使得服务器可以主动向客户端推送数据,而不需要客户端发起请求。

WebSocket 与 HTTP 的区别

与传统的 HTTP 协议相比,WebSocket 具有以下几个显著的区别:

  • 双向通信:WebSocket 支持客户端和服务器之间的实时双向通信,而 HTTP 协议是单向请求-响应模式。
  • 低延迟:由于 WebSocket 使用长连接,避免了 HTTP 的连接建立和断开过程,可以降低通信延迟。
  • 更少的数据传输:WebSocket 头部信息相对较小,减少了数据传输的开销。
  • 跨域支持:WebSocket 可以轻松跨域,而 HTTP 需要通过 CORS 等机制来实现。

WebSocket 的工作原理

WebSocket 的握手过程和 HTTP 有所不同。客户端通过发送特定的 HTTP 请求进行握手,服务器收到请求后进行验证,如果验证通过,则会建立 WebSocket 连接。

建立连接后,客户端和服务器之间可以通过 WebSocket 发送和接收消息,可以使用文本、二进制数据等进行通信。

WebSocket 的应用场景

WebSocket 的实时双向通信特性使得它在许多应用场景中发挥重要作用,例如:

  • 即时聊天:WebSocket 可以实现实时的聊天功能,用户可以发送和接收消息,实现快速、低延迟的聊天体验。
  • 实时数据更新:对于需要实时更新数据的应用,如股票行情、实时监控等,WebSocket 可以将数据实时推送给客户端,确保数据的及时更新。
  • 在线游戏:在线游戏需要实时的双向通信,WebSocket 可以提供稳定的通信通道,支持实时交互和多人游戏。

WebSocket 的使用

以下是使用 JavaScript 与 WebSocket 建立连接的示例代码:

var Socket = new WebSocket("url, [protocol]");

以上代码中的第一个参数url, 指定连接的 URL。第二个参数protocol是可选的,指定了可接受的子协议。

WebSocket 属性

以下是 WebSocket 对象的属性。

属性描述
Socket.readyState只读属性 readyState 表示连接状态,可以是以下值:0-表示连接尚未建立。1-表示连接已建立,可以进行通信。2-表示连接正在进行关闭。3-表示连接已经关闭或者连接不能打开。
Socket.bufferedAmount只读属性 bufferedAmount 已被 send()放入正在队列中等待传输,但是还没有发出的 UTF-8 文本字节数。
  • 0-表示连接尚未建立。
  • 1-表示连接已建立,可以进行通信。
  • 2-表示连接正在进行关闭。
  • 3-表示连接已经关闭或者连接不能打开。
WebSocket 事件

以下是 WebSocket 对象的相关事件。

事件事件处理程序描述
openSocket.onopen连接建立时触发
messageSocket.onmessage客户端接收服务端数据时触发
errorSocket.onerror通信发生错误时触发
closeSocket.onclose连接关闭时触发
  • 下面是相关示例代码:
Socket.onopen = function() {//连接建立时触发console.log("WebSocket连接已建立");
};Socket.onmessage = function(event) {//客户端接收服务端数据时触发var message = event.data;console.log("收到消息:" + message);
};Socket.onerror = function() {//通信发生错误时触发console.log("WebSocket连接发生了错误");
};Socket.onclose = function() {//连接关闭时触发console.log("WebSocket连接已关闭");
};
WebSocket 方法

以下是 WebSocket 对象的相关方法。

方法描述
Socket.send()使用连接发送数据
Socket.close()关闭连接
//发送一条消息
Socket.send('你好')
//关闭WebSocket连接
Socket.close()

WebSocket 除了发送和接收文本消息外,还支持发送和接收二进制数据。对于发送二进制数据,可以使用 send() 方法传递一个 ArrayBufferBlob 对象,例如:

const buffer = new ArrayBuffer(4);
const view = new DataView(buffer);
view.setUint32(0, 1234);
socket.send(buffer);

在接收二进制数据时,可以通过 event.data 获取到 ArrayBuffer 对象,然后进行处理。

WebSocket 的心跳机制

WebSocket 的心跳机制是一种用于保持 WebSocket 连接的稳定性和活跃性的方法。心跳机制的目的是定期发送小的探测消息,以确保连接仍然有效,如果连接断开或出现问题,可以及时发现并采取措施。

下面是 WebSocket 心跳机制的详细步骤和相关代码示例:

定义心跳间隔:为了定期发送心跳消息,你需要定义一个心跳间隔,通常以毫秒为单位。在示例中,我们将心跳间隔设置为 30 秒。

 const heartbeatInterval = 30000; // 30秒

定义心跳消息:你需要定义用于发送心跳的消息内容。这通常是一个简单的字符串,如"heartbeat",但可以根据应用的需求自定义。

const heartbeatMessage = 'heartbeat';

设置心跳定时器:一旦 WebSocket 连接打开,你可以使用setInterval函数设置一个定时器,以便每隔一段时间发送心跳消息。

let heartbeat;socket.addEventListener('open', () => {console.log('WebSocket连接已打开');heartbeat = setInterval(() => {socket.send(heartbeatMessage);}, heartbeatInterval);
});

处理心跳消息:当你接收到来自服务器的消息时,你需要检查它是否是心跳消息。这可以通过比较接收到的消息内容和心跳消息的内容来实现。

socket.addEventListener('message', (event) => {const message = event.data;if (message === heartbeatMessage) {console.log('接收到心跳消息');// 在这里可以执行一些处理心跳消息的操作} else {console.log('接收到其他消息:', message);// 处理其他类型的消息}
});

清除心跳定时器:当 WebSocket 连接关闭时,你应该清除之前设置的心跳定时器,以防止继续发送心跳消息。

socket.addEventListener('close', () => {console.log('WebSocket连接已关闭');clearInterval(heartbeat);
});

通过这些步骤,你可以实现 WebSocket 的心跳机制,确保连接的持续稳定,以适应长时间的通信需求。如果连接断开或出现问题,你可以根据需要添加进一步的错误处理机制。

WebSocket 的安全性和跨域问题如何处理?

WebSocket 支持通过 wss:// 前缀建立加密的安全连接,使用 TLS/SSL 加密通信,确保数据的安全性。在使用加密连接时,服务器需要配置相应的证书。

对于跨域问题,WebSocket 遵循同源策略,只能与同源的服务器建立连接。如果需要与不同域的服务器通信,可以使用 CORS(跨域资源共享)来进行跨域访问控制。

有哪些好用的客户端 WebSocket 第三方库

  1. Socket.io-client:Socket.io 是一个流行的实时通信库,它提供了客户端 JavaScript 库,可用于在浏览器中与 Socket.io 服务器建立 WebSocket 连接。它支持自动重连、事件处理等功能,用于构建实时应用非常方便。
  2. ReconnectingWebSocket:ReconnectingWebSocket 是一个带有自动重连功能的 WebSocket 客户端库,可以很好地处理网络连接断开和重新连接的情况,适合用于浏览器端的 WebSocket 开发。
  3. SockJS-client:SockJS 提供了一个浏览器端的 JavaScript 客户端库,用于与 SockJS 服务器建立连接。它可以在不支持 WebSocket 的浏览器上自动降级到其他传输方式,具有良好的兼容性。
  4. RxJS WebSocketSubject:RxJS 是一个流式编程库,它提供了 WebSocketSubject 类,可以将 WebSocket 转换为可观察对象,方便进行响应式编程。
  5. autobahn.js:autobahn.js 是一个用于实现 WebSocket 和 WAMP(Web Application Messaging Protocol)的客户端库,在浏览器中可以方便地使用它来与 WAMP 路由进行通信。

这些库都提供了良好的接口封装和功能特性,可以根据项目需求选择适合的库来进行浏览器端的 WebSocket 开发。

总结

WebSocket 协议是一种基于 TCP 的应用层协议,它提供了在客户端和服务器之间进行双向通信的能力。相比传统的 HTTP 协议,它具有更低的延迟和更高的实时性。

WebSocket 协议通过建立一条持久化的连接来实现双向通信,从而避免了 HTTP 协议中频繁建立和断开连接的过程,减少了网络开销和服务器的负担。客户端可以发送消息给服务器,服务器也可以发送消息给客户端,实现了真正的双向通信。

在使用 WebSocket 协议时,客户端和服务器会进行一次握手过程,以建立起 WebSocket 连接。握手过程中,客户端会发送一个 HTTP 请求,请求头中包含 Upgrade 和 Connection 字段,告诉服务器它希望升级到 WebSocket 连接。服务器收到请求后会返回一个 HTTP 响应,响应头中包含 Upgrade 和 Connection 字段,以及一个 Sec-WebSocket-Accept 字段,用于验证请求的合法性。握手成功后,客户端和服务器就可以开始使用 WebSocket 协议进行通信了。

WebSocket 协议支持二进制数据和文本数据的传输,开发者可以根据实际需求进行选择。同时,WebSocket 还提供了心跳机制、自动重连等功能,可以提高连接的稳定性和可靠性。

总之,WebSocket 协议在实时通信、游戏、在线聊天等场景中得到了广泛应用,它为 Web 应用提供了更加高效、可靠的双向通信方式。

最后

欢迎关注"所谓前端"微信公众号,大家一起交流
点击扫码关注

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/676389.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ArcGIS学习(四)坐标系-1

ArcGIS学习(四)坐标系 大家平时在处理数据的时候肯定经常遇到坐标系相关的问题。最常见的就是同一个地区的两个数据,导入ArcGIS内却对不上;也肯定听到过坐标系相关的一些词语,比如地理坐标系投影坐标系、投影、WGS1984坐标、CGCS2000坐标系、火星坐标系、百度坐标系等。 …

redis-sentinel(哨兵模式)

目录 1、哨兵简介:Redis Sentinel 2、作用 3、工作模式 4、主观下线和客观下线 5、配置哨兵模式 希望能够帮助到大家!!! 1、哨兵简介:Redis Sentinel Sentinel(哨兵)是用于监控redis集群中Master状态的工具,其已经被集成在re…

【C语言自定义类型详解进阶】结构体(补充结构体的对齐和位段,一口气看完系列,央妈都点赞的博文)

目录 1.结构体 1.1 结构的基础知识 1.2 结构的声明 1.2.1特殊的声明(匿名结构体类型) 1.3结构体变量的定义 1.4关于匿名结构体类型的补充 1.5结构体的自引用 1.6结构体变量的初始化 2.结构体内存对齐(重点) 2.1偏移量补…

统一数据格式返回,统一异常处理

目录 1.统一数据格式返回 2.统一异常处理 3.接口返回String类型问题 1.统一数据格式返回 添加ControllerAdvice注解实现ResponseBodyAdvice接口重写supports方法,beforeBodyWrite方法 /*** 统一数据格式返回的保底类 对于一些非对象的数据的再统一 即非对象的封…

Verilog刷题笔记28

题目: A “population count” circuit counts the number of 1’s in an input vector. Build a population count circuit for a 255-bit input vector. 解题: module top_module( input [254:0] in,output [7:0] out );int i;always(*)beginout8b0;…

java实战:销售订单号自动生成

本文将介绍如何使用Java实现一个销售订单号的自动生成系统,该系统能够在高并发环境下保证订单号的唯一性。我们将探讨几种常见的订单号生成策略,并实现一个基于数据库的唯一性检查的解决方案。通过本文,可以了解到如何在Java应用程序中生成唯…

手把手教你开发Python桌面应用-PyQt6图书管理系统-图书添加模块-图书类别ComboBox下拉框初始化数据实现

锋哥原创的PyQt6图书管理系统视频教程: PyQt6图书管理系统视频教程 Python桌面开发 Python入门级项目实战 (无废话版) 火爆连载更新中~_哔哩哔哩_bilibiliPyQt6图书管理系统视频教程 Python桌面开发 Python入门级项目实战 (无废话版) 火爆连载更新中~共计24条视频&…

如何手机搜大学生答案? #笔记#微信

今天我就分享几款搜题软件和搜题网站给大家,每一款都能轻松搜索题目,让大家快速找到精准的答案,有需要的小伙伴快点赞收藏起来,防止需要的时候找不到啦。 1.试题猪 这个是公众号 涵盖初大学/专升本/考研…

完美运营的最新视频打赏系统及附带教程

(购买本专栏可免费下载栏目内所有资源不受限制,持续发布中,需要注意的是,本专栏为批量下载专用,并无法保证某款源码或者插件绝对可用,介意不要购买) 优于市面上95%的打赏系统,与其他打赏系统相比,功能更加强大,完美运营且无bug。支付会调、短链接生成、代理后台、价…

突破编程_C++_基础教程(类的基础知识)

1 面向对象 面向对象( Object-Oriented ,简称 OO )是一种编程思想,它使用对象的理念来设计软件和构建程序。面向对象编程( Object-Oriented Programming ,简称 OOP )是这种思想的具体实现方式。…

LeetCode1365之切披萨的方案数(相关话题:二维前缀和,动态规划)

题目描述 给你一个 rows x cols 大小的矩形披萨和一个整数 k ,矩形包含两种字符: A (表示苹果)和 . (表示空白格子)。你需要切披萨 k-1 次,得到 k 块披萨并送给别人。 切披萨的每一刀&#xf…

vscode开发FPGA(0)--windows平台搭建

一、从官网下载安装VScode Download Visual Studio Code - Mac, Linux, Windows 二、安装配置插件 1. 安装Chinese(simplified)中文汉化包 2.安装Verilog-HDL/systemVerilog插件(支持verilog语法) 3.配置CTags Support插件(支持代码跳转) 1)在github下…

MySQL篇之定位与优化MySQL慢查询

一、如何定位慢查询 1.方案一:开源工具 调试工具:Arthas。 运维工具:Prometheus 、Skywalking。 2.方案二:MySQL自带慢日志 慢查询日志记录了所有执行时间超过指定参数(long_query_time,单位:…

Backtrader 文档学习- Plotting -Plotting on the same axis

Backtrader 文档学习- Plotting -Plotting on the same axis 1.概述 在同一轴上绘图,绘图是在同一空间上绘制原始数据和稍微(随机)修改的数据,但不是在同一轴上。 核心代码,data数据正负50点。 # The filter which changes the close pri…

(50)矩阵对角线元素的和

文章目录 每日一言题目解题思路法一:法二: 代码法一:法二: 结语 每日一言 高山之巅,方见大河奔涌;于群峰之上,更觉长风浩荡。 题目 题目链接:矩阵对角线元素的和 给你一个正方形矩…

力扣热门100题 - 5.最长回文子串

力扣热门100题 - 5.最长回文子串 题目描述:示例:提示:解题思路:(动态规划)代码: 题目链接:5. 最长回文子串 题目描述: 给你一个字符串 s,找到 s 中最长的回…

[day0] 借着“ai春晚”开个场

1 文思ai笔记-新的开始 今天是2024年2月29日,也是传统农历的除夕夜。早起在ai圈看到一个比较新奇的消息,ai春晚今日举办,竟然有一点小小的激动。这些年确实好久没看过春晚了,自己对于春晚的映像还停留在“白云黑土”、“今天&…

Sklearn、TensorFlow 与 Keras 机器学习实用指南第三版(六)

原文:Hands-On Machine Learning with Scikit-Learn, Keras, and TensorFlow 译者:飞龙 协议:CC BY-NC-SA 4.0 第十四章:使用卷积神经网络进行深度计算机视觉 尽管 IBM 的 Deep Blue 超级计算机在 1996 年击败了国际象棋世界冠军…

【51单片机】烧写教程:将代码下载到单片机中(图示&解析)

前言 大家好吖,欢迎来到 YY 滴单片机系列 ,热烈欢迎! 本章主要内容面向接触过单片机的老铁 这是LCD基本实验中的一部分,完整实验传送门如下:传送门 欢迎订阅 YY滴C专栏!更多干货持续更新!以下是…

初始web服务器(并基于idea来实现无需下载的tomcat)

前言 前面学习了对应的http协议,我们知道了他是在网络层进行数据传输的协议,负责相应数据以及接收数据的规则,但是在人员开发后端的时候不仅仅需要你写io流进行数据传输,还需要你进行对应的tcp协议来进行数据打包发送http协议-CSD…