服务器端推送技术在web开发中比较常用,在早期最简单的解决方案是采用ajax向服务器轮询消息,这种方式的轮询频率不好控制,会导致服务器的压力 。稍优的方案为:当客户端向服务器发送请求时,服务器端会抓住这个请求不放,等有数据更新的时候才返回给客户端,当客户端接收到数据后再次发送请求,周而复始,这样就大大减少了请求次数,减轻了服务器的压力 。这里我么使用webSokcet实现服务器端消息推送 。
下面我们一次说一下什么是 websocket 已经如何实用js 实现对websocket 数据的获取,并实现数据交互的长连接 。
1. 什么是websocket及特点:
由于http请求只能由客户端发起,所有当服务器资源有变化时,客户端只能通过轮询的方式 。非常浪费资源 。
websocket的特点:
服务器可以主动向客户端推送信息,客户端也可以主动向服务器发送信息,是真正的双向平等对话,属于服务器推送技术的一种建立在 TCP 协议之上,服务器端的实现比较容易可以发送文本,也可以发送二进制数据没有同源限制,客户端可以与任意服务器通信协议标识符是ws(如果加密,则为wss),服务器网址就是 URL 。如ws:localhost:8081/msg.
2. JS示例
var ws = new WebSocket("ws://localhost:8080/msg");ws.onopen = function(evt) { console.log("Connection open ..."); ws.send("Hello WebSockets!");};ws.onmessage = function(evt) { console.log("Received Message: " + evt.data); ws.close();};ws.onclose = function(evt) { console.log("Connection closed.");};3. api
1. websocket构造函数
【js实现websocket 数据交互】用于创建一个webSocket实例,执行后,客户端就会与服务端连接
var ws = new WebSocket("ws://localhost:8080/msg");2. webSocket.readyState
readyState属性返回实例对象的当前状态,共有四种 。
CONNECTING:值为0,表示正在连接 。OPEN:值为1,表示连接成功,可以通信了 。CLOSING:值为2,表示连接正在关闭 。CLOSED:值为3,表示连接已经关闭,或者打开连接失败例如:if(ws.readyState ==WebSocket.CONNECTING){}3. webSocket.onopen
用于指定连接成功后的回调函数
ws.onopen = function(evt) { console.log("Connection open ..."); ws.send("Hello WebSockets!");};或者:
ws.addEventListener('open', function (event) { ws.send('Hello Server!');});4. webSocket.onclose
用于指定连接关闭后的回调函数 。
ws.onclose = function(event) { var code = event.code; var reason = event.reason; var wasClean = event.wasClean;};ws.addEventListener("close", function(event) { var code = event.code; var reason = event.reason; var wasClean = event.wasClean;});5. webSocket.onmessage
用于指定收到服务器数据后的回调函数
ws.onmessage = function(event) { var data = https://www.isolves.com/it/cxkf/yy/js/2019-09-05/event.data;}; ws.addEventListener("message", function(event) { var data = event.data;});服务器数据有可能是文本,也有可能是二进制数据,需要判断
ws.onmessage = function(event){ if(typeof event.data =https://www.isolves.com/it/cxkf/yy/js/2019-09-05/== String) { console.log("Received data string"); }if(event.data instanceof ArrayBuffer){ var buffer = event.data; console.log("Received arraybuffer"); }}除了动态判断收到的数据类型,也可以使用binaryType属性,显式指定收到的二进制数据类型
// 收到的是 blob 数据
ws.binaryType = "blob";
ws.onmessage = function(e) { console.log(e.data.size);}; // 收到的是 ArrayBuffer 数据ws.binaryType = "arraybuffer";ws.onmessage = function(e) { console.log(e.data.byteLength);};6. webSocket.send()
send方法用于向服务器发送数据
发送文本
ws.send("Hello WebSockets!");
发送Blob数据
var file = document .querySelector('input[type="file"]') .files[0];ws.send(file);发送ArrayBuffervar img = canvas_context.getImageData(0, 0, 400, 320);var binary = new Uint8Array(img.data.length);for (var i = 0; i < img.data.length; i++) { binary[i] = img.data[i];}ws.send(binary.buffer);7. webSocket.bufferedAmount
bufferedAmount属性,表示还有多少字节的二进制数据没有发送出去 。它可以用来判断发送是否结束
var data = https://www.isolves.com/it/cxkf/yy/js/2019-09-05/new ArrayBuffer(10000000);socket.send(data); if (socket.bufferedAmount === 0) { // 发送完毕} else { // 发送还没结束}8. webSocket.onerror
用于指定报错时的回调函数
ws.onerror = function(event) {}; es.addEventListener("error", function(event) {});至此,一个基于JS的WebSocket通信实例构建完毕 。
推荐阅读
- 抖音,头条这类自媒体的推荐机制是什么?大数据如何给你贴标签?
- 大数据黄码多久能转绿码 黄码自己会变绿码吗
- 如果你换新手机,旧手机必做这2步处理!以免隐私数据泄露
- 手机连接WiFi后,需要关掉数据流量吗?运营商给出了“答案”
- 超详细的mysql数据库主备切换演练教程,值得收藏
- mysql导入数据
- 利用jQuery实现简单的数据双向绑定
- https实现原理
- 如何设计实现一个通用的分布式事务框架?
- 苹果手机不支持通话录音!!跟着我实现苹果手机通话录音功能