【node进阶】深入浅出websocket即时通讯(一)

news2025/8/12 21:13:31

✅ 作者简介:一名普通本科大三的学生,致力于提高前端开发能力
✨ 个人主页:前端小白在前进的主页
🔥 系列专栏 : node.js学习专栏
⭐️ 个人社区 : 个人交流社区
🍀 学习格言: ☀️ 打不倒你的会使你更强!☀️
💯 刷题网站:这段时间有许多的小伙伴在问有没有什么好的刷题网站,博主在这里给大家推荐一款刷题网站:👉点击访问牛客网👈牛客网支持多种编程语言的学习,各大互联网大厂面试真题,从基础到拔高,快来体验一下吧!


在这里插入图片描述
🔥前言

在上一章中node的主要内容其实已经结束了,本篇文章从扩展角度去学习当下比较流行的即时通讯技术—websocket,WebSocket并不是全新的协议,而是利用了HTTP协议来建立连接,接下来让我们正式走进websocket的大门!


📃目录

  • 为什么需要 WebSocket?
  • WebSocket简介
  • Websocket的特点
  • WebSocket的应用场景
  • 服务器支持
  • 客户端websocket的 API
    • WebScoket构造函数
    • ws.onopen()
    • ws.onclose()
    • ws.onmessage()
    • ws.send()
  • node中使用WebSocket
    • 客户端使用
    • 安装ws模块
    • node中简单使用
  • 小结

为什么需要 WebSocket?

初次接触 WebSocket ,大家都会问同样的问题:我们已经有了 HTTP 协议,为什么还需要另一个协议?它能带来什么好处?
答案很简单,因为 HTTP 协议有一个缺陷通信只能由客户端发起
举例来说,我们想了解今天的天气,只能是客户端服务器发出请求,服务器返回查询结果。HTTP 协议做不到服务器主动向客户端推送信息

这种单向请求的特点,注定了如果服务器有连续的状态变化,客户端要获知就非常麻烦。我们只能使用"轮询":每隔一段时候,就发出一个询问,了解服务器有没有新的信息。最典型的场景就是聊天室

轮询的效率低,非常浪费资源(因为必须不停连接,或者 HTTP 连接始终打开)。因此,工程师们一直在思考,有没有更好的方法。WebSocket 就是这样发明的。


WebSocket简介

服务器可以主动向客户端推送信息,客户端也可以主动向服务器发送信息,是真正的双向平等对话,属于服务器推送技术的一种。

为什么WebSocket连接可以实现全双工通信而HTTP连接不行呢?实际上HTTP协议是建立在TCP协议之上的,TCP协议本身就实现了全双工通信,但是HTTP协议的请求-应答机制限制了全双工通信。WebSocket连接建立以后,其实只是简单规定了一下:接下来,咱们通信就不使用HTTP协议了,直接互相发数据吧

注意WebSocket连接必须由浏览器发起,因为请求协议是一个标准的HTTP请求


Websocket的特点

  • 建立在 TCP 协议之上,服务器端的实现比较容易。
  • 与 HTTP 协议有着良好的兼容性。默认端口也是80和443,并且握手阶段采用 HTTP 协议,因此握手时不容易屏蔽,能通过各种 HTTP 代理服务器。
  • 数据格式比较轻量,性能开销小,通信高效。
  • 可以发送文本,也可以发送二进制数据
  • 没有同源限制,客户端可以与任意服务器通信。
  • 协议标识符是ws(如果加密,则为wss),服务器网址就是 URL(例如:ws://localhost:8080)。
    在这里插入图片描述

WebSocket的应用场景

  • 弹幕

  • 媒体聊天

  • 协同编辑(我们常用的在线编辑)

  • 基于位置的应用(例如:美团外卖中我们可以实时查看外卖小哥的位置,距离目的地的距离)

  • 体育实况更新(腾讯体育nba直播技术统计的数据实时更新)

  • 股票基金报价实时更新


服务器支持

由于WebSocket是一个协议,服务器具体怎么实现,取决于所用编程语言和框架本身。Node.js本身支持的协议包括TCP协议HTTP协议,要支持WebSocket协议,需要对Node.js提供的HTTPServer做额外的开发。已经有若干基于Node.js的稳定可靠的WebSocket实现,我们直接用npm安装使用即可。


客户端websocket的 API

WebScoket构造函数

const ws = new WebSocket(`ws://localhost:8080?token=${localStorage.getItem("token")}`)

WebSocket 对象作为一个构造函数,用于新建 WebSocket 实例。执行上面语句之后,客户端就会与服务器进行连接
注意: 在这里传入的参数url中可以携带token,可以进行登录鉴权

ws.onopen()

实例对象的onopen属性,用于指定连接成功后的回调函数

ws.onopen = () => {
       console.log('连接成功!');
}

ws.onclose()

实例对象的onclose属性,用于指定连接关闭后的回调函数

ws.onclose = () => {
       console.log('关闭成功!')
}

ws.onmessage()

实例对象的onmessage属性,用于指定收到服务器数据后的回调函数

ws.onmessage = (msgObj) => {
	//...在这里进行逻辑操作
}

注意:这里的形参是服务器传来的数据对象,msgObj.data可以访问到服务端返回的具体信息数据

ws.send()

实例对象的send()方法用于向服务器发送数据

ws.send('hello websocket')

node中使用WebSocket

客户端使用

var ws = new WebSocket(`ws://localhost:8080?token=${localStorage.getItem("token")}`)
ws.onopen = () => {
      console.log("open")
      ws.send(JSON.stringify({
        type: WebSocketType.GroupList
      }))
    }
ws.onmessage = (evt) => {
    console.log(evt.data)
}

在上面我们对客户端的方法做了一个了解后,将对服务端进行了解!=>node中使用websocket官网

安装ws模块

 npm install ws

node中简单使用

const  WebSocket = require("ws")
const WebSocketServer = WebSocket.WebSocketServer
//创建websocket服务,端口号为8080,与客户端请求的端口号保持一致
const wss = new WebSocketServer({ port: 8080 });
wss.on('connection', function connection(ws) {
// connection,表示连接客户端,形参中的ws代表我们的客户端
    ws.on('message', function message(data, isBinary) {
    //这里表示只要ws标记的客户端给我们发送消息,我们通过监听message可以得到前台发过来的消息
        wss.clients.forEach(function each(client) {
        //wss.clients存放着连接到我们服务器所有的客户端,通过遍历,将客户端的消息转发给其他客户端,从而实现群聊
            if (client !== ws && client.readyState === WebSocket.OPEN) {
            //这里client!==ws 目的是群发的时候不给自己发消息
                client.send(data, { binary: false });
                //在这里binary:false表示返回的数据不是二进制类型!
            }
        });

    });
    ws.send('欢迎加入聊天室');  //给客户端返回信息
});

注意:上述代码中ws实质上是一个句柄,(按照我的理解就是:ws代表我们打开的浏览器窗口,每打开一个窗口,ws就代表不同的窗口,代表不同的客户端),用来指示服务端指向客户端的唯一标识


小结

WebScoket整体来说的话不是很难,只是比较繁琐罢了,前后端必须要进行一对一的匹配,也就是说,有来就有回,本篇为wensocket学习的第一阶段而已,后面的文章将会切入到群聊、私聊的demo中去体验一下!


👑书写不易,希望大家能够给予三连支持,期待我更好的文章哟👑

在这里插入图片描述

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

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

相关文章

游戏黑卡代充36技术及库存系统案例分析

黑卡充值常隐匿于「代充」服务中,且形式多变,从外币汇率差、退款到36漏洞、黑卡/盗刷信用卡充值,甚至还出现了专门的库存系统。 「36漏洞」是利用iOS小额支付漏洞实现的刷单套利业务。苹果为提高用户体验,在 APP Store 购买商品时…

【Hack The Box】linux练习-- Sunday

HTB 学习笔记 【Hack The Box】linux练习-- Sunday 🔥系列专栏:Hack The Box 🎉欢迎关注🔎点赞👍收藏⭐️留言📝 📆首发时间:🌴2022年11月17日🌴 &#x1f3…

电容笔用什么品牌?电容笔10大品牌排行榜

尽管苹果公司的原装电容笔使用起来非常的流畅,非常的方便,但是它的价格却非常昂贵,这让很多学生党望而却步,还有这款电容笔的重量也不轻,长时间使用手会感觉疲劳。如果是来学习的,那就未必买如此贵的电容笔…

Java抽象类(abstract)

抽象类 当父类的某些方法,需要声明,但是又不确定如何实现时,可以将其声明为抽象方法,那么这个类就是抽象类 1)用abstract关键字来修饰一个类时,这个类就叫抽象类 访问修饰符 abstract 类名 {}2)用abstract关键宇来修饰一个方法时…

C. Division(分解质因数)

Problem - 1445C - Codeforces 奥列格最喜欢的科目是历史和数学,而他最喜欢的数学分支是除法。 为了提高他的除法技巧,奥列格想出了t对整数pi和qi,并决定为每对整数找到最大的整数xi,这样。 pi能被xi整除。 xi不能被qi整除。 奥…

基于NodeJs+Express+MySQL 实现的个人博客完整项目

目录 一、创建项目并初始化 项目结构 二、安装项目所需要的包 三、创建所需要的数据库表 表 user 用于存放账户密码 表 notepad 用于存放文章数据 表 leaving 用于存放留言板的数据 三、编写app.js文件 1、导入所有需要的包 2、创建web服务器 3、创建db文件夹&#…

智能制造APS,赋能「钣金行业」提升数字化战斗力!

导语: 钣金加工是典型的离散制造行业,具有品种多、批量小、交期短、质量要求高的发展趋势,这对钣金车间的生产管理提出了新的挑战。推进行业数字化、智能化改造,实现质效双提升,打破增长瓶颈,成为钣金行业…

Git常用命令与分支管理

Git常用的命令有以下6个:fetch/clone命令,add命令,commit命令,checkout命令,push命令,pull命令。 workspace:工作区staging area:暂存区loacl repository:本地仓库remot…

计算机毕业设计springboot+vue+elementUI会员制医疗预约服务管理信息系统

项目介绍 会员制医疗预约服务管理信息系统是针对会员制医疗预约服务管理方面必不可少的一个部分。在会员制医疗预约服务管理的整个过程中,会员制医疗预约服务管理系统担负着最重要的角色。为满足如今日益复杂的管理需求,各类的管理系统也在不断改进 本系…

字节面试问到CPU的多级缓存架构,诸佬们怎么回答?

前言:大家好,我是小威,24届毕业生,上周在面试字节中,问到了一个关于CPU多级缓存架构的问题,当时答得并不是很好,之后查阅了资料,对此进行了复盘总结。 如果文章有什么需要改进的地方…

全网最详细SpringBoot、SpringCloud整合阿里云OSS对象存储服务

1、进入阿里云官网 https://www.aliyun.com/ 2、搜索“对象存储OSS” 3、进入“管理控制台” 4、进入“Bucket列表”,点击“创建Bucket” 5、根据实际情况选择,最后点击“确定” 这里插入一个可以通过代码创建Bucket的测试类,如下&#xff…

什么是供应商管理?为什么它很重要?

**供应商管理**是确保企业付给供应商的钱获得最大价值的过程,且目标是确保与供应商签订的所有合同都能满足企业业务的需求。 乍一看,供应商管理似乎是一件很容易总结的事情,建立适当的关系,管理需求,并与供应商进行清…

VR直播系统设置大揭秘,带你穿越时空亲临现场

直播现在可谓是各个行业的香饽饽,不管是电商带货直播,还是游戏竞赛直播都是如火如荼。而VR直播也逐渐频繁出现在大众眼前,就例如前两年广大人民都是通过VR直播在线观看火神山的建设,随着近两年5G技术和VR技术的兴起和发展&#xf…

MongoDB安装及进程介绍

文章目录 MongoDB安装重要的进程介绍mongo进程其他进程MongoDB安装 MongoDB 官方已经提供了Linux、Windows、Mac OS X 以及Solaris 4 种平台的二进制分发包,最新的稳定版本是 6.0.2,下载地址是:https://www.mongodb.com/try/download/community,如图: 下载完成后,解压…

Vue3源码解读之patch

例子代码 本篇将要讲解dom diff,那么咱们结合下面的例子来进行讲解,这个例子是在上一篇文章的基础上,加了一个数据变更,也就是list的值发生了改变。html中增加了一个按钮change,通过点击change按钮来调用change函数&a…

Java语法之封装

我们应该都知道Java面向对象的三大特性:封装,继承,多态,今天小编给大家分享封装这个概念以及使用,我们开始吧: 目录 🎉封装的概念 🎉封装的使用 🎉封装的好处 &#…

论文写作:word连续交叉引用

文章目录一、问题背景二、步骤一、问题背景 在写作得时候,使用word的 “交叉引用”功能可以形成超链接格式的标号。但是交叉引用每次只能选择一篇论文,在连续选择多篇论文的时候,就是 “[1][2][3]” 而不是 “[1-3]” 这样的格式。 如图&…

redis set zset key 常用命令

list 可以重复 set不可以 list 有序 set元素位置无序 key常用命令 #1. 存储数据 sadd key member [member ...] 获取的结果是无序的 #2. 获取数据(获取全部数据) smembers key #3. 随机获取一个数据(获取的同时,移除数据&#…

22.11.17打卡 mysql学习笔记

为了不挂科...... 内连接 2022年11月17日 19:34 分为隐式内连接和显式内连接 区别是: 表的连接形式和链接条件的表现形式; 链接条件的表现形式 隐式内连接 显式内连接 外连接 2022年11月17日 19:44 外连接分为左外连接和右外连接 左外连接 右外连接 自连接 2022年11月17…

为什么vue3要选用proxy,好处是什么?

提问 Object.defineProperty()和proxy的区别?为什么vue3要选用proxy,好处是什么? proxy Proxy 对象用于创建一个对象的代理,从而实现基本操作的拦截和自定义(如属性查找、赋值、枚举、函数调用等)。 Pr…