微信,QQ这类IM app怎么做——谈谈Websocket
<p style="text-align:center"><img src="https://simg.open-open.com/show/a3f88e89a351b29e78a94908fe222752.jpg"></p> <h2>前言</h2> <p>关于我和WebSocket的缘:我从大二在计算机网络课上听老师讲过之后,第一次使用就到了毕业之后的第一份工作。直到最近换了工作,到了一家是含有IM社交聊天功能的app的时候,我觉得我现在可以谈谈我对WebSocket/Socket的一些看法了。要想做IM聊天app,就不得不理解WebSocket和Socket的原理了,听我一一道来。</p> <h2>目录</h2> <p>1.WebSocket使用场景</p> <p>2.WebSocket诞生由来</p> <p>3.谈谈WebSocket协议原理</p> <p>4.WebSocket 和 Socket的区别与联系</p> <p>5.iOS平台有哪些WebSocket和Socket的开源框架</p> <p>6.iOS平台如何实现WebSocket协议</p> <h2>一.WebSocket的使用场景</h2> <p>1.社交聊天</p> <p>最著名的就是微信,QQ,这一类社交聊天的app。这一类聊天app的特点是低延迟,高即时。即时是这里面要求最高的,如果有一个紧急的事情,通过IM软件通知你,假设网络环境良好的情况下,这条message还无法立即送达到你的客户端上,紧急的事情都结束了,你才收到消息,那么这个软件肯定是失败的。</p> <p>2.弹幕</p> <p>说到这里,大家一定里面想到了A站和B站了。确实,他们的弹幕一直是一种特色。而且弹幕对于一个视频来说,很可能弹幕才是精华。发弹幕需要实时显示,也需要和聊天一样,需要即时。</p> <p>3.多玩家游戏</p> <p>4.协同编辑</p> <p>现在很多开源项目都是分散在世界各地的开发者一起协同开发,此时就会用到版本控制系统,比如Git,SVN去合并冲突。但是如果有一份文档,支持多人实时在线协同编辑,那么此时就会用到比如WebSocket了,它可以保证各个编辑者都在编辑同一个文档,此时不需要用到Git,SVN这些版本控制,因为在协同编辑界面就会实时看到对方编辑了什么,谁在修改哪些段落和文字。</p> <p>5.股票基金实时报价</p> <p>金融界瞬息万变——几乎是每毫秒都在变化。如果采用的网络架构无法满足实时性,那么就会给客户带来巨大的损失。几毫秒钱股票开始大跌,几秒以后才刷新数据,一秒钟的时间内,很可能用户就已经损失巨大财产了。</p> <p>6.体育实况更新</p> <p>全世界的球迷,体育爱好者特别多,当然大家在关心自己喜欢的体育活动的时候,比赛实时的赛况是他们最最关心的事情。这类新闻中最好的体验就是利用Websocket达到实时的更新!</p> <p>7.视频会议/聊天</p> <p>视频会议并不能代替和真人相见,但是他能让分布在全球天涯海角的人聚在电脑前一起开会。既能节省大家聚在一起路上花费的时间,讨论聚会地点的纠结,还能随时随地,只要有网络就可以开会。</p> <p>8.基于位置的应用</p> <p>越来越多的开发者借用移动设备的GPS功能来实现他们基于位置的网络应用。如果你一直记录用户的位置(比如运行应用来记录运动轨迹),你可以收集到更加细致化的数据。</p> <p>9.在线教育</p> <p>在线教育近几年也发展迅速。优点很多,免去了场地的限制,能让名师的资源合理的分配给全国各地想要学习知识的同学手上,Websocket是个不错的选择,可以视频聊天、即时聊天以及其与别人合作一起在网上讨论问题...</p> <p>10.智能家居</p> <p>这也是我一毕业加入的一个伟大的物联网智能家居的公司。考虑到家里的智能设备的状态必须需要实时的展现在手机app客户端上,毫无疑问选择了Websocket。</p> <p>11.总结</p> <p>从上面我列举的这些场景来看,一个共同点就是,高实时性!</p> <h2>二.WebSocket诞生由来</h2> <p>1.最开始的轮询Polling阶段</p> <p style="text-align:center"><img src="https://simg.open-open.com/show/66e6821858abc19070c971c1c604d149.jpg"></p> <p>这种方式下,是不适合获取实时信息的,客户端和服务器之间会一直进行连接,每隔一段时间就询问一次。客户端会轮询,有没有新消息。这种方式连接数会很多,一个接受,一个发送。而且每次发送请求都会有Http的Header,会很耗流量,也会消耗CPU的利用率。</p> <p>2.改进版的长轮询Long polling阶段</p> <p><img src="https://simg.open-open.com/show/8c122d2b6976440da5c45fa9e2517643.jpg"></p> <p>长轮询是对轮询的改进版,客户端发送HTTP给服务器之后,有没有新消息,如果没有新消息,就一直等待。当有新消息的时候,才会返回给客户端。在某种程度上减小了网络带宽和CPU利用率等问题。但是这种方式还是有一种弊端:例如假设服务器端的数据更新速度很快,服务器在传送一个数据包给客户端后必须等待客户端的下一个Get请求到来,才能传递第二个更新的数据包给客户端,那么这样的话,客户端显示实时数据最快的时间为2×RTT(往返时间),而且如果在网络拥塞的情况下,这个时间用户是不能接受的,比如在股市的的报价上。另外,由于http数据包的头部数据量往往很大(通常有400多个字节),但是真正被服务器需要的数据却很少(有时只有10个字节左右),这样的数据包在网络上周期性的传输,难免对网络带宽是一种浪费。</p> <p>3.WebSocket诞生</p> <p>现在急需的需求是能支持客户端和服务器端的双向通信,而且协议的头部又没有HTTP的Header那么大,于是,Websocket就诞生了!</p> <p style="text-align:center"><img src="https://simg.open-open.com/show/4b1690706e2c4c3be0df4b4153873345.png"></p> <p>上图就是Websocket和Polling的区别,从图中可以看到Polling里面客户端发送了好多Request,而下图,只有一个Upgrade,非常简洁高效。至于消耗方面的比较就要看下图了</p> <p style="text-align:center"><img src="https://simg.open-open.com/show/9590d68db56eeee05125081842aac06f.png"></p> <p>上图中,我们先看蓝色的柱状图,是Polling轮询消耗的流量,</p> <p>Use case A:1,000 clients polling every second: Network throughput is (871 x 1,000) = 871,000 bytes = 6,968,000 bits per second (6.6 Mbps)</p> <p>Use case B:10,000 clients polling every second: Network throughput is (871 x 10,000) = 8,710,000 bytes = 69,680,000 bits per second (66 Mbps)</p> <p>Use case C:100,000 clients polling every 1 second: Network throughput is (871 x 100,000) = 87,100,000 bytes = 696,800,000 bits per second (665 Mbps)</p> <p>而Websocket的Frame是 just two bytes of overhead instead of 871,仅仅用2个字节就代替了轮询的871字节!</p> <p>Use case A:1,000 clients receive 1 message per second: Network throughput is (2 x 1,000) = 2,000 bytes = 16,000 bits per second (0.015 Mbps)</p> <p>Use case B:10,000 clients receive 1 message per second: Network throughput is (2 x 10,000) = 20,000 bytes = 160,000 bits per second (0.153 Mbps)</p> <p>Use case C:100,000 clients receive 1 message per second: Network throughput is (2 x 100,000) = 200,000 bytes = 1,600,000 bits per second (1.526 Mbps)</p> <p>相同的每秒客户端轮询的次数,当次数高达10W/s的高频率次数的时候,Polling轮询需要消耗665Mbps,而Websocket仅仅只花费了1.526Mbps,将近435倍!!</p> <h2>三.谈谈WebSocket协议原理</h2> <p>Websocket是应用层第七层上的一个应用层协议,它必须依赖 <a href="/misc/goto?guid=4959673809304583128" rel="nofollow,noindex">HTTP 协议进行一次握手</a> ,握手成功后,数据就直接从 TCP 通道传输,与 HTTP 无关了。</p> <p>Websocket的数据传输是frame形式传输的,比如会将一条消息分为几个frame,按照先后顺序传输出去。这样做会有几个好处:</p> <p>1)大数据的传输可以分片传输,不用考虑到数据大小导致的长度标志位不足够的情况。</p> <p>2)和http的chunk一样,可以边生成数据边传递消息,即提高传输效率。</p> <p style="text-align:center"><img src="https://simg.open-open.com/show/462e9ded6fce5aef30fa7bce68528814.png"></p> <h2>四.WebSocket 和 Socket的区别与联系</h2> <p>首先, Socket 其实并不是一个协议。它工作在 OSI 模型会话层(第5层),是为了方便大家直接使用更底层协议(一般是 TCP 或 UDP )而存在的一个抽象层。Socket是对TCP/IP协议的封装,Socket本身并不是协议,而是一个调用接口(API)。</p> <p><img src="https://simg.open-open.com/show/eabc18b728f49dd98cdccd6dd60dda5b.jpg"></p> <p>Socket通常也称作”套接字”,用于描述IP地址和端口,是一个通信链的句柄。网络上的两个程序通过一个双向的通讯连接实现数据的交换,这个双向链路的一端称为一个Socket,一个Socket由一个IP地址和一个端口号唯一确定。应用程序通常通过”套接字”向网络发出请求或者应答网络请求。</p> <p>Socket在通讯过程中,服务端监听某个端口是否有连接请求,客户端向服务端发送连接请求,服务端收到连接请求向客户端发出接收消息,这样一个连接就建立起来了。客户端和服务端也都可以相互发送消息与对方进行通讯,直到双方连接断开。</p> <p>所以基于WebSocket和基于Socket都可以开发出IM社交聊天类的app</p> <h2>五.iOS平台有哪些WebSocket和Socket的开源框架</h2> <p>Socket开源框架有: <a href="/misc/goto?guid=4958870675441281877" rel="nofollow,noindex">CocoaAsyncSocket</a> , <a href="/misc/goto?guid=4958968172878425183" rel="nofollow,noindex">socketio/socket.io-client-swift</a></p> <p>WebSocket开源框架有: <a href="/misc/goto?guid=4959673809445494564" rel="nofollow,noindex">非死book/SocketRocket</a> , <a href="/misc/goto?guid=4958875644332488200" rel="nofollow,noindex">tidwall/SwiftWebSocket</a></p> <h2>六.iOS平台如何实现WebSocket协议</h2> <p>Talk is cheap。Show me the code ——Linus Torvalds</p> <p>我们今天来看看 <a href="/misc/goto?guid=4959673809445494564" rel="nofollow,noindex">非死book/SocketRocket</a> 的实现方法</p> <p>首先这是SRWebSocket定义的一些成员变量</p> <pre> <code class="language-objectivec">@property (nonatomic, weak) id delegate; /** A dispatch queue for scheduling the delegate calls. The queue doesn't need be a serial queue. If `nil` and `delegateOperationQueue` is `nil`, the socket uses main queue for performing all delegate method calls. */ @property (nonatomic, strong) dispatch_queue_t delegateDispatchQueue; /** An operation queue for scheduling the delegate calls. If `nil` and `delegateOperationQueue` is `nil`, the socket uses main queue for performing all delegate method calls. */ @property (nonatomic, strong) NSOperationQueue *delegateOperationQueue; @property (nonatomic, readonly) SRReadyState readyState; @property (nonatomic, readonly, retain) NSURL *url; @property (nonatomic, readonly) CFHTTPMessageRef receivedHTTPHeaders; // Optional array of cookies (NSHTTPCookie objects) to apply to the connections @property (nonatomic, copy) NSArray *requestCookies; // This returns the negotiated protocol. // It will be nil until after the handshake completes. @property (nonatomic, readonly, copy) NSString *protocol;</code></pre> <p>下面这些是SRWebSocket的一些方法</p> <pre> <code class="language-objectivec">// Protocols should be an array of strings that turn into Sec-WebSocket-Protocol. - (instancetype)initWithURLRequest:(NSURLRequest *)request; - (instancetype)initWithURLRequest:(NSURLRequest *)request protocols:(NSArray *)protocols; - (instancetype)initWithURLRequest:(NSURLRequest *)request protocols:(NSArray *)protocols allowsUntrustedSSLCertificates:(BOOL)allowsUntrustedSSLCertificates; // Some helper constructors. - (instancetype)initWithURL:(NSURL *)url; - (instancetype)initWithURL:(NSURL *)url protocols:(NSArray *)protocols; - (instancetype)initWithURL:(NSURL *)url protocols:(NSArray *)protocols allowsUntrustedSSLCertificates:(BOOL)allowsUntrustedSSLCertificates; // By default, it will schedule itself on +[NSRunLoop SR_networkRunLoop] using defaultModes. - (void)scheduleInRunLoop:(NSRunLoop *)aRunLoop forMode:(NSString *)mode; - (void)unscheduleFromRunLoop:(NSRunLoop *)aRunLoop forMode:(NSString *)mode; // SRWebSockets are intended for one-time-use only. Open should be called once and only once. - (void)open; - (void)close; - (void)closeWithCode:(NSInteger)code reason:(NSString *)reason; ///-------------------------------------- #pragma mark Send ///-------------------------------------- //下面是4个发送的方法 /** Send a UTF-8 string or binary data to the server. @param message UTF-8 String or Data to send. @deprecated Please use `sendString:` or `sendData` instead. */ - (void)send:(id)message __attribute__((deprecated("Please use `sendString:` or `sendData` instead."))); - (void)sendString:(NSString *)string; - (void)sendData:(NSData *)data; - (void)sendPing:(NSData *)data; @end</code></pre> <p>对应5种状态的代理方法</p> <pre> <code class="language-objectivec">///-------------------------------------- #pragma mark - SRWebSocketDelegate ///-------------------------------------- @protocol SRWebSocketDelegate - (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message; @optional - (void)webSocketDidOpen:(SRWebSocket *)webSocket; - (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error; - (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean; - (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload; // Return YES to convert messages sent as Text to an NSString. Return NO to skip NSData -> NSString conversion for Text messages. Defaults to YES. - (BOOL)webSocketShouldConvertTextFrameToString:(SRWebSocket *)webSocket; @end</code></pre> <p>didReceiveMessage方法是必须实现的,用来接收消息的。</p> <p>下面4个did方法分别对应着Open,Fail,Close,ReceivePong不同状态的代理方法</p> <p>方法就上面这些了,我们实际来看看代码怎么写</p> <p>先是初始化Websocket连接,注意此处ws://或者wss://连接有且最多只能有一个,这个是Websocket协议规定的</p> <pre> <code class="language-objectivec">self.ws = [[SRWebSocket alloc] initWithURLRequest:[NSURLRequest requestWithURL:[NSURL URLWithString:[NSString stringWithFormat:@"%@://%@:%zd/ws", serverProto, serverIP, serverPort]]]]; self.ws.delegate = delegate; [self.ws open];</code></pre> <p>发送消息</p> <pre> <code class="language-objectivec">[self.ws send:message];</code></pre> <p>接收消息以及其他3个代理方法</p> <pre> <code class="language-objectivec">//这个就是接受消息的代理方法了,这里接受服务器返回的数据,方法里面就应该写处理数据,存储数据的方法了。 - (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message { NSDictionary *data = [NetworkUtils decodeData:message]; if (!data) return; } //这里是Websocket刚刚Open之后的代理方法。就想微信刚刚连接中,会显示连接中,当连接上了,就不显示连接中了,取消显示连接的方法就应该写在这里面 - (void)webSocketDidOpen:(SRWebSocket *)webSocket { // Open = silent ping [self.ws receivedPing]; } //这是关闭Websocket的代理方法 - (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean { [self failedConnection:NSLS(Disconnected)]; } //这里是连接Websocket失败的方法,这里面一般都会写重连的方法 - (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error { [self failedConnection:NSLS(Disconnected)]; }</code></pre> <h2>最后</h2> <p>以上就是我想分享的一些关于Websocket的心得,文中如果有错误的地方,欢迎大家指点!一般没有微信QQ那么大用户量的app,用Websocket应该都可以完成IM社交聊天的任务。当用户达到亿级别,应该还有很多需要优化,优化性能各种的吧。</p> <p>最后,微信和QQ的实现方法也许并不是只用Websocket和Socket这么简单,也许是他们自己开发的一套能支持这么大用户,大数据的,各方面也都优化都最优的方法。如果有开发和微信和QQ的大神看到这篇文章,可以留言说说看你们用什么方式实现的,也可以和我们一起分享,我们一起学习!我先谢谢大神们的指点了!</p> <p> </p> <p>来自: <a href="/misc/goto?guid=4959673809561138306" rel="nofollow">http://www.cocoachina.com/ios/20160527/16482.html</a></p> <p> </p>
本文由用户 63xinghang 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
转载本站原创文章,请注明出处,并保留原始链接、图片水印。
本站是一个以用户分享为主的开源技术平台,欢迎各类分享!