作者:Gaby原文链接https:juejin。cnpost7020964728386093093一。前言 踩着年末的尾巴,提前布局来年,为来年的工作做个好的铺垫,所以就开始了面试历程,因为项目中使用到了WebSocket,面试官在深挖项目经验的时候,也难免提到WebSocket相关的知识点,因为之前并没有考虑这么深,所以,回答的还是有所欠缺,因此,赶紧趁热再熟悉熟悉,也借此机会,整理出来供大家咀嚼,每个项目都有其值得挖掘的闪光点,要用有爱的眼睛去发现。二。什么是WebSocket WebSocket是一种在单个TCP连接上进行全双工通信的协议。WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。 在WebSocketAPI中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。(维基百科) WebSocket本质上一种计算机网络应用层的协议,用来弥补http协议在持久通信能力上的不足。 WebSocket协议在2008年诞生,2011年成为国际标准。现在最新版本浏览器都已经支持了。 它的最大特点就是,服务器可以主动向客户端推送信息,客户端也可以主动向服务器发送信息,是真正的双向平等对话,属于服务器推送技术的一种。 WebSocket的其他特点包括:(1)建立在TCP协议之上,服务器端的实现比较容易。(2)与HTTP协议有着良好的兼容性。默认端口也是80和443,并且握手阶段采用HTTP协议,因此握手时不容易屏蔽,能通过各种HTTP代理服务器。(3)数据格式比较轻量,性能开销小,通信高效。(4)可以发送文本,也可以发送二进制数据。(5)没有同源限制,客户端可以与任意服务器通信。(6)协议标识符是ws(如果加密,则为wss),服务器网址就是URL。ws:example。com:80somepath 为什么需要WebSocket? 我们已经有了HTTP协议,为什么还需要另一个协议?它能带来什么好处? 因为HTTP协议有一个缺陷:通信只能由客户端发起,不具备服务器推送能力。 举例来说,我们想了解查询今天的实时数据,只能是客户端向服务器发出请求,服务器返回查询结果。HTTP协议做不到服务器主动向客户端推送信息。 这种单向请求的特点,注定了如果服务器有连续的状态变化,客户端要获知就非常麻烦。我们只能使用轮询:每隔一段时候,就发出一个询问,了解服务器有没有新的信息。最典型的场景就是聊天室。轮询的效率低,非常浪费资源(因为必须不停连接,或者HTTP连接始终打开)。 在WebSocket协议出现以前,创建一个和服务端进双通道通信的web应用,需要依赖HTTP协议,进行不停的轮询,这会导致一些问题:服务端被迫维持来自每个客户端的大量不同的连接大量的轮询请求会造成高开销,比如会带上多余的header,造成了无用的数据传输。 http协议本身是没有持久通信能力的,但是我们在实际的应用中,是很需要这种能力的,所以,为了解决这些问题,WebSocket协议由此而生,于2011年被IETF定为标准RFC6455,并被RFC7936所补充规范。并且在HTML5标准中增加了有关WebSocket协议的相关api,所以只要实现了HTML5标准的客户端,就可以与支持WebSocket协议的服务器进行全双工的持久通信了。WebSocket与HTTP的区别 WebSocket与HTTP的关系图: 相同点:都是一样基于TCP的,都是可靠性传输协议。都是应用层协议。联系:WebSocket在建立握手时,数据是通过HTTP传输的。但是建立之后,在真正传输时候是不需要HTTP协议的。 下面一张图说明了HTTP与WebSocket的主要区别: 不同点:1、WebSocket是双向通信协议,模拟Socket协议,可以双向发送或接受信息,而HTTP是单向的;2、WebSocket是需要浏览器和服务器握手进行建立连接的,而http是浏览器发起向服务器的连接。3、虽然HTTP2也具备服务器推送功能,但HTTP2只能推送静态资源,无法推送指定的信息。三、WebSocket协议的原理 与http协议一样,WebSocket协议也需要通过已建立的TCP连接来传输数据。具体实现上是通过http协议建立通道,然后在此基础上用真正WebSocket协议进行通信,所以WebSocket协议和http协议是有一定的交叉关系的。首先,WebSocket是一个持久化的协议,相对于HTTP这种非持久的协议来说。简单的举个例子吧,用目前应用比较广泛的PHP生命周期来解释。 HTTP的生命周期通过Request来界定,也就是一个Request一个Response,那么在HTTP1。0中,这次HTTP请求就结束了。 在HTTP1。1中进行了改进,使得有一个keepalive,也就是说,在一个HTTP连接中,可以发送多个Request,接收多个Response。但是请记住RequestResponse,在HTTP中永远是这样,也就是说一个Request只能有一个Response。而且这个Response也是被动的,不能主动发起。首先WebSocket是基于HTTP协议的,或者说借用了HTTP协议来完成一部分握手。 首先我们来看个典型的WebSocket握手GETchatHTTP1。1Host:server。example。comUpgrade:websocketConnection:UpgradeSecWebSocketKey:x3JJHMbDL1EzLkh9GBhXDwSecWebSocketProtocol:chat,superchatSecWebSocketVersion:13Origin:http:example。com 熟悉HTTP的童鞋可能发现了,这段类似HTTP协议的握手请求中,多了这么几个东西。Upgrade:websocketConnection:Upgrade 这个就是WebSocket的核心了,告诉Apache、Nginx等服务器:注意啦,我发起的请求要用WebSocket协议,快点帮我找到对应的助理处理而不是那个老土的HTTP。SecWebSocketKey:x3JJHMbDL1EzLkh9GBhXDwSecWebSocketProtocol:chat,superchatSecWebSocketVersion:13首先,SecWebSocketKey是一个Base64encode的值,这个是浏览器随机生成的,告诉服务器:泥煤,不要忽悠我,我要验证你是不是真的是WebSocket助理。然后,SecWebSocketProtocol是一个用户定义的字符串,用来区分同URL下,不同的服务所需要的协议。简单理解:今晚我要服务A,别搞错啦最后,SecWebSocketVersion是告诉服务器所使用的WebSocketDraft(协议版本),在最初的时候,WebSocket协议还在Draft阶段,各种奇奇怪怪的协议都有,而且还有很多期奇奇怪怪不同的东西,什么Firefox和Chrome用的不是一个版本之类的,当初WebSocket协议太多可是一个大难题不过现在还好,已经定下来啦大家都使用同一个版本:服务员,我要的是13岁的噢然后服务器会返回下列东西,表示已经接受到请求,成功建立WebSocket啦!HTTP1。1101SwitchingProtocolsUpgrade:websocketConnection:UpgradeSecWebSocketAccept:HSmrc0sMlYUkAGmm5OPpG2HaGWkSecWebSocketProtocol:chat 这里开始就是HTTP最后负责的区域了,告诉客户,我已经成功切换协议啦Upgrade:websocketConnection:Upgrade 依然是固定的,告诉客户端即将升级的是WebSocket协议,而不是mozillasocket,lurnarsocket或者shitsocket。 然后,SecWebSocketAccept这个则是经过服务器确认,并且加密过后的SecWebSocketKey。服务器:好啦好啦,知道啦,给你看我的IDCARD来证明行了吧。后面的,SecWebSocketProtocol则是表示最终使用的协议。至此,HTTP已经完成它所有工作了,接下来就是完全按照WebSocket协议进行了。总结,WebSocket连接的过程是:首先,客户端发起http请求,经过3次握手后,建立起TCP连接;http请求里存放WebSocket支持的版本号等信息,如:Upgrade、Connection、WebSocketVersion等;然后,服务器收到客户端的握手请求后,同样采用HTTP协议回馈数据;最后,客户端收到连接成功的消息后,开始借助于TCP传输信道进行全双工通信。四、Websocket的优缺点 优点:WebSocket协议一旦建议后,互相沟通所消耗的请求头是很小的服务器可以向客户端推送消息了 缺点:少部分浏览器不支持,浏览器支持的程度与方式有区别(IE10)五、WebSocket应用场景即时聊天通信多玩家游戏在线协同编辑编辑实时数据流的拉取与推送体育游戏实况实时地图位置即时Web应用程序:即时Web应用程序使用一个Web套接字在客户端显示数据,这些数据由后端服务器连续发送。在WebSocket中,数据被连续推送传输到已经打开的同一连接中,这就是为什么WebSocket更快并提高了应用程序性能的原因。例如在交易网站或比特币交易中,这是最不稳定的事情,它用于显示价格波动,数据被后端服务器使用Web套接字通道连续推送到客户端。游戏应用程序:在游戏应用程序中,你可能会注意到,服务器会持续接收数据,而不会刷新用户界面。屏幕上的用户界面会自动刷新,而且不需要建立新的连接,因此在WebSocket游戏应用程序中非常有帮助。聊天应用程序:聊天应用程序仅使用WebSocket建立一次连接,便能在订阅户之间交换,发布和广播消息。它重复使用相同的WebSocket连接,用于发送和接收消息以及一对一的消息传输。六、websocket断线重连 心跳就是客户端定时的给服务端发送消息,证明客户端是在线的,如果超过一定的时间没有发送则就是离线了。如何判断在线离线? 当客户端第一次发送请求至服务端时会携带唯一标识、以及时间戳,服务端到db或者缓存去查询改请求的唯一标识,如果不存在就存入db或者缓存中,第二次客户端定时再次发送请求依旧携带唯一标识、以及时间戳,服务端到db或者缓存去查询改请求的唯一标识,如果存在就把上次的时间戳拿取出来,使用当前时间戳减去上次的时间,得出的毫秒秒数判断是否大于指定的时间,若小于的话就是在线,否则就是离线;如何解决断线问题 通过查阅资料了解到nginx代理的websocket转发,无消息连接会出现超时断开问题。网上资料提到解决方案两种,一种是修改nginx配置信息,第二种是websocket发送心跳包。下面就来总结一下本次项目实践中解决的websocket的断线和重连这两个问题的解决方案。主动触发包括主动断开连接,客户端主动发送消息给后端1主动断开连接ws。close(); 主动断开连接,根据需要使用,基本很少用到。2主动发送消息ws。send(helloworld);断线的可能原因1:websocket超时没有消息自动断开连接,应对措施:这时候我们就需要知道服务端设置的超时时长是多少,在小于超时时间内发送心跳包,有2中方案:一种是客户端主动发送上行心跳包,另一种方案是服务端主动发送下行心跳包。 下面主要讲一下客户端也就是前端如何实现心跳包: 首先了解一下心跳包机制 跳包之所以叫心跳包是因为:它像心跳一样每隔固定时间发一次,以此来告诉服务器,这个客户端还活着。事实上这是为了保持长连接,至于这个包的内容,是没有什么特别规定的,不过一般都是很小的包,或者只包含包头的一个空包。 在TCP的机制里面,本身是存在有心跳包的机制的,也就是TCP的选项:SOKEEPALIVE。系统默认是设置的2小时的心跳频率。但是它检查不到机器断电、网线拔出、防火墙这些断线。而且逻辑层处理断线可能也不是那么好处理。一般,如果只是用于保活还是可以的。 心跳包一般来说都是在逻辑层发送空的echo包来实现的。下一个定时器,在一定时间间隔下发送一个空包给客户端,然后客户端反馈一个同样的空包回来,服务器如果在一定时间内收不到客户端发送过来的反馈包,那就只有认定说掉线了。 在长连接下,有可能很长一段时间都没有数据往来。理论上说,这个连接是一直保持连接的,但是实际情况中,如果中间节点出现什么故障是难以知道的。更要命的是,有的节点(防火墙)会自动把一定时间之内没有数据交互的连接给断掉。在这个时候,就需要我们的心跳包了,用于维持长连接,保活。 心跳检测步骤:客户端每隔一个时间间隔发生一个探测包给服务器客户端发包时启动一个超时定时器服务器端接收到检测包,应该回应一个包如果客户机收到服务器的应答包,则说明服务器正常,删除超时定时器如果客户端的超时定时器超时,依然没有收到应答包,则说明服务器挂了前端解决方案:心跳检测varheartCheck{timeout:30000,30秒发一次心跳timeoutObj:null,serverTimeoutObj:null,reset:function(){clearTimeout(this。timeoutObj);clearTimeout(this。serverTimeoutObj);},start:function(){this。timeoutObjsetTimeout(function(){这里发送一个心跳,后端收到后,返回一个心跳消息,onmessage拿到返回的心跳就说明连接正常ws。send(ping);console。log(ping!)self。serverTimeoutObjsetTimeout(function(){如果超过一定时间还没重置,说明后端主动断开了ws。close();如果onclose会执行reconnect,我们执行ws。close()就行了。如果直接执行reconnect会触发onclose导致重连两次},self。timeout);},this。timeout);}}断线的可能原因2:websocket异常包括服务端出现中断,交互切屏等等客户端异常中断等等当若服务端宕机了,客户端怎么做、服务端再次上线时怎么做?客户端则需要断开连接,通过onclose关闭连接,服务端再次上线时则需要清除之间存的数据,若不清除则会造成只要请求到服务端的都会被视为离线。 针对这种异常的中断解决方案就是处理重连,下面我们给出的重连方案是使用js库处理:引入reconnectingwebsocket。min。js,ws建立链接方法使用js库api方法:varwsnewReconnectingWebSocket(url);断线重连:reconnectSocket(){if(wsinwindow){wsnewReconnectingWebSocket(url);}elseif(MozWebSocketinwindow){wsnewMozWebSocket(url);}else{wsnewSockJS(url);}} 断网监测支持使用js库:offline。min。jsonLineCheck(){Offline。check();console。log(Offline。state,Offline。state);console。log(this。socketStatus,this。socketStatus);if(!this。socketStatus){console。log(网络连接已断开!);if(Offline。stateupwebsocket。reconnectAttemptswebsocket。maxReconnectInterval){window。location。reload();}reconnectSocket();}else{console。log(网络连接成功!);websocket。send(heartBeat);}}使用:在websocket断开链接时调用网络中断监测websocket。onclose(){onLineCheck();}; 以上方案,只是抛砖引玉,如果大家有更好的解决方案欢迎评论区分享交流。七、总结 WebSocket是为了在web应用上进行双通道通信而产生的协议,相比于轮询HTTP请求的方式,WebSocket有节省服务器资源,效率高等优点。WebSocket中的掩码是为了防止早期版本中存在中间缓存污染攻击等问题而设置的,客户端向服务端发送数据需要掩码,服务端向客户端发送数据不需要掩码。WebSocket中SecWebSocketKey的生成算法是拼接服务端和客户端生成的字符串,进行SHA1哈希算法,再用base64编码。WebSocket协议握手是依靠HTTP协议的,依靠于HTTP响应101进行协议升级转换。参考阮一峰:WebSocket教程看完让你彻底理解WebSocket原理