一、 简介
1. websocket 推送技术在 2008 诞生,2011 成为标准,现在所有浏览器都支持了。
2. 最大特点 是真正的双向平等对话,属于服务器推送技术的一种
扩展:服务器推送技术
1. webpush
Internet工程任务组的Webpush提议是一种使用HTTP版本2的简单协议,用于提供可以及时传递(或“推送”)的实时事件,例如传入呼叫或消息。该协议将所有实时事件合并到一个会话中,以确保更有效地使用网络和无线电资源。单个服务整合所有事件,在应用程序到达时将这些事件分发给应用程序。这只需要一个会话,避免重复的开销成本。
2. HTTP 服务器推送
HTTP服务器推送(也称为HTTP流)是一种用于将未经请求的(异步)数据从Web服务器发送到Web浏览器的机制。HTTP服务器推送可以通过几种机制中的任何一种来实现。
作为HTML5的一部分,WebSocket API允许Web服务器和客户端通过全双工 TCP连接进行通信。
3. pushlet
在这种技术中,服务器利用持久的HTTP连接,使响应永久“打开”(即,服务器永远不会终止响应),有效地欺骗浏览器在初始页面加载被考虑之后保持“加载”模式完成。然后,服务器定期发送JavaScript片段以更新页面内容,从而实现推送功能。通过使用这种技术,客户端不需要Java applet或其他插件来保持与服务器的开放连接; 客户端会自动通知服务器推送的新事件。[11] [12]然而,这种方法的一个严重缺点是服务器缺乏对浏览器超时的控制; 如果浏览器端发生超时,则始终需要页面刷新。
4. 长轮询
5. Flash XMLSockt 中继
Cbox和其他聊天应用程序使用的这种技术在单像素Adobe Flash电影中使用了XMLSocket对象。在控制的JavaScript,客户端建立一个TCP连接到一个单向的服务器上的继电器。中继服务器不从该套接字读取任何内容; 相反,它立即向客户端发送唯一标识符。接下来,客户端发出HTTP请求到web服务器,包括它的这个标识符。然后,Web应用程序可以将发往客户端的消息推送到中继服务器的本地接口,中继服务器通过Flash套接字对它们进行中继。这种方法的优点在于它欣赏许多Web应用程序(包括聊天)的典型自然读写不对称性,因此它提供了高效率。因为它不接受即将离任的插座数据,中继服务器不需要轮询传出TCP连接,在所有的,从而能够容纳的并发连接打开数万人。在此模型中,规模限制是底层服务器操作系统的TCP堆栈。
6. 可靠的集团数据交付(RGDD)
在云计算等服务中,为了提高数据的可靠性和可用性,通常会将其推送(复制)到多台计算机上。例如,Hadoop分布式文件系统(HDFS)为存储的任何对象生成2个额外副本。RGDD专注于有效地将对象从一个位置转换为多个位置,同时通过在网络上的任何链接上发送对象的最小数量的副本(在最佳情况下只有一个)来节省带宽。例如,Datacast [15]是一种向数据中心内的许多节点传递的方案,它依赖于常规和结构化拓扑,DCCast [16]是一种跨数据中心交付的类似方法。
7. 推送通知
推送通知是从后端服务器或应用程序“推送”到用户界面的消息,例如(但不限于)移动应用程序和桌面应用程序。Apple于2009年首次推出推送通知。[17] 2010年,Google发布了自己的服务,即Google Cloud to Device Messaging。(此后它已被Google云消息传递和Firebase云消息传递所取代。)[18] 2015年11月,微软宣布推出Windows通知服务将扩展为使用通用Windows平台架构,允许使用通用API调用和POST请求将推送数据发送到Windows 10,Windows 10移动版,Xbox以及其他支持的平台。[19]
特点包括:
(1)建立在 TCP 协议之上,服务器端的实现比较容易。
(2)与 HTTP 协议有着良好的兼容性。默认端口也是80和443,并且握手阶段采用 HTTP 协议,因此握手时不容易屏蔽,能通过各种 HTTP 代理服务器。
(3)数据格式比较轻量,性能开销小,通信高效。
(4)可以发送文本,也可以发送二进制数据。
(5)没有同源限制,客户端可以与任意服务器通信。
(6)协议标识符是ws(如果加密,则为wss),服务器网址就是 URL。
ws://example.com:80/some/path
二、客户端示例
var ws = new WebSocket("wss://echo.websocket.org"); 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."); };
三、客户端 API
4.1 构造函数
var ws = new WebSocket('ws://localhost:8080');
4.2 webSocket.readyState
readyState 属性返回实例对象的当前状态,共有四种
CONNECTING:值为0,表示正在连接。 OPEN:值为1,表示连接成功,可以通信了。 CLOSING:值为2,表示连接正在关闭。 CLOSED:值为3,表示连接已经关闭,或者打开连接失败。
示例
switch (ws.readyState) { case WebSocket.CONNECTING: // do something break; case WebSocket.OPEN: // do something break; case WebSocket.CLOSING: // do something break; case WebSocket.CLOSED: // do something break; default: // this never happens break; }
4.3 webSocket.onopen
实例对象的 onopen 属性,用于指定连接成功后的回调函数
ws.onopen = function () { ws.send('Hello Server!'); }
如果指定多个回调函数,可以使用 addEventListnenr 方法
ws.addEventListener('open', function (event) { ws.send('Hello Server!'); });
4.4 webSocket.onclose
实例对象的 onclose 属性,用于指定连接关闭后的回调函数
ws.onclose = function(event) { var code = event.code; var reason = event.reason; var wasClean = event.wasClean; // handle close event }; ws.addEventListener("close", function(event) { var code = event.code; var reason = event.reason; var wasClean = event.wasClean; // handle close event });
4.5 webSocket.onmessage
实例对象的 onmessage 属性,用于指定收到服务器数据后的回调函数
ws.onmessage = function(event) { var data = event.data; // 处理数据 }; ws.addEventListener("message", function(event) { var data = event.data; // 处理数据 });
注意,服务器数据可能是文本,也可能是二进制数据(blob 对象或 Arraybuffer 对象)
ws.onmessage = function(event){ if(typeof event.data === String) { console.log("Received data string"); } if(event.data instanceof ArrayBuffer){ var buffer = event.data; console.log("Received arraybuffer"); } }
出来动态判断收到的数据类型,也可以使用 binaryType 属性,显式指定收到的二进制数据类
// Sending canvas ImageData as ArrayBuffer var 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);
型。
// 收到的是 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); };
4.6 webSocket.sed()
实例对象的 send() 方法用于向服务器发送数据
发送文本的例子
ws.send('your message');
发送 Blob 对象的例子
var file = document .querySelector('input[type="file"]') .files[0]; ws.send(file);
发送 ArrayBuffer 对象的例子
// Sending canvas ImageData as ArrayBuffer var 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);
4.7 webSocket.bufferedAmount
实例对象的bufferedAmount属性,表示还有多少字节的二进制数据没有发送出去。它可以用来判断发送是否结束。
var data = new ArrayBuffer(10000000); socket.send(data); if (socket.bufferedAmount === 0) { // 发送完毕 } else { // 发送还没结束 }
4.8 webSocket.onerror
实例对象的onerror属性,用于指定报错时的回调函数。
socket.onerror = function(event) { // handle error event }; socket.addEventListener("error", function(event) { // handle error event });
来看看,因为,总能学到东西!