1、什么是WebSocket1.1 定义Websocket是一个持久化的网络通信协议,可以在单个 TCP 连接上进行 1.2 关联和区别
![]()
![]()
1.3 应用场景WebSocket可以做弹幕、消息订阅、多玩家游戏、协同编辑、股票基金实时报价、视频会议、在线教育、聊天室等应用实时监听服务端变化 2、Websocket握手
Host: server.example.com Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== Sec-WebSocket-Protocol: chat, superchat Sec-WebSocket-Version: 13 Origin: http://example.com 下面是与传统 HTTP 报文不同的地方: Upgrade: websocketConnection: Upgrade 表示发起的是 WebSocket 协议 Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==Sec-WebSocket-Protocol: chat, superchat Sec-WebSocket-Version: 13 Sec-WebSocket-Key 是由浏览器随机生成的,验证是否可以进行Websocket通信,防止恶意或者无意的连接。 Sec_WebSocket-Protocol 是用户自定义的字符串,用来标识服务所需要的协议 Sec-WebSocket-Version 表示支持的 WebSocket 版本。
Upgrade: websocket Connection: Upgrade Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= Sec-WebSocket-Protocol: chat 101 响应码 表示要转换协议。 Connection: Upgrade 表示升级新协议请求。 Upgrade: websocket 表示升级为 WebSocket 协议。 Sec-WebSocket-Accept 是经过服务器确认,并且加密过后的 Sec-WebSocket-Key。用来证明客户端和服务器之间能进行通信了。 Sec-WebSocket-Protocol 表示最终使用的协议。 至此,客户端和服务器握手成功建立了Websocket连接,HTTP已经完成它所有工作了,接下来就是完全按照Websocket协议进行通信了。 3、关于Websocket3.1 WebSocket心跳可能会有一些未知情况导致SOCKET断开,而客户端和服务端却不知道,需要客户端定时发送一个 3.2 WebSocket状态WebSocket 对象中的readyState属性有四种状态:
3.3 WebSocket实践3.3.1 服务端接收发送消息WebSocket的服务端部分,本文会以Node.js搭建 安装 安装成功后的package.json: ![]() 接着在根目录创建server.js文件: //引入express 和 wsconst express = require('express'); const SocketServer = require('ws').Server; //指定开启的端口号 const PORT = 3000; // 创建express,绑定监听3000端口,且设定开启后在consol中提示 const server = express().listen(PORT, () => console.log(`Listening on ${PORT}`)); // 将express交给SocketServer开启WebSocket的服务 const wss = new SocketServer({ server }); //当 WebSocket 从外部连接时执行 wss.on('connection', (ws) => { //连接时执行此 console 提示 console.log('Client connected'); // 对message设置监听,接收从客户端发送的消息 ws.on('message', (data) => { //data为客户端发送的消息,将消息原封不动返回回去 ws.send(data); }); // 当WebSocket的连接关闭时执行 ws.on('close', () => { console.log('Close connected'); }); }); 执行node server.js启动服务,端口打开后会执行监听时间打印提示,说明服务启动成功 ![]() 在开启WebSocket后,服务端会在message中监听,接收参数data捕获客户端发送的消息,然后使用send发送消息 【学习地址】:FFmpeg/WebRTC/RTMP/NDK/Android音视频流媒体高级开发 ![]() ![]() 3.3.2 客户端接收发送消息 分别在根目录创建index.html和index.js文件
<body> <script src="./index.js"></script> </body> </html>
let ws = new WebSocket('ws://localhost:3000'); // 开启后的动作,指定在连接后执行的事件 ws.onopen = () => { console.log('open connection'); }; // 接收服务端发送的消息 ws.onmessage = (event) => { console.log(event); }; // 指定在关闭后执行的事件 ws.onclose = () => { console.log('close connection'); }; 上面的 ![]() 打印了 其中 手动在控制台调用 ![]() 3.3.3 服务端定时发送上面是从客户端发送消息,服务端回传。我们也可以通过 server.js修改如下: //当WebSocket从外部连接时执行wss.on('connection', (ws) => { //连接时执行此 console 提示 console.log('Client connected'); + //固定发送最新消息给客户端 + const sendNowTime = setInterval(() => { + ws.send(String(new Date())); + }, 1000); - //对message设置监听,接收从客户端发送的消息 - ws.on('message', (data) => { - //data为客户端发送的消息,将消息原封不动返回回去 - ws.send(data); - }); //当 WebSocket的连接关闭时执行 ws.on('close', () => { console.log('Close connected'); }); }); 客户端连接后就会定时接收,直至我们关闭websocket服务 ![]() 3.3.4 多人聊天如果多个客户端连接按照上面的方式只会返回各自发送的消息,先注释服务端定时发送,开启两个窗口模拟: ![]() 如果我们要让客户端间消息共享,也同时接收到服务端回传的消息呢? 我们可以使用 修改server.js如下: ...//当WebSocket从外部连接时执行 wss.on('connection', (ws) => { //连接时执行此 console 提示 console.log('Client connected'); - //固定发送最新消息给客户端 - const sendNowTime = setInterval(() => { - ws.send(String(new Date())); - }, 1000); + //对message设置监听,接收从客户端发送的消息 + ws.on('message', (data) => { + //取得所有连接中的 客户端 + let clients = wss.clients; + //循环,发送消息至每个客户端 + clients.forEach((client) => { + client.send(data); + }); + }); //当WebSocket的连接关闭时执行 ws.on('close', () => { console.log('Close connected'); }); }); 这样一来,不论在哪个客户端发送消息,服务端都能将消息回传到每个客户端 : ![]() 可以观察下连接信息: ![]() ![]() 4、总结纸上得来终觉浅,绝知此事要躬行,希望大家可以把理论配合上面的实例进行消化,搭好服务端也可以直接使用测试工具好好玩耍一波 ![]() 5、参考文章阮一峰-WebSocket 教程 Using WebSockets on Heroku with Node.js WebSocket 是什么原理?为什么可以实现持久连接? 6、扩展如果你觉得本文对你有帮助,可以查看我的其他文章: Web开发应了解的5种设计模式 10个简单的技巧让你的 vue.js 代码更优雅 Web开发应该知道的数据结构 经典面试题!从输入URL到页面展示你还不赶紧学起来? 浅谈SSL协议的握手过程 原文链接:https://juejin.cn/post/6876301731966713869 |
万奢网手机版
官网微博:万奢网服务平台