iOS系統SRWebSocket的源碼解析上

　　一。 前言：

　　WebSocket協議是基于TCP的一種新的網絡協議。它實現了瀏覽器與服務器全雙工（full-duplex）通信——可以通俗的解釋為服務器主動發送信息給客戶端。

　　區別于MQTT、XMPP等聊天的應用層協議，它是一個傳輸通訊協議。它有著自己一套連接握手，以及數據傳輸的規范。

　　而本文要講到的SRWebSocket就是iOS中使用websocket必用的一個框架，它是用Facebook提供的。

　　關于WebSocket起源與發展，是怎么由：輪詢、長輪詢、再到websocket的，可以看看冰霜這篇文章：

　　微信，QQ這類IM app怎么做——談談Websocket

　　關于SRWebSocket的API用法，可以看看樓主之前這篇文章：

　　iOS即時通訊，從入門到“放棄”？

　　二。 SRWebSocket的對外的業務流程：

　　首先貼一段SRWebSocket的API調用代碼：

　　//初始化socket并且連接

　　- （void）connectServer：（NSString *）server port：（NSString *）port

　　{

　　NSURLRequest *request = ［NSURLRequest requestWithURL：［NSURL URLWithString：［NSString stringWithFormat：@“ws://%@：%@”，server，port］］］;

　　_socket = ［［SRWebSocket alloc］ initWithURLRequest:request］;

　　_socket.delegate = self;

　?。踎socket open］;

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didReceiveMessage：（id）message

　　{

　　}

　　- （void）webSocketDidOpen：（SRWebSocket *）webSocket

　　{

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didFailWithError：（NSError *）error

　　{

　　}

　　- （void）webSocket：（SRWebSocket *）webSocket didCloseWithCode：（NSInteger）code reason：（NSString *）reason wasClean：（BOOL）wasClean

　　{

　　}

　　要簡單使用起來，總共就4行代碼，并且實現你需要的代理即可，整個業務邏輯非常簡潔。

　　但是就這么幾個對外的方法，SRWebSocket.m里面用了2000行代碼來進行封裝，那么它到底做了什么？我們接著往下看：

　　三。 SRWebSocket的初始化以及連接流程：

　　1首先我們初始化：

　　//初始化

　　- （void）_SR_commonInit;

　　{

　　//得到url schem小寫

　　NSString *scheme = _url.scheme.lowercaseString;

　　//如果不是這幾種，則斷言錯誤

　　assert（［scheme isEqualToString：@“ws”］ || ［scheme isEqualToString：@“http”］ || ［scheme isEqualToString：@“wss”］ || ［scheme isEqualToString：@“https”］）;

　　_readyState = SR_CONNECTING;

　　_webSocketVersion = 13;

　　//初始化工作的隊列，串行

　　_workQueue = dispatch_queue_create（NULL， DISPATCH_QUEUE_SERIAL）;

　　//給隊列設置一個標識，標識為指向自己的，上下文對象為這個隊列

　　dispatch_queue_set_specific（_workQueue， （__bridge void *）self， maybe_bridge（_workQueue）， NULL）;

　　//設置代理queue為主隊列

　　_delegateDispatchQueue = dispatch_get_main_queue（）;

　　//retain主隊列？

　　sr_dispatch_retain（_delegateDispatchQueue）;

　　//讀Buffer

　　_readBuffer = ［［NSMutableData alloc］ init］;

　　//輸出Buffer

　　_outputBuffer = ［［NSMutableData alloc］ init］;

　　//當前數據幀

　　_currentFrameData = ［［NSMutableData alloc］ init］;

　　//消費者數據幀的對象

　　_consumers = ［［NSMutableArray alloc］ init］;

　　_consumerPool = ［［SRIOConsumerPool alloc］ init］;

　　//注冊的runloop

　　_scheduledRunloops = ［［NSMutableSet alloc］ init］;

　　。。.。省略了一部分代碼

　　}

　　會初始化一些屬性：

　　包括對schem進行斷言，只支持ws/wss/http/https四種。

　　當前socket狀態，是正在連接，還是已連接、斷開等等。

　　初始化工作隊列，以及流回調線程等等。